NIOReactor

NIO和BIO

多路IO复用

Reactor模式

高性能IO的发展历程:单线程阻塞->多线程并发->事件驱动NIO
单线程阻塞&＃xff1a;最大问题是无法并发&＃xff0c;效率太低&＃xff0c;当前请求没有处理完&＃xff0c;后面的请求一直排队等待&＃xff0c;通常是一个while循环&＃xff0c;accept&＃xff0c;有数据后执行&＃xff0c;执行完成后执行while下一次循环
多线程并发&＃xff1a;一个连接一个线程&＃xff0c;缺点是&＃xff1a;资源要求太高&＃xff0c;系统中创建线程是需要比较高的系统资源的&＃xff0c;如果连接数太高&＃xff0c;系统无法承受&＃xff0c;而且&＃xff0c;线程的反复创建-销毁也需要代价。
事件驱动NIO&＃xff1a;reactor模型&＃xff0c;当有事件触发时&＃xff0c;才会调用处理器进行数据处理&＃xff0c;一个线程调度大量事件给不同的handler&＃xff0c;高并发。

1、Reactor线程模型和生产消费模式

reactor和生产消费模式有点像&＃xff0c;都是基于"变化"的处理模式。
生产消费模式&＃xff0c;一般是生产者将生产出来的消息存储到消息队列中&＃xff0c;消费者冲消息队列中拿到消息进行异步处理&＃xff1b;
生产消费模式主要解耦了生产者和消费者&＃xff0c;能够解决生产者和消费者处理速度不一致的问题。

2、Reactor模型详解

Reactor和Handler两个组件&＃xff1a;

&＃xff08;1&＃xff09;Reactor&＃xff1a;负责响应IO事件&＃xff0c;当检测到一个新的事件&＃xff0c;将其发送给相应的Handler去处理&＃xff1b;新的事件包含连接建立就绪、读就绪、写就绪等。

&＃xff08;2&＃xff09;Handler:将自身&＃xff08;handler&＃xff09;与事件绑定&＃xff0c;负责事件的处理&＃xff0c;完成channel的读入&＃xff0c;完成处理业务逻辑后&＃xff0c;负责将结果写出channel。

3、Reactor与Netty

服务端启动时创建了两个NioEventLoopGroup&＃xff0c;一个是boss&＃xff0c;一个是worker。实际上他们是两个独立的Reactor线程池&＃xff0c;一个用于接收客户端的TCP连接&＃xff0c;另一个用于处理Io相关的读写操作&＃xff0c;或则执行系统的Task&＃xff0c;定时Task。
Boss线程池职责如下&＃xff1a;
&＃xff08;1&＃xff09;接收客户端的连接&＃xff0c;初始化Channel参数
&＃xff08;2&＃xff09;将链路状态变更时间通知给ChannelPipeline

worker线程池作用是&＃xff1a;
&＃xff08;1&＃xff09;异步读取通信对端的数据报&＃xff0c;发送读事件到ChannelPipeline
&＃xff08;2&＃xff09;异步发送消息到通信对端&＃xff0c;调用ChannelPipeline的消息发送接口
&＃xff08;3&＃xff09;执行系统调用Task;
&＃xff08;4&＃xff09;执行定时任务Task&＃xff1b;