appleliang96 / lcrpc Goto Github PK

@RpcAutowired//实现了类似@Reference的注解，可以直接注入Rpc服务
HelloService helloService;

/**
* 异步调用+callback支持
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void asyncTest() throws ExecutionException, InterruptedException {
  AsyncInvokeFuture future = helloService.asyncHello("World");
  future.addCallBack(new AsyncCallBack() {
    @Override
    public void success(RpcResponse response) {
      System.out.println("执行成功");
    }
    @Override
    public void fail(RpcResponse response) {
      System.out.println("执行失败");
    }
  });
  System.out.println("已发送请求");
  System.out.println(future.get());
}
/**
* 同步调用支持
*/
@Test
public void helloTest2() {
  String world = helloService.hello("World");
  System.out.println(world);
}

@RpcAutowired
HelloService helloService;//在生产方只需这样注入服务即可

@RpcService(HelloService.class)//在消费者端只需加入这个注解即可
public class HelloServiceImpl implements HelloService

public class RpcContext {
    private static final ThreadLocal<RpcContext> LOCAL = new ThreadLocal<RpcContext>() {
        @Override
        protected RpcContext initialValue() {
            return new RpcContext();
        }
    };

    protected RpcContext() {
    }

    public static RpcContext getContext() {
        return LOCAL.get();
    }

    private String curThreadId;
    private String traceId;
}