Netty Reator（三）Reactor 模型

Netty Reator（三）Reactor 模型

Netty 系列目录 (http://www.javashuo.com/article/p-hskusway-em.html)

本文介绍 DC Schmidt 大神的一篇文章《Reactor: an object behavioral pattern for concurrent event demultiplexing and event handler dispatching》

1、What：Reactor 模式是什么？

反应器设计模式(Reactor pattern)是一种为处理并发服务请求，并将请求提交到一个或者多个服务处理程序的事件设计模式。当客户端请求抵达后，服务处理程序使用多路分配策略，由一个非阻塞的线程来接收全部的请求，而后派发这些请求至相关的工做线程进行处理。 Reactor模式主要包含下面几部份内容。

1. 初始事件分发器(Initialization Dispatcher) ：用于管理 Event Handler，定义注册、移除 EventHandler 等。它还做为 Reactor 模式的入口调用 Synchronous Event Demultiplexer 的 select 方法以阻塞等待事件返回，当阻塞等待返回时，根据事件发生的 Handle 将其分发给对应的 Event Handler 处理，即回调 EventHandler 中的 handle_event() 方法

2. 同步(多路)事件分离器(Synchronous Event Demultiplexer) ：无限循环等待新事件的到来，一旦发现有新的事件到来，就会通知初始事件分发器去调取特定的事件处理器。

3. 系统处理程序(Handles) ：操做系统中的句柄，是对资源在操做系统层面上的一种抽象，它能够是打开的文件、一个链接(Socket)、Timer 等。因为 Reactor 模式通常使用在网络编程中，于是这里通常指 Socket Handle，即一个网络链接（Connection，在 Java NIO 中的 Channel）。这个 Channel 注册到 Synchronous Event Demultiplexer 中，以监听 Handle 中发生的事件，对 ServerSocketChannnel 能够是 CONNECT 事件，对 SocketChannel 能够是 READ、WRITE、CLOSE 事件等。

4. 事件处理器(Event Handler) ： 定义事件处理方法，以供 Initialization Dispatcher 回调使用。

1、Why：为何使用 Reactor 模式？

(1) Part A

对于一个事件驱动的分布式日志登陆服务系统，以下图1所示。

客户端应用经过日志服务来录入它们当前状态和记录，这些状态可记录可能包含了错误通知信息、断点调试信息等。日志记录被发送到一个中央日服务器上，该服务器能够处理日志和链接用户请求。客户端想要记录日志信息，首先必须发送一个链接请求给服务器。服务器经过一个“处理工厂”来监听客户端对应的地址信息，以等待这些链接请求的到来。当一个链接请求到来时，“处理工厂”就建立一个handle，其表明了链接的端点，用来创建客户端和服务器之间的链接。当handle收到来自客户端的请求链接时，就会返回给服务器。一旦客户端链接成功，它们就能够同时发送日志记录到服务器。

(2) Part B

或许最有效的方法来开发一个并发日志系统是使用多线程，这样能够同时处多个理客户端请求，以下图2所示。

然而，多线程实现这样的分布式日志系统可能会面临下面的问题：

1. 可用性：服务器必须可以处理传入请求即便是等待其余请求到达的。特别是，一个服务器不能无限期地处理任何单一来源的事件而排斥其余事件源。由于这可能大大延迟响应其余客户的时间。
2. 效率：一个服务器应该作到延迟最小化、吞吐量最大化，避免没必要要地使用CPU。多线程可能会致使糟糕的性能因为上下文切换、同步和数据移动。
3. 编程简洁：服务器的设计上应该简化使用合适的并发策略。多线程可能须要复杂的并发控制方案。
4. 可移植性：多线程不是可用在全部操做系统平台。
5. 适应性：集成新的或改进服务，如改变消息格式或添加服务器端缓存，应该承担最小的现有代码的修改和维护成本。例如，实现新应用程序服务应该不须要修改通用事件多路分解和调度机制。

(3) Part C

针对上面的问题，能够集成同步多路分解事件并分发相应的事件处理程序来处理相应的事件。对于每个应用程序所提供的服务，引入一个单独的事件处理器处理某些类型的事件。全部事件处理程序实现了相同的接口。事件处理程序注册一个初始调度程序，它使用一个同步事件信号分离器等待事件发生。当事件发生时，同步事件信号分离器通知初始调度器，它同步告知事件处理程序去关联对应的事件。事件处理程序而后分派事件到实现了所请求服务的方法中。

客户端链接到日志服务器所通过的一系列步骤以下图所示：

日志服务器记录日志所通过的一系列步骤以下图所示：

2、Reactor 模型

针对上面的问题，能够集成同步多路分解事件并分发相应的事件处理程序来处理相应的事件。对于每个应用程序所提供的服务，引入一个单独的事件处理器处理某些类型的事件。全部事件处理程序实现了相同的接口。事件处理程序注册一个初始调度程序，它使用一个同步事件信号分离器等待事件发生。当事件发生时，同步事件信号分离器通知初始调度器，它同步告知事件处理程序去关联对应的事件。事件处理程序而后分派事件到实现了所请求服务的方法中。

上述日志系统的 Reactor 模式类图以下所示：

参考：

1. 《Reactor 模型》：https://blog.csdn.net/pistolove/article/details/53152708

---

天天用心记录一点点。内容也许不重要，但习惯很重要！