转载

浅谈Netty的线程模型

// 配置服务端的NIO线程组
            EventLoopGroup bossGroup = new NioEventLoopGroup();
            EventLoopGroup workerGroup = new NioEventLoopGroup();
            try {
                ServerBootstrap b = new ServerBootstrap();

                // 设置线程组及Socket参数
                b.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class)
                        .option(ChannelOption.SO_BACKLOG, 1024)
                        .childHandler(new ChildChannelHandler());
复制代码

服务端启动的时候，创建了两个NioEventLoopGroup。它们实际是两个独立的Reactor线程池。一个用于接收客户端的TCP连接，另一个用于处理IO相关的读写操作，或者执行系统Task、定时任务等。

Netty用于接收客户端请求的线程池职责如下：

接收客户端TCP连接，初始化Channel参数；
将链路状态变更事件通知给ChannelPipeline。

Netty处理IO操作的Reactor线程池职责如下：

异步读取通信对端的数据报，发送读事件到ChannalPipeline；
异步发送消息到通信对端，调用ChannelPipeline的消息发送接口；
执行系统调用task；
执行定时任务Task，例如链路空闲状态监测定时任务。

通过调整线程池的线程个数、是否共享线程池等方式，Netty的Reactor模型可以在上述模型中灵活转换。

3. 与Reactor类似却又不同

为了尽可能的提升性能，Netty在很多地方进行了无锁化设计，例如在IO线程内部进行串行操作，避免多线程竞争导致的性能下降问题。表面上看，串行化设计似乎CPU利用率不高，并发程度不够，但是，通过调整NIO线程池的线程参数，可以同时启动多个串行化的线程并行运行，这种局部无锁化的串行线程设计相比一个队列---多个工作线程的模型性能更优。

Netty的 NioEventLoop 读取到消息之后，直接调用 ChannelPipeline的fireChannelRead(Object msg) 。只要用户不主动切换线程，一直都是由 NioEventLoopLoop 调用用户的 Handler ，期间不进行线程切换。这种串行处理方式避免了多线程操作导致的锁的竞争，从性能角度看是最优的。

原文 https://juejin.im/post/5bb626945188255c9031e747

正文到此结束