主从 Reactor 工作模式

有的时候博客内容会有变动，首发博客是最新的，其他博客地址可能会未同步, 认准 https://blog.zysicyj.top

全网最细面试题手册，支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java 面试题，不建议你死记硬背，只要每天复习一遍，有个大概印象就行了。https://store.amazingmemo.com/chapterDetail/1685324709017001`

image.png

主从 Reactor 工作模式

在网络编程中，Reactor 模式是一种事件处理的模式，用于处理服务端接收到的并发请求。它的主要目的是在单线程或多线程环境下高效地处理多个客户端的连接和请求。主从 Reactor 工作模式是 Reactor 模式的一种变种，它使用了多个 Reactor。

基本概念

在深入主从 Reactor 工作模式之前，我们先了解一下基本的 Reactor 模式。

Reactor 模式

  • 单 Reactor 单线程：最简单的 Reactor 模式，所有的 I/O 操作（包括接受连接、读写数据）和业务逻辑都在同一个线程中处理。
  • 单 Reactor 多线程：在这种模式下，Reactor 负责 I/O 操作，业务处理交给工作线程池，可以处理更多的并发连接和业务。

主从 Reactor 工作模式

主从 Reactor 工作模式是对单 Reactor 多线程模式的扩展，它使用了多个 Reactor。通常情况下，主从 Reactor 工作模式包含一个主 Reactor 和多个从 Reactor。

主 Reactor

  • 负责处理客户端的连接请求。
  • 将新的连接分配给从 Reactor 进行后续的 I/O 处理。

从 Reactor

  • 负责处理与客户端之间的读写请求。
  • 每个从 Reactor 通常会有自己的线程池来处理具体的业务逻辑。

工作流程

  1. 初始化：启动主 Reactor 线程，监听客户端连接请求。
  2. 连接分配：当有新的客户端连接时，主 Reactor 接受连接，并将得到的 SocketChannel 注册到某个从 Reactor 上。
  3. 请求处理：从 Reactor 负责后续的 I/O 读写事件，并将读取到的数据传递给工作线程池进行业务处理。
  4. 响应客户端：工作线程处理完业务逻辑后，将响应结果写回到客户端。

优点

  • 高效的连接管理：主 Reactor 专注于连接的接受，避免了大量连接时的性能瓶颈。
  • 高效的请求处理：从 Reactor 处理所有的 I/O 操作，可以平衡负载，提高系统的吞吐量。
  • 资源利用最大化：通过线程池的使用，可以有效地利用系统资源，提高并发处理能力。

应用场景

  • 高并发服务器：如 Web 服务器、数据库服务器等。
  • 实时通信平台：如即时通讯、游戏服务器等。

示例代码

以下是一个简化的 Java 伪代码示例，展示了主从 Reactor 模式的基本结构：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
public class MainReactor implements Runnable {
    // ... 初始化 Selector 和 ServerSocketChannel

    public void run() {
        while (!Thread.interrupted()) {
            // 处理新的连接
            SocketChannel clientChannel = serverSocketChannel.accept();
            if (clientChannel != null) {
                // 分配给从 Reactor
                subReactor.register(clientChannel);
            }
        }
    }
}

public class SubReactor implements Runnable {
    // ... 初始化 Selector 和线程池

    public void run() {
        while (!Thread.interrupted()) {
            // 处理 I/O 事件
            // ... 读写操作
            // 提交业务处理任务到线程池
            threadPool.submit(new BusinessTask());
        }
    }
}

public class BusinessTask implements Runnable {
    public void run() {
        // 处理业务逻辑
    }
}

在实际应用中，主从 Reactor 模式可以结合 NIO（非阻塞 I/O）来实现高性能的网络服务器。