简介相关对象reactor框架教程

C++ACEProactorC++ACEProactorACE简I/O相关对Reactor框ServiceConfiguration框Acceptor-Connector框➔杂C++ACEC++ACEProactorI/OAcceptor-ConnectorProactorProactor●●Proactor●Proactor●●●●●ProactorACEProactorACE 说 定义用于接受异步I/O 在I/O流上发起异步读和异步写操作，并使每个操作与一个用 于接收操作结果的ACE_Result对象关联起来 Acceptor-Connector TCP/IP定义ACE_Asynch_Acceptor ACE_Asynch_Connector来初始化通过TCP/IP 管理定时器和异步I/OACE_Reactor框架中ACE_ReactorProactorProactorProactorProactorProactorProactorProactorProactorProactorProactor异步I/OAcceptor-ConnectorProactorProactor异步I/O●●Proactor异步Proactor异步I/O●●●●ProactorProactor异步I/OProactor方 说Proactor方 说 获取异步I/O操作所使用的I/O 获取指向在操作中所使用的ACE_Message_Block 指示请求read 指示请求writeProactorProactor异步I/OProactorProactor异步I/O●●●ProactorProactorI/OAcceptor-ProactorProactor●●ProactorProactor#proactor_:ACE_Proactor+handle():+handle_read_stream(resultconstACE_Asynch_Read_Stream::Result+handle_write_stream(resultconstACE_Asynch_Write_Stream::Result+handle_time_out(tv:constACE_Time_Valueact:constvoid+handle_accept(resultconstACE_Asynch_Accept::Result+handle_connect(resultconstACE_Asynch_Connect::ResultProactor方Proactor方 说 挂钩方法，在ACE_Asynch_Read_Stream发起的 挂钩方法，在ACE_Asynch_Write_Streamwrite 挂钩方法，在通过ACE_ProactorProactor框架Proactor框架前摄式Accepter-I/OProactor框架前摄Proactor框架前摄式Accepter-●●●●●Proactor框架前摄Proactor框架前摄式Accepter-●●●●●Proactor框架Proactor框架前摄式Accepter-●●●Proactor框Proactor框架前摄式Accepter-Proactor框架前摄式Proactor框架前摄式Accepter-方 说 初始化和发出一个或多个异步accept 取消所有由该接受器发起的异步accept ProactorProactor框架前摄式Accepter-Proactor框架前摄式Accepter-方 Proactor框架前摄式Accepter-方 说 方 说 发起一个异步的connect 取消所有由该接受器发起的异步accept Proactor框架Proactor框架前摄式Accepter-#include"ace/Asynch_IO.h"#include"ace/INET_Addr.h"#include"ace/Proactor.h"classEchoService:publicACE_Service_Handler~EchoService()if(this->handle()!=ACE_INVALID_HANDLE)}Proactor框架Proactor框架前摄式Accepter-virtualvoidopen(ACE_HANDLEh,ACE_Message_Block&)if(this->reader_.open(*this)!=0this->writer_.open(*this)!={ACE_ERROR((LM_ERROR,"%p\n",}ACE_Message_Block*ACE_NEW_NORETURN(mb,ACE_Message_Blockif(this->reader_.read(*mb,mb->space())!={ACE_ERROR((LM_ERROR,"%p\n",deletethis;}}Proactor框架前摄式Accepter-virtualvoidconstProactor框架前摄式Accepter-virtualvoidconstACE_Asynch_Read_Stream::Result&{ACE_Message_Block&mb=if(!result.success()||result.bytes_transferred(){deletethis;else{if(this->writer_.write(mb,mb.length())!=ACE_ERROR((LM_ERROR,"%p\n",}else}{ACE_NEW_NORETURN(mblk,}}}Proactor框架Proactor框架前摄式Accepter-virtualvoidconstACE_Asynch_Write_Stream::Result&result){}ACE_Asynch_Read_Streamreader_;ACE_Asynch_Write_Streamwriter_;Proactor框架Proactor框架前摄式Accepter-intmain()ACE_INET_Addrlisten_addr(8868);ACE_Asynch_Acceptor<EchoService>aio_acceptor;if(0!=aio_acceptor.open(listen_addr,0,//0,//pass_addressesACE_DEFAULT_BACKLOG,1,//reuse_addr0,//proactor0))//validate_new_connectionACE_ERROR_RETURN((LM_ERROR,"%p\n","write()"),1);}ProactorProactorI/OAcceptor-Proactor●Proactor●●●●●ProactorProactorProactor方Proactor方 说 静态方法，返回执行一个单例 的指Proactor方Proactor方 说 反复调用handle_events 败、proactor_event_loop_done返回 proactor_end_event_loop），则返回Pr