ace_udp_server_dll.cpp

来自「本源码采用ACE中间件开发包实现C/S通信服务」· C++ 代码 · 共 43 行

#ifndef DLL_FILE
#define DLL_FILE
#endif

#define SIZE_DATA 19
#define DATA_BUFFER_SIZE 1024
#include "ACE_UDP_SERVER_DLL.H"

Server::Server(int local_port):local_addr_(local_port),local_(local_addr_)
{ 
		data_buf = new char[DATA_BUFFER_SIZE];
}

Server::~Server()
{

}
 int Server::accept_data()
 {
	 	int byte_count=0;
		while( (byte_count=local_.recv(data_buf,SIZE_DATA,remote_addr_))!=-1)
		{
			data_buf[byte_count]=0;
			ACE_DEBUG((LM_DEBUG, "Data received from remote %s was %s \n",remote_addr_.get_host_name(), data_buf));
			ACE_OS::sleep(1);
		}	
		return -1;	
 }

 int  Server::send_data()
 {
	 	ACE_DEBUG((LM_DEBUG,"Preparing to send reply to client %s:%d\n",remote_addr_.get_host_name(),remote_addr_.get_port_number()));
		
		ACE_OS::sprintf(data_buf,"Server says hello to you too");
		
		if( local_.send(data_buf, ACE_OS::strlen(data_buf)+1,remote_addr_)==-1)
			return -1;
		
		else
			
			return 0;
		
 }