服务器Reactor架构浅析ACE、libev、NIO

Reactor模式是一个架构模式,它主要解决的问题是高并发场景下的服务器的性能问题

原来的服务器与客户端的链接是一对一的,也就是说一个客户端socket接到后,对应一个线程去接收和处理,这种模式的好处,是思路很清晰,一个线程处理一个socket请求,但是这种太消耗线程资源,因为毕竟socket不是实时都有数据接入的。

例如网卡属于是典型的慢速设备,因此,如何能高效的利用一些模式,可以改变这种局面,这个时候Reactor模式就出来了:

上图就是基于socket的reactor模式,socket作为文件fd,被多路事件分离器监听,这个多路事件分离器一般就是指Select/poll这种IO多路复用的机制,select/poll将事件分离出来后,委托给反应器去寻找创建对应的事件处理器,当创建完成后,以后有socket事件进来,直接由select分离出来,交由对应的Handler去处理。

Reactor模式其实最初其实来源于 华盛顿大学 Douglas C.Schmdt的一篇论文,最初用于解决分布式日志系统存在慢速设备的问题。论文中的类图如下:

标准的Reactor模式图一共有5个角色:
1、描述符(handle):
由操作系统提供,用于识别每一个事件,如Socket描述符、文件描述符fd等。在Linux中,它用一个整数来表示。
事件可以来自外部,如来自客户端的连接请求、数据等。事件也可以来自内部,如定时器事件。

2、同步事件分离器(demultiplexer):

一个函数,用来等待一个或多个事件的发生。调用者会被阻塞,直到分离器分离的描述符集上有事件发生。
Linux的select/poll/epoll函数一个经常被使用的分离器。

3、事件处理器接口(event handler):

是由一个或多个模板函数组成的接口。这些模板函数描述了和应用程序相关的对某个事件的操作。

4、具体的事件处理器:

是事件处理器接口的实现。它实现了应用程序提供的某个服务。也就是libev中的回调函数callback函数
每个具体的事件处理器总和一个描述符相关。它使用描述符来识别事件、识别应用程序提供的服务。

5、Reactor 管理器(reactor):

定义了一些接口,用于应用程序控制事件调度,以及应用程序注册删除事件处理器和相关的描述符。它是事件处理器的调度核心。(如libev中的loop)
Reactor管理器使用同步事件分离器来等待事件的发生。
一旦事件发生,Reactor管理器先是分离每个事件,然后调度事件处理器,最后调用相关的模 板函数来处理这个事件。

/////////////////////////////////////////////////////
其实对Reactor实现的最好实现在C++的ACE框架上,ACE框架用于替代传统socket这种编程方式的,提供了很多封装的模式的框架,其中有一个模式,就叫Reactor框架。

上述的几个角色,在Reactor框架都有非常明确的对应关系,但是ACE的整体类图和Reactor还略有区别,加了一些基于时间的事件调度的内容
Reactor对应的就是ACE的Reactor,负责handler注册,和整个Reactor模式的管控;
具体的事件源,也就是handle,其实也就是对应的fd,和socket的文件描述符等事件产生源;
多路复用事件分离器,其实就是操作系统中的select,poll等机制
Event Handler接口就是对应的事件接口,ACE将这个Reactor的接口标准化了,供应用自己去实现自己的Event Handler;
Application Event Handler是对应的应用的事件Handler,继承自Event Handler接口;
对于ACE Reactor框架,还提供了诸如定时任务队列等的支持功能可谓非常强大。
///////////////////////////////////////////////////

在Java中,其实大家都非常比较清楚了,NIO其实也比较类似Reactor模式。

Selector可以理解为操作系统底层映射到java API层级的一个多路复用事件的分离器。 SelectionKey其实就是对应的事件,如socket read,socket listen,accept等等。 当对应的事件触发之后,NIO需要你自己针对于SelectionKey中的事件进行if else的判断,而这部分就没有用到Handler, 当然,如ServerSocketChannel,FileChannel对应的事件就那么几个,完全自己可以封装一个完美的Reactor框架。 ///////////////////////////////////////////// 在我们的libev事件驱动的网络库来说,上述reactor模型的5个角色也都有很明显的对应,类似c++的ACE框架。 ////////////////////////////////////////////////// 总结一下,Reactor模式产生的年头较早,它最初解决的问题是一客户端连接一线程模型中,针对于慢速客户端如打印机等的线程时间片的浪费问题, 后期逐渐演变为服务器前端架构模式,ACE,libev,JAVA的NIO都是基于Reactor的实现案例。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


