[ACE源码分析]ACE_Reactor是如何做到事件分发的 转载自：http://www.cppblog.com/sandy/archive/2006/02/23/3451.html 1. ACE_Reactor的创建 ACE_Reactor: ACE_Reactor (ACE_Reactor_Impl *implementation = 0, int delete_implementation

       看到ACE中反应器（Reactor） 用于事件多路分离和分派的体系结构模式  一章中说：在从反应器注销，以及handle_close()挂钩方法被调用时，该类将自己删除。但是，必须保证MyEventHandler总是动态分配的（即是从ACE_Event_Handler派生出的类一定是new出来的，而不是stack上临时变量或全局变量。），否则，全局内存堆可能会崩溃。确保类总是动态地创

    在服务器socket编程中，用来处理客户端的请求，最直接的做法是，为每一个socket连接创建一个线程，采用阻塞模式的方法来处理，然这种阻塞模式随着并发量增大，效果也会越来越差。一种比较好的方法就是select模型的思想。比如可把来自客户端的连接保存在一个cook中，采用轮询的方式检测某个连接是否可读或者可写。ACE反应器模式与这种思想类似。     ACE_Reactor的使用很简单，在

ACE中的两种I/O多路复用模式 Reactor 和 Proactor 的比较。 一般情况下，I/O 复用机制需要事件分离器（event demultiplexor）。 事件分离器的作用，即将那些读写事件源分发给各读写事件的处理者，就像送快递的在楼下喊：谁的什么东西送了，快来拿吧。开发人员在开始的时候需要在分离器那里注册感兴趣的事件，并提供相应的处理者（event handlers），或者是回调函

用ACE的Reactor模式实现网络通讯的例子，不罗嗦，直接上代码。 服务器代码： #include <ace/Reactor.h> #include <ace/SOCK_Connector.h> #include <ace/SOCK_Acceptor.h> #include <ace/Auto_Ptr.h> class ClientService : public ACE_E

用ACE的Reactor模式实现网络通讯时，ACE内部用 WSAEventSelect 函数把网络事件与一个事件对象关联起来，目的是为了后面用WaitForMultipleObjects函数统一处理。   下面是 ACE 的 ACE_WFMO_Reactor::register_handler_i 函数的代码，里面调用了WSAEventSelect 函数。 int ACE_WFMO_Reacto

ACE_Reactor::register_handler 调用 WSAEventSelect 系统函数， 而 WSAEventSelect 函数自动把关联的 socket 设置为非阻塞模式。 看 MSDN 里的描述： The WSAEventSelect function automatically sets socket s to nonblocking mode, regardless of

最近接触力ACE，发现了很多好文章，在此转载一下，也当作一个笔记吧。 Reactor与 Proactor 基本概念 在高性能的I/O设计中，有两个比较著名的模式Reactor和Proactor模式，其中Reactor模式用于同步I/O，而Proactor运用于异步I/O操作。        在比较这两个模式之前，我们首先的搞明白几个概念， 什么是阻塞和非阻塞 阻塞和非阻塞是针对于进程在访问数据的时

Reactor 模型的基础是事件多路分离器 ，比如 selete(),poll(),WaitForMultipleObjects() 系统函数 。这些优秀的系统函数允许使用者只用一个进程或线程，就能处理许多事件。 下面，针对 selete() 作详解说明，其余系统函数类同。 select() 的机制 中提供一 fd_set 的数据结构，实际上是一 long 类型的数组 ，每一个数组元素都能与一打开

1．ACE反应器框架简介 反应器（Reactor）：用于事件多路分离和分派的体系结构模式 通常的，对一个文件描述符指定的文件或设备, 有两种工作方式: 阻塞与非阻塞。所谓阻塞方式的意思是指, 当试图对该文件描述符进行读写时, 如果当时没有东西可读,或者暂时不可写, 程序就进入等待状态, 直到有东西可读或者可写为止。而对于非阻塞状态, 如果没有东西可读, 或者不可写, 读写函数马上返回, 而不会等待

