学习笔记：用于事件多路分离和分派的reactor体系结构模式

如上图所示，应答者（或称反应器）框架通过在OS事件多路分离接口上进行监听，检测事件的发生。当检测到事件的发生后，回调预登记时间处理器（event handler）对象中的方法。该方法是一个回调函数，包含有应用处理事件的具体代码，由应用程序开发者实现。

于是，应用开发者必须做好以下工作：

（1）创建事件处理器对象，以便将来能处理它所感兴趣的事件；

（2）向反应器（reactor,应答者）注册、登记，并告知反应器处理该事件的事件处理器的指针。

这样，随后，反应器框架就能自动地完成以下工作：

（1）在内部维护一个表（结构体表或者哈希表等等），将不同的事件类型与事件处理器对象联系起来；

（2）当用户（即应用开发者）已登记的某个事件发生时，反应器检测到事件发生，回调处理器中相应callback函数。

下面我们看一个例子：

#include <signal.h>

#include "ace/Reactor.h"

#include "ace/Event_handler.h"

class MyEventHandler:public ACE_EVENT_HANDLER

{

int handle_signal( int signum, siginfo_t *, ucontext_t * )

{

case SIGWINCH:

printf("We are handling SIGWINCH.\n");

break;

case SIGINT:

printf("We are handling SIGWINCH.\n");

break;

default:

break;

return 0;



}



}

int main( int argc, char *argv[] )

{

MyEventHandler *HandleEventObject = new MyEventHandler;

ACE_Reactor::Instance()->register_handler(SIGWINCH,HandleEventObject);

ACE_Reactor::Instance()->register_handler(SIGINT, HandleEventObject);

while(1)

{

ACE_Reactor::instance()->handle_events();

}

}