simple-rpc

一个简单的 Rpc 框架。

服务端代码样例：

RpcServer rpcServer = RpcServer.builder()
    .port(8998)
    .zoo("127.0.0.1:2181")
    .bossThread(1)
    .workThread(4)
    .addListener(new MethodInvocationListener() {
        @Override
        public Object around(MethodInvocationPoint point) throws Throwable {
            // to do something as framework level without any business.
            // to add monitor.
            return point.proceed();
        }
    })
    .build();
rpcServer.start(); //启动服务
rpcServer.publish(HelloWordService.class, new HelloWordServiceImpl()); //注册服务

关闭服务

rpcServer.shutdown();

客户端代码样例：

RpcClient rpcClient = RpcClient.builder()
    .zkCoon("127.0.0.1:2181")
    .timeout(3000)
    .addListener(new MethodInvocationListener() {
      @Override
      public Object around(MethodInvocationPoint point) throws Throwable {
          // to do something as framework level without any business.
          // to add monitor.
          return point.proceed();
      }
    })
    .build();
rpcClient.init();
HelloWordService helloWordService = rpcClient.proxy(HelloWordService.class); //代理服务
helloWordService.sayHello(); //调用远程服务

关闭客户端

rpcClient.close();