ACE_Reactor模式（handle_input的工作）V1.0

handle_input的调用时机

我们通过Acceptor-Connector模式一（Acceptor的工作）知道了接受器主要是当连接建立之后创建服务处理器，并启动服务处理的open方法来实现正式通信流程的。

所以，open方法中总是有跟socket有关的read，write方法的调用。当这些read，write方法执行完毕之后，就会调用handle_read方法或handle_write方法。

handle_input的工作

由于handle_input函数是处理read操作的后事的，所以这里涉及到还要不要有后续：

（1）如果read完毕就结束流程，那这里只需要返回-1，由反应器来调用服务处理器的handle_close()方法，而这个方法的默认实现就是delete this

（2）如果read完毕并不结束流程，那就继续执行其他流程，比如用write操作给对端写返回数据。

下面的例子仅仅展示handle_input什么也不做，用于结束流程的情况：

server.cpp

功能：收到客户端的数据之后就打印出来，然后结束流程

#include <ace/Log_Msg.h>
#include "ace/Svc_Handler.h"
#include <ace/Acceptor.h>
#include "ace/SOCK_Acceptor.h"
#include "ace/INET_Addr.h"
#include "ace/Reactor.h"
#include "ace/Message_Block.h"

class My_Time_Server_Handler : public ACE_Svc_Handler<ACE_SOCK_Stream,ACE_NULL_SYNCH>
{
public:
~My_Time_Server_Handler();
//由接收器在接收到对端的连接请求之后调用此方法
virtual int open(void *)
{
ACE_DEBUG((LM_DEBUG,"one client connection established.\n"));
//当有TCP连接收到了数据之后，会调用这个类的handle_input()方法来处理
//所以需要实现handle_input()方法
ACE_Reactor::instance()->register_handler(this,ACE_Event_Handler::READ_MASK);

ACE_Message_Block* blk = new ACE_Message_Block(1024);
this->peer().recv_n(blk->wr_ptr(),1024);
ACE_DEBUG((LM_DEBUG,"服务端收到：%s\n",blk->rd_ptr()));

return 0;// OK
}
//这个方法仅仅是被反应器调用，但是具体做什么事，由当前类自己说了算
//当前实现是将收到的数据打印出来
virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE)
{
ACE_DEBUG((LM_DEBUG,"服务处理器read完毕\n"));
//此处返回-1会让反应器调用服务处理器的handle_close()方法，
//而这个方法的默认实现就是delete this
return -1;
}

};

My_Time_Server_Handler::~My_Time_Server_Handler()
{
ACE_DEBUG((LM_DEBUG,"~My_Time_Server_Handler()\n"));
}

int main(int argc, char *argv[])
{
ACE_INET_Addr local_addr(1500);

ACE_Acceptor<My_Time_Server_Handler,ACE_SOCK_Acceptor> acceptor;

acceptor.open(local_addr,ACE_Reactor::instance());
//截过连接信息
ACE_Reactor::instance()->run_reactor_event_loop();

return 0;
}

client.cpp

功能：向服务端发送一个字符串，由服务端负责打印出来

#include <ace/Log_Msg.h>
#include <ace/SOCK_Connector.h>
#include "ace/INET_Addr.h"
#include <string>
using namespace std;

int main(int argc, char *argv[])
{
ACE_INET_Addr addr(1500,"127.0.0.1"); //remote address
ACE_SOCK_Connector client_connetor; // connetor for socket client
ACE_SOCK_Stream sock_stream; // stream is for socket read/write

if(client_connetor.connect(sock_stream,addr)==-1) //connect to remote address
{
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("(%P|%t) %p\n"),ACE_TEXT ("connection failed!")));
return -1;
}
string command_to_server("give_me_time");
int send_lenth;
if ((send_lenth =sock_stream.send_n(command_to_server.c_str(),command_to_server.size())) == -1)
{
ACE_DEBUG((LM_DEBUG,"客户端发送获取时间命令失败！\n"));
}

if (sock_stream.close () == -1) //close the connection
{
ACE_ERROR ((LM_ERROR,ACE_TEXT ("(%P|%t) %p\n"),ACE_TEXT ("sock close")));
return -1;
}
return 0;
}