• 什么是Reactor模式？
• Reactor模式由什么组成的？
• Reactor模式解决什么问题？
• Reactor模式下的三种模型
• Reactor线程模型演进
• Reactor主从线程模型-抽象模型
• Netty线程模型

相关面试题

• 什么是Reactor模式？
• Reactor模式由什么组成的？
• Reactor模式解决什么问题？
• Reactor模式线程模型有哪些？演进过程？

web处理请求架构

大多数web请求处理流程可以抽象成这几个步骤：读取(read)，解码(decode)，处理(process)，编码(encode)，发送(send)，如下图所示：

同时，处理web请求通常有两种架构：传统基于线程架构和事件驱动架构。

传统基于线程架构

概念

每个新连接创建一个线程来处理。对于长连接服务，如果一个client和server保持一个连接的话，有多少个client接入，server就需要创建同等的线程来处理。线程上下文切换，数据同步和内存消耗，对server来说，将是非常大的开销。

为了避免线程创建销毁的开销，我们通常会采用线程池，但是同样也有很大的弊端：

• 同步阻塞IO，读写阻塞，线程等待时间过长
• 在制定线程策略的时候，只能根据CPU的数目来限定可用线程资源，不能根据连接并发数目来制定，也就是连接有限制。否则很难保证对客户端请求的高效和公平。
• 多线程之间的上下文切换，造成线程使用效率并不高，并且不易扩展
• 状态数据以及其他需要保持一致的数据，需要采用并发同步控制

应用场景

传统基于线程架构适用于连接数目比较小且一次传输大量数据的场景，比如上传，下载。

事件驱动架构

事件驱动架构：可以把线程和连接解耦，线程只用于执行事件注册的回调函数。事件驱动架构由事件生产者和事件消费者组成，前者是事件的来源，它只负责监听哪些事件发生；后者是直接处理事件或者事件发生时，响应事件的实体。

Reactor模式

什么是Reactor模式？

Reactor模式是事件驱动架构的一种具体实现方法，简而言之，就是一个单线程进行循环监听就绪IO事件，并将就绪IO事件分发给对应的回调函数。

Reactor模式由什么组成的？

Reactor模式分为两个重要组成部分，Reactor和Handler。 Reactor(反应器)：循环监听就绪IO事件，并分发给回调函数。 Handler(回调函数)：执行对应IO事件的实际业务逻辑。

Reactor模式解决什么问题？

反应器模式可以实现同步的多路复用，同步是指按照事件到达的顺序分发处理。反应器 接收来自不同的客户端的消息、请求和连接，尽管客户端是并发的，但是反应器可以按照事件到达的顺序触发回调函数。因此，Reactor模式将连接和线程解耦，不需要为每个连接创建单独线程。这个问题和C10K问题相同，提供了一个解决思路。

Reactor模式下的三种模型

• 单线程模型：IO事件轮询，分发(accept)和IO事件执行(read,decode,compute,encode,send)都在一个线程中完成，如下图所示：

在单线程模型下，不仅IO操作在Reactor线程上，而非IO操作(handlder中process()方法)也在Reactor线程上执行了，当非IO操作执行慢的话，这会大大延迟IO请求响应，所以应该把非IO操作拆出来，来加速Reactor线程对IO请求响应，就出现多线程模型。

• 多线程模型：与单线程模型不同的是添加一个业务线程池，将非IO操作(业务逻辑处理)交给业务线程池来处理，提高Reactor线程的IO响应，如图所示：

在多线程模型下，虽然将非IO操作拆出去了，但是所有IO操作都在Reactor单线程中完成的。在高负载、高并发场景下，也会成为瓶颈，于是对Reactor单线程进行了优化，出现了主从线程模型。

• 主从线程模型： 相比多线程模型而言，对于多核cpu，为了充分利用资源，将Reactor拆分成了mainReactor 和 subReactor，但是，主从线程模型也有弊端，不适合大量数据传输。 mainReactor：负责监听接收(accpet)新连接，将新连接后续操作交给subReactor来处理，通常由一个线程处理。 subReactor： 负责处理IO的读写操作，通常由多个线程处理。 非IO操作依然由业务线程池来处理。

Reactor线程模型演进

Netty线程模型

Reactor主从线程模型-抽象模型

• 创建ServerSocketChannel过程(创建channel，配置非阻塞）
• ServerSocketChannel注册到mainReactor的selector对象上，监听accept事件
• mainReactor的selector监听到新连接SocketChannel，将SocketChannel注册到subReactor的selector对象上，监听read/write事件
• subReactor的selector监听到read/write事件，移交给业务线程池(对应netty的pipeline)

Netty线程模型

我们再好好看看mainReactor和subReactor，其实这两个类功能非常相似，所以Netty将mainReactor和subReactor统一成了EventLoop。对于Netty零基础的，请参考这个Reactor主从线程模型-抽象模型和下面这张图来理解EventLoop。