Nio实现细节架构图

单机RPC调用

rpc server

    public class ServerBootstrapTest {
        static {
            //1 init context
            Serializer serializer = new JavaSerializer();
            Context.<Request, Response>builder()
                    .decoder(new DefaultDecoder<>(serializer))
                    .encoder(new DefaultEncoder<>(serializer))
                    .serializer(serializer)
                    .channelHandler(new RequestHandler())
                    .executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory()))
                    .build()
                    .init();
        }

        public static void main(String[] args) throws Exception {
            // 2 init rpc server
            ServerBootstrap serverBootstrap = new ServerBootstrap(9999);
            //3 registry shutdown clean hook
            Runtime.getRuntime().addShutdownHook(new Thread(serverBootstrap::shutdown));
            //4 registry services..
            serverBootstrap.registry(UserService.class, new SimpleUserService());
            //5 started rpc server and await thread
            serverBootstrap.startup();


        }
    }

rpc client

    public class BootstrapTest {
        static {
            //1 init
            Serializer serializer = new JavaSerializer();
            Context.<Request, Response>builder()
                    .decoder(new DefaultDecoder<>(serializer))
                    .encoder(new DefaultEncoder<>(serializer))
                    .serializer(serializer)
                    .channelHandler(new ResponseHandler())
                    .executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory()))
                    .build()
                    .init();
        }

        public static void main(String[] args) throws Exception {
            //2 create client
            Bootstrap bootstrap = new Bootstrap("localhost", 9999);
            //3 started client
            bootstrap.startup();
            //4 get proxy service
            UserService service = bootstrap.getService(UserService.class);
            //5 remote invoker
            User add = service.add(new User());
            // out result
            System.out.println(add);
            //7 shutdown
            bootstrap.shutdown();

        }
    }

单机的性能测试

1.PerfServerBootstrapTest
2.PerfClientTest

集群RPC调用 依赖zookeeper注册中心

注册协议

     gdRPC 根目录
      --$|{applicationName.version.group} 模块名称.版本号.分组 account.v1.0.0.shanghai
        --|${service} 服务类全路径 com.goudai.test.UserService
            --| provider 服务提供者目录
                 --|具体的服务提通知"provider://host:port/com.goudai.test.UserService?timeout=1000&methods=test,getUser,findUser&app=gd-app&version=v1.0.0&group=gd-group"
            --| consumer 消费者目录
                 --|具体的调用者 "consumer://host:port/com.goudai.test.UserService?timeout=1000&methods=test,getUser,findUser&app=gd-app&version=v1.0.0&group=gd-group"

rpc server

    public class ServerBootTest {
         public static void main(String[] args) throws Exception {
             ClusterConfig.application = "myApp";
             //1 init context
             Serializer serializer = new JavaSerializer();
             ZooKeeRegistry registry = new ZooKeeRegistry();
             registry.startup();
             Context.<Request, Response>builder()
                     .decoder(new DefaultDecoder<>(serializer))
                     .encoder(new DefaultEncoder<>(serializer))
                     .serializer(serializer)
                     .channelHandler(new ClusterRequestHandler(registry))
                     .sessionListener(new AbstractSessionListener())
                     .executorService(Executors.newFixedThreadPool(200, new NamedThreadFactory()))
                     .build()
                     .init();
             ClusterConfig.port = 6161;
             // 2 init rpc server
             ClusterServerBootstrap serverBootstrap = new ClusterServerBootstrap(2);
             //4 registry services..
             serverBootstrap.registry(UserService.class, new SimpleUserService());
             //3 registry shutdown clean hook
             Runtime.getRuntime().addShutdownHook(new Thread(serverBootstrap::shutdown));
             //5 started rpc server and await thread
             serverBootstrap.startup();
         }
     }

集群client

    public class ClusterBootstrapTest {
               static {
                   // init
                   Serializer serializer = new JavaSerializer();
                   Context.<Request, Response>builder()
                           .decoder(new DefaultDecoder<>(serializer))
                           .encoder(new DefaultEncoder<>(serializer))
                           .serializer(serializer)
                           .channelHandler(new ResponseHandler())
                           .sessionListener(new RpcListener())
                           .executorService(Executors.newFixedThreadPool(20, new NamedThreadFactory("goudai-rpc-works", true)))
                           .build()
                           .init();
               }
               public static void main(String[] args) throws Exception {
                   //application name is requied
                   ClusterConfig.application = "myApp";
                   //2 create client
                   ZooKeeRegistry registry = new ZooKeeRegistry();
                   ClusterBootstrap clusterBootstrap = new ClusterBootstrap(registry, 1);
                   //3 started client
                   clusterBootstrap.startup();
                   //4 get proxy service
                   UserService service = clusterBootstrap.getService(UserService.class);
                   //5 remote invoker
                   User add = service.add(new User());
                   // out result
                   System.err.println(add);
                   //7 shutdown
                   clusterBootstrap.shutdown();
               }
           }