Echo server就是那種提供回顯服務(wù)的程序，就是收到什么，然后就發(fā)送什么的程序。
兩種實(shí)現(xiàn)方法
1.
Per client Per Thread (每個(gè)連接每個(gè)線程來(lái)處理)
這種方式比較簡(jiǎn)單，易于實(shí)現(xiàn)。缺點(diǎn)是如果有大量的連接，必然占用過(guò)量的系統(tǒng)資源。
代碼:
#ifdef _DEBUG
#pragma comment(lib,"ACED.lib")
#else
#pragma comment(lib,"ACE.lib")
#endif
#include <ace/OS_main.h>
#include <ace/ACE.h>
#include <ace/Log_Msg.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/Thread.h>
DWORD worker(void *arg)
{
ACE_SOCK_Stream *pStream =(ACE_SOCK_Stream *) arg;
char buffer[32] = {0};
int len;
while( (len = pStream->recv(buffer,sizeof(buffer)-1)) >0)
{
if(pStream->send_n(buffer,len)<=0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) %p\n"),
ACE_TEXT ("send failed")));
break;
}
}
ACE_INET_Addr raddr;
pStream->get_remote_addr(raddr);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("(%P|%t) close:%s %d\n"),raddr.get_host_addr(),raddr.get_port_number()));
pStream->close();
delete pStream;
return 0;
}
int main(int argc, char *argv[])
{
ACE_INET_Addr addr(1500);
ACE_SOCK_Acceptor server;
if(server.open(addr)==-1)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) %p\n"),
ACE_TEXT ("bind failed")));
return 1;
}
ACE_SOCK_Stream *pStream = 0;
while((pStream =new ACE_SOCK_Stream()) && server.accept(*pStream)!=-1)
{
ACE_INET_Addr raddr;
pStream->get_remote_addr(raddr);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("(%P|%t) connect:%s %d\n"),raddr.get_host_addr(),raddr.get_port_number()));
ACE_Thread::spawn(worker,pStream);
}
server.close();
return 0;
}
說(shuō)明:
ACE_Thread用來(lái)啟動(dòng)thread，當(dāng)有client連上來(lái)的時(shí)候，啟動(dòng)worker thread來(lái)處理。
2.
事件模型socket里面是有select機(jī)制，ACE也提供了這種方式。
概念:
Event_Handler:有事件來(lái)臨的時(shí)候的處理器
Reactor:事件管理，負(fù)責(zé)管理Event_Hanlde和分發(fā)事件
Acceptor負(fù)責(zé)連接Event_Handle,Reactor和Sock_Acceptor
代碼:
#ifdef _DEBUG
#pragma comment(lib,"ACED.lib")
#else
#pragma comment(lib,"ACE.lib")
#endif
#include <ace/OS_main.h>
#include <ace/ACE.h>
#include <ace/Svc_Handler.h>
#include <ace/Acceptor.h>
#include <ace/Log_Msg.h>
#include <ace/SOCK_Acceptor.h>
#include <ace/Thread.h>
class My_Svc_Handler:
public ACE_Svc_Handler <ACE_SOCK_STREAM,ACE_NULL_SYNCH>
{
public:
int open(void*)
{
ACE_INET_Addr raddr;
peer().get_remote_addr(raddr);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("(%P|%t) connect:%s %d %d\n"),raddr.get_host_addr(),raddr.get_port_number(),this));
reactor()->register_handler(this,ACE_Event_Handler::READ_MASK);
return 0;
}
int handle_input(ACE_HANDLE)
{
char buffer[32] = {0};
int len = peer().recv(buffer,sizeof(buffer)-1);
if(len>0)
{
if(peer().send_n(buffer,len)<=0)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) %p\n"),
ACE_TEXT ("send failed")));
return -1; //must return -1 to call handle_close
}
return 0;
}
else
{
return -1; //must return -1 to call handle_close
}
}
int handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask)
{
ACE_INET_Addr raddr;
peer().get_remote_addr(raddr);
ACE_DEBUG ((LM_DEBUG,ACE_TEXT ("(%P|%t) close:%s %d\n"),raddr.get_host_addr(),raddr.get_port_number()));
peer().close();
return 0;
}
};
typedef ACE_Acceptor<My_Svc_Handler,ACE_SOCK_ACCEPTOR> MyAcceptor;
int main(int argc, char *argv[])
{
ACE_INET_Addr addr(1500);
MyAcceptor server;
if(server.open(addr)==-1)
{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) %p\n"),
ACE_TEXT ("bind failed")));
return 1;
}
while(1){
ACE_Reactor::instance()->handle_events();
}
server.close();
return 0;
}
說(shuō)明：
1.使用ACE_Acceptor模板類來(lái)定義自己的Acceptor
2.ACE_Reactor::instance()->handle_events()來(lái)實(shí)現(xiàn)事件分發(fā)
3.在Event_Handle里面使用reactor()->register_handler(this,ACE_Event_Handler::READ_MASK);來(lái)注冊(cè)要關(guān)心的事件
4.在Event_Handle中使用peer()來(lái)獲得Sock_Stream來(lái)發(fā)送接受數(shù)據(jù)。