Reactor和Proactor应用代码编写对比。
这里以Linux上的客户端的连接服务端建立连接并接收数据的例子作为对比。
如果是Reactor,
1.声明一个Client_reactor_service类,该类从ACE_Svc_Handler《ACE_SOCK_STREAM,ACE_NULL_SYNTH》派生出来。
实现Client_reactor_service的:
open:open函数实现主要调用的是ACE_Svc_Handler的open接口handle_input:调用peer接口的recv函数去收取数据并打印
hand_close:调用ACE_Svc_Handler的close接口
2.使用时,则是在main函数中:
(1)创建一个ACE_INET_Addr对象赋远程服务器端口和地址,并将这个值和
(2)创建的Client_reactor_service对象的指针
(3)创建ACE_Connector《Client,ACE_SOCK_STREAM》对象,并将上述两个值(1)(2),作为参数调用其connect接口。
(4)执行ACE_Reactor::instance()->handle_events()的while循环用于捕获事件并处理。
如果是Proactor,
1.声明一个Client_proactor_service类,该类从ACE_Service_Handler派生出来。
增加了ACE_Asynch_Read_Stream类对象作为成员变量。
实现Client_proactor_service的:
open:
(2)new一个ACE_Message_Block作为读取buffer,然后传入调用ACE_Asynch_Read_Stream的read接口,等待读完成后handle_read_stream被调用。
handle_read_stream:此时这次的读取已完成,可以再new一个ACE_Message_Block调用ACE_Asynch_Read_Stream的read接口,等待下一次读完成后此回调被调用。
2.使用时,则是在main函数中:
(1)创建一个ACE_INET_Addr对象赋远程服务器端口和地址,并将这个值.
(2)创建ACE_Asynch_Connector《Client_reactor_service》对象,并将上述两个值(1),作为参数调用其connect接口。
(4)执行ACE_Proactor::instance()->practor_run_event_loop()的while循环用于捕获完成事件通知并处理。
最关键的区别就是:proactor在读写事件开始前就要把缓冲区准备好,并调用read或者write接口告知系统需要异步的去读写数据。而reactor是直接在handle_input这些回调函数中区读写数据。