Netty内置传输方式

EventLoopGroup workGroup = Epoll.isAvailable() ? new EpollEventLoopGroup(4) : new NioEventLoopGroup(4);
Bootstrap bootstrap = new Bootstrap();
bootstrap.group(workGroup)
        .channel(Epoll.isAvailable() ? EpollSocketChannel.class : NioSocketChannel.class)
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)
        .handler(new ChannelInitializer<SocketChannel>() {
            @Override
            protected void initChannel(SocketChannel ch) throws Exception {
                // Using Java Object serializable, you can also use other serializable frameworks like thrift, Protobuf and so on.
                ch.pipeline()
                        .addLast(new ObjectDecoder(1024*1024,
                                ClassResolvers.weakCachingConcurrentResolver(this.getClass().getClassLoader())) )
                        .addLast(new ObjectEncoder())
                        .addLast(new SimpleChannelInboundHandler<Object>() {
                            @Override
                            protected void channelRead0(ChannelHandlerContext ctx, Object msg) throws Exception {
                                System.out.println("Receive msg: " + msg);
                            }
                        });
            }
        });
// Connect to the server sync
channel = bootstrap.connect(host, port).sync().channel();