Java 举例说明Reactor模式

Java中的NIO框架就是基于Reactor模式实现的，下面以NIO为例说明Reactor模式的应用。

在NIO中，Reactor被称为Selector，它负责监控所有的Channel，当某个Channel有数据可读或可写时，Selector就会通知对应的Handler进行处理。Handler通常以回调函数的形式实现，例如：

class ReadHandler implements CompletionHandler<Integer, ByteBuffer> {
    private AsynchronousSocketChannel channel;
    public ReadHandler(AsynchronousSocketChannel channel) {
        this.channel = channel;
    }
    public void completed(Integer result, ByteBuffer buffer) {
        if (result == -1) {
            try {
                channel.close();
            } catch (IOException e) {
                // ignore
            }
            return;
        }
        buffer.flip();
        byte[] bytes = new byte[buffer.remaining()];
        buffer.get(bytes);
        String message = new String(bytes);
        System.out.println("Received message: " + message);
        buffer.clear();
        channel.read(buffer, buffer, this);
    }
    public void failed(Throwable exc, ByteBuffer buffer) {
        // handle error
    }
}

上面的ReadHandler实现了CompletionHandler接口，它作为回调函数来处理读事件。当Selector监测到某个Channel可读时，会调用ReadHandler的completed方法来处理该事件。在completed方法中，我们可以读取Channel中的数据，并通过ByteBuffer传递给业务逻辑处理。读取完成后，我们再次调用channel.read方法来监听下一次读事件。

通过NIO框架，我们可以实现高并发、高吞吐量的IO操作，同时也能够降低系统的资源消耗。