react 中的高阶组件主要是对于 hooks 之前的类组件来说的,如果组件之中有复用的代码,需要重新创建一个父类,父类中存储公共代码,返回子类,同时把公用属性...
我们上一节了解了组件的更新机制,但是只是停留在表层上,例如我们的 setState 函数式同步执行的,我们的事件处理直接绑定在了 dom 元素上,这些都跟 re...
我们上一节了解了 react 的虚拟 dom 的格式,如何把虚拟 dom 转为真实 dom 进行挂载。其实函数是组件和类组件也是在这个基础上包裹了一层,一个是调...
react 本身提供了克隆组件的方法,但是平时开发中可能很少使用,可能是不了解。我公司的项目就没有使用,但是在很多三方库中都有使用。本小节我们来学习下如果使用该...
mobx 是一个简单可扩展的状态管理库,中文官网链接。小编在接触 react 就一直使用 mobx 库,上手简单不复杂。
我们在平常的开发中不可避免的会有很多列表渲染逻辑,在 pc 端可以使用分页进行渲染数限制,在移动端可以使用下拉加载更多。但是对于大量的列表渲染,特别像有实时数据...
本小节开始前,我们先答复下一个同学的问题。上一小节发布后,有小伙伴后台来信问到:‘小编你只讲了类组件中怎么使用 ref,那在函数式组件中怎么使用呢?’。确实我们...
上一小节我们了解了固定高度的滚动列表实现,因为是固定高度所以容器总高度和每个元素的 size、offset 很容易得到,这种场景也适合我们常见的大部分场景,例如...
上一小节我们处理了 setState 的批量更新机制,但是我们有两个遗漏点,一个是源码中的 setState 可以传入函数,同时 setState 可以传入第二...
我们知道 react 进行页面渲染或者刷新的时候,会从根节点到子节点全部执行一遍,即使子组件中没有状态的改变,也会执行。这就造成了性能不必要的浪费。之前我们了解...
在平时工作中的某些场景下,你可能想在整个组件树中传递数据,但却不想手动地通过 props 属性在每一层传递属性,contextAPI 应用而生。
楼主最近入职新单位了,恰好新单位使用的技术栈是 react,因为之前一直进行的是 vue2/vue3 和小程序开发,对于这些技术栈实现机制也有一些了解,最少面试...
我们上一节了了解了函数式组件和类组件的处理方式,本质就是处理基于 babel 处理后的 type 类型,最后还是要处理虚拟 dom。本小节我们学习下组件的更新机...
前面几节我们学习了解了 react 的渲染机制和生命周期,本节我们正式进入基本面试必考的核心地带 -- diff 算法,了解如何优化和复用 dom 操作的,还有...
我们在之前已经学习过 react 生命周期,但是在 16 版本中 will 类的生命周期进行了废除,虽然依然可以用,但是需要加上 UNSAFE 开头,表示是不安...
上一小节我们学习了 react 中类组件的优化方式,对于 hooks 为主流的函数式编程,react 也提供了优化方式 memo 方法,本小节我们来了解下它的用...
开源不易,感谢你的支持,❤ star me if you like concent ^_^
hel-micro,模块联邦sdk化,免构建、热更新、工具链无关的微模块方案 ,欢迎关注与了解
本文主题围绕concent的setup和react的五把钩子来展开,既然提到了setup就离不开composition api这个关键词,准确的说setup是由...
ReactsetState的执行是异步还是同步官方文档是这么说的setState()doesnotalwaysimmediatelyupdatethecomponent.Itmaybatchordefertheupdateuntillater.Thismakesreadingthis.staterightaftercallingsetState()apotentialpitfall.Instead,usecom