Reactor模型就是网络服务器用来处理高并发网络IO请求的一种编程模型。
一般我们网络交互都是基于客户端服务端模式,然后就会有如下事件
所以一般的网络请求就包含如上三种事件:连接事件、写事件、读事件
Reactor 模型中一般有三种角色。这三种角色分别与上面网络请求中的三种事件,即
本来看似 只需要acceptor
、handler
这两种角色就可以对应三毛的三种事件,为什么会多出来了Reactor
这个角色呢。因为在高并发场景中,连接事件、读写事件会同时发生,所以我们需要一个角色专门去监听和分配事件,这个职责就落到了reactor
头上来了。下面图片就三者的关系
在理解了Reactor
模型后,我们再来聊聊Netty中Reactor
模型的实现
Reactor
模型的实现EventLoopGroup eventLoopGroup = new NioEventLoopGroup(1); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(eventLoopGroup);
可以看到从连接的建立,并创建handler来处理后续的各种业务时间,都是一个线程执行所有事情
缺点很明显:
EventLoopGroup eventLoopGroup = new NioEventLoopGroup(); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(eventLoopGroup);
这里与上面的Reactor 单线程模式相比,我们没有设置NioEventLoopGroup
的线程数,如果跟源码会发现如果没有设置线程数默认是CPu核数的2倍的线程数
优点:
1. 使用了多线程去处理业务和连接,不会因为某个业务处理阻塞导致服务端无法处理请求
缺点:
1. 连接事件和业务处理没有分开,不够解耦 2. 可能因为业务的处理效率影响连接的处理
EventLoopGroup bossGroup = new NioEventLoopGroup(); EventLoopGroup workerGroup = new NioEventLoopGroup(); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(bossGroup, workerGroup);
主从Reactor多线程模式中我们使用了两个NioEventLoopGroup
线程池,将连接和业务处理分开了,用了一个专门的线程池去处理连接请求。这也就对应多Reactor多线程模型,也是目前最主流的使用方式