一、 主从 反应器 ( Reactor ) 多线程 模式

单反应器 ( Reactor ) 单线程模型 弊端 : 反应器 ( Reactor ) 运行在一个线程中 , 同时处理客户端连接 , 与客户端数据收发 , 在高并发的情况下会产生阻塞 ;

主从 反应器 ( Reactor ) 多线程 模式 :

1 . 主反应器 ( MainReactor ) : 运行在独立的 Reactor 主线程中 , 该线程中只负责与客户端的连接请求 ;

2 . 从反应器 ( SubReactor ) : 运行在独立的 Reactor 子线程中 , 该线程中负责与客户端的读写操作 ; 在该子线程中 , 从反应器 ( Reactor ) 监听多个客户端的请求事件 , 如果监听到客户端的数据发送事件 , 将对应的业务逻辑转发给 处理器 ( Handler 进行处理 ) ;

3 . 主反应器 ( MainReactor ) 与 从反应器 ( SubReactor ) 对应关系 : 主反应器在服务器端只有一个 , 但是从反应器在服务器端 , 不只一个 , 可以运行多个 Reactor 子线程 , 每个子线程中运行一个 从反应器 ;

之后的操作与 单反应器 ( Reactor ) 多线程的处理机制一样 ;

4 . 服务器端 处理者 ( Handler ) : Handler 只负责响应业务处理的请求事件 , 不处理具体的与客户端交互的业务逻辑 , 因此不会长时间阻塞 , 其调用 read 方法读取客户端数据后 , 将业务逻辑交给 线程池 ( Worker ) 处理相关业务逻辑 , 处理完毕后 , 将结果返回 , Handler 将该结果写出到客户端 ;

5 . 服务器端 线程池 ( Worker ) : 接收 处理者 ( Handler ) 的请求 , 为将请求对应业务逻辑操作 , 分配给某个独立线程完成 , 执行完成后的结果再次返回给 处理者 ( Handler ) ,

( Handler 读取客户端数据 -> Worker 线程池分配线程执行业务处理操作 -> Handler 将结果回送给客户端 )

6 . 从反应器 ( SubReactor ) 与 线程池 ( Worker ) 对应关系 : 每个从反应器对应一个线程池 , 也就是说每个主反应器 对应多个 从反应器及配套的线程池 ;

二、 主从 反应器 ( Reactor ) 多线程 工作流程

1 . 主反应器监听连接 :

① 主反应器 ( MainReactor ) 监听连接 : 主反应器 ( MainReactor ) 在主线程中 select 监听客户端的连接事件 , 监听到客户端连接事件后 , 将事件交给 接受者 ( Acceptor ) 进行处理 ;

② 接受者 ( Acceptor ) 建立连接 : 接受者 ( Acceptor ) 调用 accept 与客户端建立连接 , 主反应器 ( MainReactor ) 将该连接交给一个 子反应器 ( SubReactor ) 管理该连接 , 这里注意一个子反应器需要管理多个连接 ;

2 . 从反应器管理多个客户端连接 :

① 连接管理队列 : 从反应器 ( SubReactor ) 中维护了一个连接队列 , 队列中的连接都是主反应器传递下来的 ;

② 创建 处理者 ( Handler ) : 从反应器 ( SubReactor ) 接受 主反应器传递的客户端连接 , 将其加入到连接队列中 , 并为该客户端连接创建 处理者 ( Handler ) ;

③ 处理者 ( Handler ) 作用 : 处理者 ( Handler ) 负责处理与对应客户端连接之间的数据交互 , 如从连接中读取客户端数据 , 写出数据到客户端中 ;

3 . 从反应器监听客户端数据上传并进行相应处理 :

① 监听客户端数据上传事件 : 从反应器 ( SubReactor ) 调用 select 方法 , 监听其管理的客户端连接 , 如果客户端有数据上传 , 会触发事件 , 从反应器就会调用该客户端连接对应的 处理者 ( Handler ) 处理事件 ;

② 读取数据并分发事件 : 处理者 ( Handler ) 处理事件 , 首先调用 read 读取客户端上传的数据 , 然后将该数据分发给 线程池 ( Worker ) ;

③ 线程池 ( Worker ) 工作 : 线程池 ( Worker ) 为事件对应的业务逻辑分配线程执行该耗时操作 , 然后将执行结果返回给 Handler ;

