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 ("sock close")));
		return -1;
	}
	return 0;
}