ACE中的Reactor框架简介

分类：React作者：编程之家用户
Joise.LI @ 2006-10-16
一、 概要
目前用于事件多路分离的 OS 抽象既复杂又难以使用，因而也容易出错。反应器本质上提供一组更高级的编程抽象，简化了事件驱动的分布式应用的设计和实现。除此而外，反应器还将若干不同种类的事件的多路分离集成到易于使用的 API 中。特别地，反应器对 基于定时器的事件 、 信号事件 、 基于 I/O 端口监控的事件 和 用户定义的通知 进行统一地处理。
二、 使用
a) 如何使用：
首先应用开发者
1. 创建事件处理器，以处理他所感兴趣的某事件。
2. 在反应器上登记，通知说他有兴趣处理某事件，同时传递他想要用以处理此事件的事件处理器的指针给反应器。
然后反应器框架将自动地
1. 在内部维护一些表，将不同的事件类型与事件处理器对象关联起来。
2. 在用户已登记的某个事件发生时，反应器发出对处理器中相应方法的回调。
b) 基于定时器的事件简单示例：
#include <ace/Reactor.h>
#include <ace/Event_Handler.h>
#include <iostream>
using namespace std;
class timer_handler : public ACE_Event_Handler
{
public :
virtual int handle_timeout (const ACE_Time_Value &current_time,const void *act = 0)
{
cout << "handle_timeout" << endl;
return -1;
}
virtual int handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask)
{
cout << "handle_close" << endl;
delete this;
return 0;
}
private :
~timer_handler()
{
}
};
int ACE_TMAIN (int argc,ACE_TCHAR *argv[])
{
ACE_Time_Value time_(4);
ACE_Reactor::instance()->schedule_timer(new timer_handler,NULL,time_,time_);
while (true)
{
ACE_Reactor::instance()->handle_events();
}
return 0;
}
c) 基于信号事件的简单示例
#include <ace/Reactor.h>
#include <ace/Event_Handler.h>
#include <iostream>
using namespace std;
#include <signal.h>
class signal_handler : public ACE_Event_Handler
{
public :
virtual int handle_signal(int signum,siginfo_t * /* = 0 */,ucontext_t * /* = 0 */)
{
cout << "signum = " << signum << endl;
return 0;
}
};
int ACE_TMAIN (int argc,ACE_TCHAR *argv[])
{
signal_handler handler_;
ACE_Reactor::instance()->register_handler(SIGBREAK,&handler_);
ACE_Reactor::instance()->register_handler(SIGINT,&handler_);
while (true)
{
ACE_Reactor::instance()->handle_events();
}
return 0;
}
d) 基于 I/O 端口监控事件的简单示例
#include <ace/INET_Addr.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/SOCK_Stream.h>
class io_handler : public ACE_Event_Handler
{
public :
virtual int handle_input(ACE_HANDLE fd /* = ACE_INVALID_HANDLE */)
{
cout << "handle_input" << endl;
ACE_SOCK_Stream stream_;
ACE_INET_Addr addr_;
m_acceptor.accept(stream_,&addr_);
stream_.send("joise",6);
return 0;
}
io_handler()
{
ACE_INET_Addr addr_(8004);
m_acceptor.open(addr_);
}
virtual ACE_HANDLE get_handle() const
{
return m_acceptor.get_handle();
}
private :
ACE_SOCK_Acceptor m_acceptor;
};
int ACE_TMAIN (int argc,ACE_TCHAR *argv[])
{
io_handler handler_;
if (ACE_Reactor::instance()->register_handler(&handler_,ACE_Event_Handler::ACCEPT_MASK) != 0)
cout << "register failed" << endl;
while (ACE_Reactor::instance()->event_loop_done() == 0)
{
ACE_Reactor::instance()->handle_events();
}
return 0;
}
e) 基于用户定义的通知的简单示例
class notify_handler : public ACE_Event_Handler
{
public :
virtual int handle_input(ACE_HANDLE fd /* = ACE_INVALID_HANDLE */)
{
cout << "handle_input" << endl;
return 0;
}
};
int ACE_TMAIN (int argc,ACE_TCHAR *argv[])
{
notify_handler handler_;
while (ACE_Reactor::instance()->event_loop_done() == 0)
{
ACE_Time_Value time_(4);
ACE_Reactor::instance()->handle_events(time_);
ACE_Reactor::instance()->notify(&handler_,ACE_Event_Handler::READ_MASK);
}
return 0;
}
f) ACE_Event_Handler 中提供以备继承的事件回调方法：
方法
在子类中重载，所处理事件的类型:
handle_signal()
信号。当任何在反应器上登记的信号发生时，反应器自动回调该方法。
handle_input()
来自I/O设备的输入。当I/O句柄（比如UNIX中的文件描述符）上的输入可用时，反应器自动回调该方法。
handle_exception()
异常事件。当已在反应器上登记的异常事件发生时（例如，如果收到SIGURG（紧急信号）），反应器自动回调该方法。
handle_timeout()
定时器。当任何已登记的定时器超时的时候，反应器自动回调该方法。
handle_output()
I/O设备输出。当I/O设备的输出队列有可用空间时，反应器自动回调该方法。
g) 在处理器上登记或删除某事件： register_handler 、 remove_handler 、 schedule_timer
掩码
回调方法
何时
和⋯⋯一起使用
ACE_Event_Handler::READ_MASK
handle_input()
在句柄上有数据可读时。
register_handler()
ACE_Event_Handler::WRITE_MASK
handle_output()
在I/O设备输出缓冲区上有可用空间、并且新数据可以发送给它时。
register_handler()
ACE_Event_Handler::TIMER_MASK
handle_close()
传给handle_close()以指示调用它的原因是超时。
接受器和连接器的handle_timeout方法。反应器不使用此掩码。
ACE_Event_Handler::ACCEPT_MASK
handle_input()
在OS内部的侦听队列上收到了客户的新连接请求时。
register_handler()
ACE_Event_Handler::CONNECT_MASK
handle_input()
对于非阻塞连接，在连接已经建立时。
register_handler()
ACE_Event_Handler::DONT_CALL
None.
在反应器的remove_handler()被调用时保证事件处理器的handle_close()方法不被调用。
remove_handler()
h) 生命期：
i.静态管理事件处理器的生命期
在栈上声明一个事件处理器，静态管理其生命期，则
l 使用方法register_handler或schedule_timer将某事件登记到反应器上，其在反应器之上的生命期开始
l 使用方法remove_handler显式的将事件从反应器上移除，其在反应器之上的生命期结束，或
l 在事件处理器相应的handle_*方法被回调时返回-1，则框架会自动的为此事件处理器检测已登记的事件并且将其从反应器之上移除，在移除之前，会调用事件处理器的handle_close回调方法以清除资源，调用之后，其在反应器之上的生命期也结束。
ii.动态管理事件处理器的生命期
由于上述静态管理事件处理器的生命期可能会导致对已经不存在的事件处理器进行分派的问题，所以一般使用动态管理事件器的生命期：
class dynamic_handler : public ACE_Event_Handler
{
private :
~dynamic_handler(){}
ACE_Reactor_Mask m_mask;
public :
virtual int handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask)
{
ACE_CLR_BITS(m_mask,close_mask);
switch(close_mask)
{
case READ_MASK:
;// 执行read相关的清除逻辑
break;
...
}
if (m_mask == 0)
delete this;
}
};
三、 实现
a) 框架类图
b) ACE_Reactor 类详解
初始化及清理：
i. ACE_Reactor 、 Open ：创建并初始化 Reactor 实例
ii. ~ACE_Reactor 、 Close ：清理反应器在初始化时分配的资源
事件处理器的管理：
iii. register_handler ：登记事件处理器
iv. remove_handler ：移除事件处理器
v. suspend_handler ：暂停分派事件给事件处理器
vi. resume_handler ：恢复分派事件给事件处理器
vii. mask_ops ：获取、设计、增加或是清除与某事件处理器相关的事件类型及其掩码
viii. schedulee_wakeup ：将指定的掩码增加到某事件处理器的条目中，该处理器在此之前必须已经通过 register_handler 作了登记
ix. cancel_wakeup ：从某事件处理器的条目中清除指定的掩码，但并不移除此处理器
事件的分派管理：
x. handle_events ：等待事件发生，并随即分派与之相关联的事件处理器。
xi. run_event_loop ：反复调用 handle_events 方法，直到其失败或是 event_loop_done 返回１，或是发生超时。
xii. end_event_loop ：指示反应器关闭事件循环
xiii. event_loop_done ：在 end_reactor_event_loop 调用结束之后返回１
定时器管理：
xiv. schedule_timer ：登记一个事件处理器，它将在用户规定的时间之后执行，相当于一个定时器
xv. cancel_timer ：取消一个或多个先前登记的定时器
通知管理：
xvi. notify ：通知指定的事件处理器有某事件发生
xvii. max_notify_iterations ：设置反应器在其通知机制中分派的处理器的最大数目
其它方法：
xviii. instance ：提供对反应器单子模式的访问
c) 在 Reactor 框架中，使用了 Bridge 模式来实现保持 ACE_Reactor 接口恒定而又可以扩展或增强其接口。下图是

i. ACE_Select_Reactor

ACE_Reactor 接口的一种实现，使用 select 同步事件多路分离。
ii. ACE_TP_Reactor
ACE_Reactor 接口的另一种实现，可以让一“池”线程并发的调用 handle_events ，从而解决某些应用对于单线程调用 handle_events 的性能不够问题。
iii. ACE_WFMO_Reactor
windows 下的使用 WaitForMultipleObjects 函数来进行事件多路分离的一种实现。
iv. 。。。，还有一些其它的扩展的 Reactor 的实现。
四、 后记
Reactor 是 ACE 框架中的基础框架， Acceptor-Connector 、 Proactor 是依赖于 Reactor 的框架。
五、 作者相关信息：
欢迎大家与我交流，共同学习，共同提高。
joise@126.com,
http://joise.126.com

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

相关推荐

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