[编织消息框架][rpc]使用篇

rpc 分两部份，一个是调用者，另一方是服务提供者

调用者只关心那个服务，传相应参数，返回内容就可以

而提供者根据调用相应服务同参数，工作处理后响应内容即可

根据他们的关系可以用JAVA 接口同实现类来约束书写完成功能

 @QModel(1)

 public interface ITestEnhance {

     @QCommond(1)

     public void a(double a);

     @QCommond(2)

     public void b(float a);

     @QCommond(3)

     public void c(byte a);

     @QCommond(4)

     public void d(long a);

     @QCommond(5)

     public void e(TestMessageObject obj);

     @QCommond(6)

     public void f(AtomicLong al);

     @QCommond(7)

     public TestMessageObject g(AtomicLong a,long b,TestMessageObject c);

 }

接口

 public class TestEnhanceImpl implements ITestEnhance {

     @Override

     public void a(double a) {

     System.out.println("a接收到 数值 : " + a);

     }

     @Override

     public void b(float a) {

     System.out.println("b接收到 数值 : " + a);

     }

     @Override

     public void c(byte a) {

     System.out.println("c接收到 数值 : " + a);

     }

     @Override

     public void d(long a) {

     System.out.println("d接收到 数值 : " + a);

     }

     @Override

     public void e(TestMessageObject obj) {

     if (obj == null) {

         return;

     }

     System.out.println("e接收到 数值 : " + SerialUtil.writeValueAsString(obj));

     }

     @Override

     public void f(AtomicLong a) {

     System.out.println("f接收到 数值 : " + a.get());

     }

     @Override

     public TestMessageObject g(AtomicLong a, long b, TestMessageObject c) {

     System.out.println("g接收到 数值 : " + a.get());

     System.out.println("g接收到 数值 : " + b);

     System.out.println("g接收到 数值 : " + SerialUtil.writeValueAsString(c));

      return c;

     }

     public static void main(String[] args) {

     ITestEnhance proxyObject = QRpcFactory.loadProxy(ITestEnhance.class,1L);

     QRpcFactory.registerInvokeService(new TestEnhanceImpl());

     proxyObject.a(-0.2);

     proxyObject.b(0);

     proxyObject.c((byte) 0x0);

     proxyObject.c((byte) 0x1);

     proxyObject.d((byte) 0x1);

     proxyObject.e(TestMessageObject.of());

     proxyObject.f(new AtomicLong(-9));

     proxyObject.e(null);

     TestMessageObject obj=proxyObject.g(new AtomicLong(-11112), Long.MAX_VALUE, TestMessageObject.of());

     SerialUtil.println(obj);

     }

 }

实现类

 /****

  *

  * @author solq

  */

 public abstract class QRpcFactory {

     private final static QRpcEnhanceService enhanceService = QRpcEnhanceService.getFactory();

     public static <T> T loadProxy(Class<T> target, QNode... nodes) {

     JavassistProxy.getDefault().register(target, enhanceService);

     T ret = JavassistProxy.getDefault().transform(target);

     IRpcContext ctx = (IRpcContext) ret;

     ctx.setContext(RpcContext.of(nodes));

     return ret;

     }

     public static <T> T loadProxy(Class<T> target, long... ids) {

     JavassistProxy.getDefault().register(target, enhanceService);

     T ret = JavassistProxy.getDefault().transform(target);

     IRpcContext ctx = (IRpcContext) ret;

     ctx.setContext(RpcContext.of(ids));

     return ret;

     }

     public static void registerInvokeService(Object target) {

     enhanceService.registerInvokeService(target);

     }

 }

rpc调用同注册工厂

 a接收到 数值 : -0.2

 b接收到 数值 : 0.0

 c接收到 数值 : 0

 c接收到 数值 : 1

 d接收到 数值 : 1

 e接收到 数值 : {"start":1487901957121}

 f接收到 数值 : -9

 g接收到 数值 : -11112

 g接收到 数值 : 9223372036854775807

 g接收到 数值 : {"start":1487901957157}

 {"start":1487901957157}

为什么要这样做？其实也可以用最原理的方式socket 或http 或JAVA 本身提供的rpc来做，自己做轮子跟使用轮子创造出来的价值是不能相比

处理做法上面说得很清楚，具体实现细节我在新书里会写出来，欢迎大家关注

巴特西

[编织消息框架][rpc]使用篇

rpc 分两部份，一个是调用者，另一方是服务提供者

最新文章

热门文章