NIO 下 Reactor 单线程

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

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

image.png
image.png

NIO 下 Reactor 单线程模型

在 Java NIO 中，Reactor 单线程模型是一种设计模式，用于处理非阻塞 I/O 操作。在这种模型中，一个单独的线程负责所有的 I/O 事件，并且对这些事件进行分发处理。这种模型的优点是减少了线程的创建和上下文切换的开销，同时简化了程序的并发模型。

核心组件

Reactor 单线程模型主要由以下几个核心组件构成：

  • Selector（选择器）: 负责监听多个通道的事件（如连接请求、数据到达等），并能够检测多个注册的通道上是否有事件发生。
  • Channel（通道）: 表示打开的连接，能夜进行非阻塞读写操作。
  • Buffer（缓冲区）: 数据的容器，在 NIO 中数据的读写都是通过 Buffer 进行的。

工作流程

Reactor 单线程模型的工作流程通常如下：

  1. 初始化: 创建一个 Selector 和一个 ServerSocketChannel，并将 ServerSocketChannel 注册到 Selector 上，通常注册的事件是 SelectionKey.OP_ACCEPT。
  2. 事件循环: 单线程运行一个无限循环，调用 Selector 的 select() 方法等待事件。
  3. 事件分发: 当事件到来时，select() 方法返回，线程处理这些事件。如果是连接请求事件，则接受连接并将返回的 SocketChannel 注册到 Selector 上，通常注册读事件 SelectionKey.OP_READ。
  4. 请求处理: 如果是读写事件，线程将从对应的 Channel 中读取或写入数据。

示例代码

下面是一个简单的 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
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
public class Reactor implements Runnable {
    private final Selector selector;
    private final ServerSocketChannel serverSocketChannel;

    public Reactor(int port) throws IOException {
        selector = Selector.open();
        serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.socket().bind(new InetSocketAddress(port));
        serverSocketChannel.configureBlocking(false);
        SelectionKey selectionKey = serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        selectionKey.attach(new Acceptor());
    }

    @Override
    public void run() {
        try {
            while (!Thread.interrupted()) {
                selector.select();
                Set<SelectionKey> selectedKeys = selector.selectedKeys();
                Iterator<SelectionKey> it = selectedKeys.iterator();
                while (it.hasNext()) {
                    dispatch(it.next());
                    it.remove();
                }
            }
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }

    void dispatch(SelectionKey key) {
        Runnable r = (Runnable) (key.attachment());
        if (r != null) {
            r.run();
        }
    }

    class Acceptor implements Runnable {
        @Override
        public void run() {
            try {
                SocketChannel socketChannel = serverSocketChannel.accept();
                if (socketChannel != null) {
                    new Handler(selector, socketChannel);
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
    }
}

在这个例子中，Reactor 类负责初始化并启动事件循环，Acceptor 类负责处理新的连接请求。Handler 类（未展示）将处理具体的读写事件。

注意事项

  • 单点性能瓶颈: 由于所有的 I/O 操作都是在单线程中处理的，因此可能会成为性能瓶颈。
  • 异常处理: 需要妥善处理 I/O 操作中可能出现的异常，以免影响整个 Reactor 线程。
  • 扩展性: 当应用程序需要处理大量并发连接或者每个连接都需要大量计算时，单线程 Reactor 可能不足以应对。这时可以考虑使用多线程或者多 Reactor 模型。

Reactor 单线程模型适用于连接数较少且每个连接上的处理逻辑不是特别复杂的场景。对于高并发场景，可能需要使用更复杂的多线程或者 Proactor 模型来提高系统的吞吐量和可伸缩性。