Netty框架怎么样「Netty框架的使用教程」

用 Netty 实现 Echo 程序服务端

下面的示例代码基于 Netty 实现了 echo 程序服务端：首先创建了一个事件处理器（等同于 Reactor 模式中的事件处理器），然后创建了 bossGroup 和 workerGroup，再之后创建并初始化了 ServerBootstrap，代码还是很简单的，不过有两个地方需要注意一下。

第一个，如果 NettybossGroup 只监听一个端口，那 bossGroup 只需要 1 个 EventLoop就可以了，多了纯属浪费。

第二个，默认情况下，Netty 会创建“2*CPU 核数”个 EventLoop，由于网络连接与EventLoop 有稳定的关系，所以事件处理器在处理网络事件的时候是不能有阻塞操作的，否则很容易导致请求大面积超时。如果实在无法避免使用阻塞操作，那可以通过线程池来异步处理。

/* 事件处理器 */
final EchoServerHandler serverHandler
    = new EchoServerHandler();
/* boss 线程组 */
EventLoopGroup bossGroup
    = new NioEventLoopGroup( 1 );
/* worker 线程组 */
EventLoopGroup workerGroup
    = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group( bossGroup, workerGroup )
    .channel( NioServerSocketChannel.class )
    .childHandler( new ChannelInitializer<SocketChannel>()
               {
                   @Override
                   public void initChannel( SocketChannel ch )
                   {
                       ch.pipeline().addLast( serverHandler );
                   }
               } );
    /* bind 服务端端口 */
    ChannelFuture f = b.bind( 9090 ).sync();
    f.channel().closeFuture().sync();
} finally {
    /* 终止工作线程组 */
    workerGroup.shutdownGracefully();
    /* 终止 boss 线程组 */
    bossGroup.shutdownGracefully();
}

/* socket 连接处理器 */
class EchoServerHandler extends
ChannelInboundHandlerAdapter {
    /* 处理读事件 */
    @Override
    public void channelRead(
        ChannelHandlerContext ctx, Object msg )
    {
        ctx.write( msg );
    }

    /* 处理读完成事件 */
    @Override
    public void channelReadComplete(
        ChannelHandlerContext ctx )
    {
        ctx.flush();
    }

    /* 处理异常事件 */
    @Override
    public void exceptionCaught(
        ChannelHandlerContext ctx, Throwable cause )
    {
        cause.printStackTrace();
        ctx.close();
    }
}

总结

Netty 是一个款优秀的网络编程框架，性能非常好，为了实现高性能的目标，Netty 做了很多优化，例如优化了 ByteBuffer、支持零拷贝等等，和并发编程相关的就是它的线程模型了。Netty 的线程模型设计得很精巧，每个网络连接都关联到了一个线程上，这样做的好处是：对于一个网络连接，读写操作都是单线程执行的，从而避免了并发程序的各种问题。