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

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

主从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模式的基本结构：

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）来实现高性能的网络服务器。