④ 处理结果 : 处理者 ( Handler ) 接收到该数据后 , 将结果发送给客户端 ;

三、 主从 反应器 ( Reactor ) 多线程 优缺点分析

1 . 主从 反应器 ( Reactor ) 多线程 模型优点 :

① 分工明确 , 互不干扰 :

• 主反应器 ( MainReactor ) 在主线程中运行 , 只负责客户端的连接 ;
• 多个 子反应器 ( SubReactor ) 分别在对应的子线程中运行 , 负责每个客户端连接的数据交互 , 与业务逻辑调度 ; 这里的子反应器和对应的子线程有多个 ;

② 主线程 与 子线程交互简单 : 主线程中 , 主反应器将接受者 ( Acceptor ) 建立好的连接交给子线程中的子反应器 , 除此之外 , 主线程与子线程没有其它的数据交互 ;

2 . 主从 反应器 ( Reactor ) 多线程 模型缺点 : 该模型比较复杂 , 编程时需要封装各个模块 , 如 主反应器 ( MainReactor ) , 子反应器 ( SubReactor ) , 接受者 ( Acceptor ) , 处理者 ( Handler ) , 线程池 ( Worker ) , 代码实现复杂 ;

四、 单个主 Reactor 多个从 Reactor 多线程模型元素

Netty 线程模型是在 主从 反应器 ( Reactor ) 多线程模型的基础上改进而来的 ;

1 . BossGroup : 服务器端运行一个 BossGroup , 负责处理客户端申请连接的 Accept 事件 , Selector 监听客户端的连接事件 , 监听到该事件后 , 会调用 accept 方法 , 建立服务器端与客户端的连接 ;

2 . 客户端连接 : 上述连接的载体是 NIO 中的 套接字通道 ( SocketChannle ) , 将上述 SocketChannle 封装到 NIOSocketChannle 中 ;

3 . WorkerGroup : 与 BossGroup 相对应的是 WorkerGroup , 在 WorkerGroup 中也有 Selector ;

4 . 处理者 ( Handler ) : 将建立好的连接通道 NIOSocketChannle 注册到 WorkerGroup 中的 Selector 中 , 该 Selector 监听客户端的数据传输 , 如果客户端有数据上传 , 被该 Selector 监听到 , 就会将该事件交给 Handler 进行处理 ;

五、 单个主 Reactor 多个从 Reactor 多线程模型工作流程

1 . 监听连接 : BossGroup 中维护了一个 Selector , 该 Selector 只监听 Accept 事件 , 即客户端连接事件 ;

2 . 建立连接 : Selector 监听到 Accept 事件 , 就会调用 accept 方法 , 获取对应的 套接字通道 ( SocketChannel ) , 之后将该套接字通道封装成 NIOSocketChannel ;

3 . 注册通道 : 将上述封装后的 NIOSocketChannel 注册给 Worker 线程的 Selector , 该线程中一直不停的再进行事件循环监听 , 在该线程中维护相关的与客户端的连接通道 ; 注册时 , 会将 Handler 关联对应的 NIOSocketChannel 通道 ;

4 . 处理数据交互 : 当 Worker 线程中的 Selector 监听到客户端连接数据上传事件后 , 就会调用 Handler 处理该事件 ;

六、 多个主 Reactor 多个从 Reactor 多线程模型

1 . BossGroup 线程 : 上述简单模型中 , 只有一个 BossGroup 线程 , 在 Netty 中该线程可以存在多个 , 每个 BossGroup 线程中运行一个 NioEventLoop ;

2 . NioEventLoop 作用 : 在每个 NioEventLoop 中 , 都有一个 Selector , 该 Selector 作用是循环监听 IO 事件 , 如果监听到 IO 事件 , 就处理该 IO 事件 , 然后更新处理任务队列 , 然后继续监听 ;

3 . WorkerGroup : BossGroup 线程监听到连接事件后 , 连接客户端 , 并将封装好的 NIOSocketChannel 注册给 WorkerGroup 中的某个 Selector 上 ;

文章来源: hanshuliang.blog.csdn.net，作者：韩曙亮，版权归原作者所有，如需转载，请联系作者。

原文链接：hanshuliang.blog.csdn.net/article/details/106489252