Netty组件介绍

EventLoopGroup bossGroup = new EpollEventLoopGroup(1);
EventLoopGroup workerGroup = new EpollEventLoopGroup(4);
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
            .channel(EpollServerSocketChannel.class)
            //保持长连接状态
            .childOption(ChannelOption.SO_KEEPALIVE, true)
            .childOption(ChannelOption.TCP_NODELAY, true)
            .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
            .childHandler(new HttpSnoopServerInitializer());

    ChannelFuture ch = b.bind(PORT).sync();
    if (ch.isSuccess()){
        logger.info("Http server start on port :{}", PORT );
    }

    ch.channel().closeFuture().sync();
} finally {
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
}

EventLoopGroup eventLoopGroup = new EpollEventLoopGroup(8);
Bootstrap bootstrap = new Bootstrap()
        .group(eventLoopGroup)
        .option(ChannelOption.SO_KEEPALIVE, true)
        .option(ChannelOption.TCP_NODELAY, true)
        .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
        .channel(EpollSocketChannel.class)
        .handler(new RpcClientInitializer());
Channel channel = bootstrap.connect("127.0.0.1", port).sync().channel();