主从 Reactor 多线程

send

请求

Client

select

业务处理

Worker线程1

建立连接

Reactor子线程

Worker线程池

处理请求

dispatch

read

Handler

方案说明：Reactor 主线程 MainReactor 对象通过 Select 监控建立连接事件，收到事件后通过 Acceptor 接收，处理建立连接事件。Acceptor 处理建立连接事件后，MainReactor 将连接分配 Reactor 子线程给 SubReactor 进行处理。SubReactor 将连接加入连接队列进行监听，并创建一个 Handler 用于处理各种连接事件。当有新的事件发生时，SubReactor 会调用连接对应的 Handler 进行响应。Handler 通过 Read 读取数据后，会分发给后面的 Worker 线程池进行业务处理。Worker 线程池会分配独立的线程完成真正的业务处理，如何将响应结果发给 Handler 进行处理。Handler 收到响应结果后通过 Send 将响应结果返回给 Client。

Worker1

应用程序

Reactor主线程

MainReactor

accept

SubReactor

Acceptor