一、工作原理图

1、简单版

Netty 主要基于主从 Reactors 多线程模型（如图）做了一定的改进，其中主从 Reactor 多线程模型有多个 Reactor。
image.png
对上图说明

  1. BossGroup 线程维护 Selector，只关注 Accecpt
  2. 当接收到 Accept 事件，获取到对应的 SocketChannel，封装成 NIOScoketChannel 并注册到 Worker 线程（事件循环），并进行维护

  3. 当 Worker 线程监听到 Selector 中通道发生自己感兴趣的事件后，就进行处理（就由 handler），注意 handler 已经加入到通道

    2、进阶版

    image.png
    BossGroup 有点像主 Reactor 可以有多个，WorkerGroup 则像 SubReactor 一样可以有多个。
    可以类比 https://www.yuque.com/wangchao-volk4/fdw9ek/aynyrf#QzvDN

    3、详细版

    image.png

  4. Netty 抽象出两组线程池 ，BossGroup 专门负责接收客户端的连接，WorkerGroup 专门负责网络的读写

  5. BossGroup 和 WorkerGroup 类型都是 NioEventLoopGroup
  6. NioEventLoopGroup 相当于一个事件循环组，这个组中含有多个事件循环，每一个事件循环是 NioEventLoop
  7. NioEventLoop 表示一个不断循环的执行处理任务的线程，每个 NioEventLoop 都有一个 Selector，用于监听绑定在其上的 socket 的网络通讯
  8. NioEventLoopGroup 可以有多个线程，即可以含有多个 NioEventLoop
  9. 每个 BossGroup下面的NioEventLoop 循环执行的步骤有 3 步
    • 轮询 accept 事件
    • 处理 accept 事件，与 client 建立连接，生成 NioScocketChannel，并将其注册到某个 workerGroup NIOEventLoop 上的 Selector
    • 继续处理任务队列的任务，即 runAllTasks
  10. 每个 WorkerGroup NIOEventLoop 循环执行的步骤
    • 轮询 read，write 事件
    • 处理 I/O 事件，即 read，write 事件，在对应 NioScocketChannel 处理
    • 处理任务队列的任务，即 runAllTasks
  11. 每个 Worker NIOEventLoop 处理业务时，会使用 pipeline（管道），pipeline 中包含了 channel（通道），即通过 pipeline 可以获取到对应通道，管道中维护了很多的处理器（ChannelHandler）。（这个点目前只是简单的讲，后面重点说）