温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

Reactor的原理及结构是什么

发布时间:2021-12-09 15:33:20 来源:亿速云 阅读:314 作者:柒染 栏目:大数据

Reactor的原理及结构是什么,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

虽然在Java中没有真的IO多路复用模型,但是Reactor就是NIO实现多路复用的一种模式。

Reactor是什么

Reactor设计模式是一种事件处理模式,用于处理通过一个或多个输入同时交付给服务处理程序的服务请求。然后,服务处理程序对传入的请求进行多路分解,并将它们同步分发到关联的请求处理程序。

Reactor的原理及结构是什么  

从上述表述中我们大致可以总结出:

  • 基于事件驱动
  • 可以处理一个或多个输入源
  • 通过ServiceHandler同时将输入事件采用多路复用分发给相应的RequestHandler(多个)处理

对应我们的NIO中的实现:

  • 同步的等待多个事件源(Event)到达(采用select()实现)
  • 将事件多路分解以及分配相应的事件服务进行处理,这个分派采用server集中处理(Dispatch)
  • 分解的事件以及对应的事件服务应用从分派服务中分离出去(RequestHandler)
 
Reactor结构

Reactor的原理及结构是什么上述Reactor模型主要涉及的类有:

  • InitiationDispatcher:EventHandler的容器,用来注册、移除EventHandler等;另外,它作为Reactor模式的入口调用SynchronousEventDemultiplexer的select方法以阻塞等待事件的返回,当阻塞事件返回时,将事件发生的Handle分发到相应的EventHandler处理。
  • EvenHandler:定义了事件处理的方法。
  • Handle:即操作系统中的句柄,是对资源在操作系统层面上的一种抽象,它可以是打开的文件、一个连接Socket等。
  • SynchronousEventDemultiplexer:使用一个事件循环,以阻止所有的资源。当可以启动一个同步操作上的资源不会阻塞,多路分解器发送资源到分发器
 
Reactor时序图
Reactor的原理及结构是什么  
  1. 初始化InitiationDispatcher,并初始化一个Handler到EventHandler的Map
  2. 注册EventHandler到InitiationDispatcher,每个EventHandler包含Handler的引用,从而建立Handler到EventHandler的映射
  3. 调用InitiationDispatcher的handle_events()方法启动EventLoop,在EventLoop中调用select()方法(SynchronousEventDemultiplexer)阻塞等待Event发生
  4. 当某个或某些Handler的Event发生以后,select()方法返回,InitiationDispatcher根据返回的Hanler找到注册的EventHandler,并回调该EventHandler的handler_event方法
  5. 在EventHandler的handler_event()方法中还可以向InitiationDispatcher中注册新的EventHandler,比如对AcceptorEventHandler来说,当有新的client连接时,它会产生新的EventHandler以处理新的连接,并注册到InitiationDispatcher中。
 
Reactor
 
Reactor单线程模型
Reactor的原理及结构是什么  

最基本的单线程Reactor模型,Reactor负责多路分离套接字(阻塞并且当事件触发时进行分发),当有新连接触发到CONNECT事件后,交由Accptor处理,有IO读写事件交由Handler处理。

Accceptor负责获取与客户端建立的SocketChannel,绑定对应的EventHandler,当该SocketChannel上有事件发生时就可以获取到对应的EventHandler并进行处理。

 
单Reactor多线程模型
Reactor的原理及结构是什么  

相对于单Reactor模型,我们在获取到IO事件以后可以交由线程池处理,可以减少Reactor线程的消耗,Reactor从而更加专注的关注于事件的分发。

 
多Reactor多线程模型
Reactor的原理及结构是什么  
  • mainReactor负责监听ServerSocket,用来处理新连接的建立,通常单线程就可以处理,将建立的SocketChannel指定注册给subReactor。
  • subReactor(它的个数一般是和CPU个数等同)维护自己的selector,基于mainReactor注册的socketChannel多路分离IO读写事件,读写网络数据,对业务处理的功能,将其扔给worker线程池来完成。
 

关于Reactor的原理及结构是什么问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI