Reactor模式

整个 reactor 模式解决的主要问题就是在接收到任务后根据分发器快速进行分发给相应的事件处理器，不需要从开始状态就阻塞。

基于事件驱动模型，当接收到请求后会将请求封装成事件，并将事件分发给相应处理事件的Handler，handler处理完成后将事件状态修改为下一个状态，再由Reactor将事件分发给能够处理下一个状态的handler进行处理。

EventHandler：事件处理器，可以根据事件的不同状态创建处理不同状态的处理器；

java

public abstract class EventHandler {

    /**
     * 事件处理
     * @param event
     */
    public abstract void handle(Event event);

}

ReadEventHandler
AcceptEventHandler

Handle：可以理解为事件，在网络编程中就是一个Socket，在数据库操作中就是一个DBConnection；
- Event

InitiationDispatcher：用于管理EventHandler，分发event的容器，也是一个事件处理调度器，Tomcat 的 Dispatcher 就是一个很好的实现，用于接收到网络请求后进行第一步的任务分发，分发给相应的处理器去异步处理，来保证吞吐量；

java

    public void handlerEvents(){
        ExecutorService executorService = ThreadUtil.newExecutor(1);
        //同步非阻塞
        //线程池异步提交
        executorService.execute(this::dispatch);
    }

    public void dispatch(){
        while (true){
            //从 selector 中阻塞获取数据
            List<Event> events = selector.select();
            for (Event event : events) {
                //分发处理
                EventHandler eventHandler = eventHandlerMap.getOrDefault(event.getEventType(),null);
                if(Objects.isNull(eventHandler)){
                    continue;
                }
                //处理事件
                eventHandler.handle(event);
            }
        }
    }

Demultiplexer：阻塞等待一系列的 Handle 中的事件到来，如果阻塞等待返回，即表示在返回的 Handle 中可以不阻塞的执行返回的事件类型。这个模块一般使用操作系统的select来实现。在 Java NIO 中用 Selector 来封装，当 Selector.select() 返回时，可以调用 Selector的 selectedKeys() 方法获取 Set<SelectionKey>，一个SelectionKey 表达一个有事件发生的 Channel 以及该 Channel 上的事件类型。