如何构建一个简单的RPC调用

服务端

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
     .channel(NioServerSocketChannel.class)
     .option(ChannelOption.SO_BACKLOG, 100)
     .handler(new LoggingHandler(LogLevel.INFO))
     .childHandler(new ChannelInitializer<SocketChannel>() {
        @Override
        public void initChannel(SocketChannel ch) throws Exception {
            ChannelPipeline p = ch.pipeline();
            p.addLast(new RpcEncoder(RpcRequest.class));
            p.addLast(new RpcDecoder(RpcResponse.class));
            p.addLast(new RpcHandler());
        }});
     // Start the server.
     ChannelFuture f = b.bind(PORT).sync();
     // Wait until the server socket is closed.
     f.channel().closeFuture().sync();
} finally {
    // Shut down all event loops to terminate all threads.
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
}

客户端
 
 EventLoopGroup group = new NioEventLoopGroup();
 try {
     Bootstrap b = new Bootstrap();
     b.group(group)
      .channel(NioSocketChannel.class)
      .option(ChannelOption.TCP_NODELAY, true)
      .handler(new ChannelInitializer<SocketChannel>() {
        @Override
        public void initChannel(SocketChannel ch) throws Exception {
         ChannelPipeline p = ch.pipeline();
         p.addLast(new RpcEncoder(RpcResponse.class));
         p.addLast(new RpcDecoder(RpcRequest.class));
         p.addLast(new RpcClientHandler());
        }});
     // Start the client.
     ChannelFuture f = b.connect(HOST, PORT).sync();
     // Wait until the connection is closed.
     f.channel().closeFuture().sync();
 } finally {
     // Shut down the event loop to terminate all threads.
     group.shutdownGracefully();
 }