ACE_Reactor框架的任务： 检测来自于各种各样事件源的事件的发生 将事件多路分离到他们的预先注册的事件处理器上 将事件分派给由处理器所定义的挂钩方法，以按照应用程序所定义的方式来处理事件 ACE_Reactor类的实现。 接口声明放在Reactor.h中， 接口实现则分别放在Reactor.cpp和Reactor.ini文件中，而Reactor.inl作为内联函数直接在Reactor.h文

ACE_Reactor一些重要的细节 看下具体ACE_Dev_Poll_Reactor的实现，如何将一个处理集和handle关联起来，代码如下： int ACE_Dev_Poll_Reactor ::register_handler_i(handle, event_handler,mask) //step 1 if(this->handler_rep_.find(handle)==0) {

源码可以到http://www.aoc.nrao.edu/php/tjuerges/ALMA/ACE-5.5.2/html/ace/上去找. ACE_Select_Reactor_T主要是使用select来进行多路复用和分离。为了监测多个fd，ACE中新增了ACE_Handle_Set,就像类说明的说的，C++ wrapper facade for the socket @c fd_set abs

实现接口不同于类Unix平台上，select在windows上仅仅支持socket句柄的多路分离。而且在Unix平台上，select也不支持同步对象、线程或者SystemV消息队列的多路分离。 所以windows上增加了以WaitForMultipleObjets系统函数替代select的ACE_WFMO_Reactor类。 其新增特性有： 1.因为WaitForMultipleObjets支持多

在ACE_Select_Reactor_T的handle_events中，进去就会获取Token，调到ACE_Guard直至ACE_Token的share_acquire函数，会调用一个sleepHook，这个hook的代码是： 00058 // Used to wakeup the reactor. 00059 00060 template <class ACE_TOKEN_TYPE> voi

源码可以到http://www.aoc.nrao.edu/php/tjuerges/ALMA/ACE-5.5.2/html/ace/上去找 虽然ACE_Select_Reactor是灵活的，但是由于只有拥有者才能调用它的handle_events方法，所以在多线程应用程序中它还是有一定的局限性的，因而ACE_Select_Reactor得事件多路分离层的序列化处理可能对某些场景来讲约束太多了。一种

介绍 这个类提供了一个消息处理循环的功能，ACE中多个组件都会借助这个类的功能来实现消息循环处理。 全局单例 ACE_Reactor::instance() ACE提供了一个全局单例供开发者调用，一般情况下只需要调用这个全局单例遍可以了。 使用的方式 包含头文件 在你的cpp文件中加上 #include "ace/Reactor.h" 包含启动代码 在你的cpp文件中加入启动代码 ACE_Reac

ACE_Reactor  :        这是一个事件监听分派中心， 通过ACE_Reactor注册需要监控的事件，当事件发生时，ACE_Reactor就会自动调用注册时指定的控制程序进行处理。     转： ACE Reactor 框架简化了事件驱动程序的开发，而事件驱动是许多网络化应用的特征。该框架实现Reactor模式，允许事件驱动的应用对源自许多不同事件源的事件作出反应，如I/O句柄，定

handle_input的调用时机 我们通过Acceptor-Connector模式一（Acceptor的工作）知道了接受器主要是当连接建立之后创建服务处理器，并启动服务处理的open方法来实现正式通信流程的。 所以，open方法中总是有跟socket有关的read，write方法的调用。当这些read，write方法执行完毕之后，就会调用handle_read方法或handle_write方法。

ACE_Reactor执行逻辑 （1）ACE_Reactor反应器作为全局基础服务，提供了事件回调的统一管理。 （2）一般在处理类的构造函数里注册一个事件到反应器，或者由其他的模式显示调用反应器的注册函数来注册事件。 （3）一旦事件被注册到反应器，就意味着反应器拥有指向处理器的指针 （4）当事件发生时，反应器可以知道当前事件应该回调哪一个处理器 （5）当事件发生时，不同的事件会回调处理器的不同的h