如上图所示,应答者(或称反应器)框架通过在OS事件多路分离接口上进行监听,检测事件的发生。当检测到事件的发生后,回调预登记时间处理器(event handler)对象中的方法。该方法是一个回调函数,包含有应用处理事件的具体代码,由应用程序开发者实现。
于是,应用开发者必须做好以下工作:
(1)创建事件处理器对象,以便将来能处理它所感兴趣的事件;
(2)向反应器(reactor,应答者)注册、登记,并告知反应器处理该事件的事件处理器的指针。
这样,随后,反应器框架就能自动地完成以下工作:
(1)在内部维护一个表(结构体表或者哈希表等等),将不同的事件类型与事件处理器对象联系起来;
(2)当用户(即应用开发者)已登记的某个事件发生时,反应器检测到事件发生,回调处理器中相应callback函数。
下面我们看一个例子:
#include <signal.h>@H_403_17@ #include "ace/Reactor.h"@H_403_17@ #include "ace/Event_handler.h"@H_403_17@ class MyEventHandler:public ACE_EVENT_HANDLER@H_403_17@ {@H_403_17@ int handle_signal( int signum,siginfo_t *,ucontext_t * )@H_403_17@ {@H_403_17@ case SIGWINCH:@H_403_17@ printf("We are handling SIGWINCH.\n");@H_403_17@ break;@H_403_17@ case SIGINT:@H_403_17@ printf("We are handling SIGWINCH.\n");@H_403_17@ break;@H_403_17@ default:@H_403_17@ break;@H_403_17@ return 0;@H_403_17@ @H_403_17@ }@H_403_17@ @H_403_17@ }
@H_403_17@ int main( int argc,char *argv[] )@H_403_17@ {@H_403_17@ MyEventHandler *HandleEventObject = new MyEventHandler;@H_403_17@ ACE_Reactor::Instance()->register_handler(SIGWINCH,HandleEventObject);@H_403_17@ ACE_Reactor::Instance()->register_handler(SIGINT,HandleEventObject); while(1) { ACE_Reactor::instance()->handle_events(); } }