ACE reactor --- Echo Server
发布时间:2020-12-15 04:57:04 所属栏目:百科 来源:网络整理
导读:Echo server就是那种提供回显服务的程序,就是收到什么,然后就发送什么的程序。 两种实现方法 1. Perclient Per Thread (每个连接每个线程来处理) 这种方式比较简单,易于实现。缺点是如果有大量的连接,必然占用过量的系统资源。 代码: #ifdef_DEBUG #prag
Echo server就是那种提供回显服务的程序,就是收到什么,然后就发送什么的程序。
两种实现方法 1. Perclient Per Thread (每个连接每个线程来处理) 这种方式比较简单,易于实现。缺点是如果有大量的连接,必然占用过量的系统资源。 代码:
#ifdef_DEBUG
#pragmacomment(lib,"ACED.lib") #else #pragmacomment(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> DWORDworker( void*arg) { ACE_SOCK_Stream*pStream=(ACE_SOCK_Stream*)arg; charbuffer[32]={0}; intlen; while((len=pStream->recv(buffer,sizeof(buffer)-1))>0) { if(pStream->send_n(buffer,len)<=0) { ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t)%pn"), ACE_TEXT("sendfailed"))); break; } } ACE_INET_Addrraddr; pStream->get_remote_addr(raddr); ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%P|%t)close:%s%dn"),raddr.get_host_addr(),raddr.get_port_number())); pStream->close(); deletepStream; return0; } intmain( intargc,255)">char*argv[]) { ACE_INET_Addraddr(1500); ACE_SOCK_Acceptorserver; if(server.open(addr)==-1) { ACE_DEBUG((LM_DEBUG, ACE_TEXT("bindfailed"))); return1; } ACE_SOCK_Stream*pStream=0; while((pStream= newACE_SOCK_Stream())&&server.accept(*pStream)!=-1) { ACE_INET_Addrraddr; pStream->get_remote_addr(raddr); ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%P|%t)connect:%s%dn"),raddr.get_port_number())); ACE_Thread::spawn(worker,pStream); } server.close(); return0; } 说明: ACE_Thread用来启动thread,当有client连上来的时候,启动worker thread来处理。 2. 事件模型 socket里面是有select机制,ACE也提供了这种方式。 概念: Event_Handler:有事件来临的时候的处理器 Reactor:事件管理,负责管理Event_Hanlde和分发事件 Acceptor负责连接Event_Handle,Reactor和Sock_Acceptor #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> classMy_Svc_Handler: publicACE_Svc_Handler<ACE_SOCK_STREAM,ACE_NULL_SYNCH> { public: intopen( void*) { ACE_INET_Addrraddr; peer().get_remote_addr(raddr); ACE_DEBUG((LM_DEBUG,ACE_TEXT("(%P|%t)connect:%s%d%dn"),raddr.get_port_number(),255)">this)); reactor()->register_handler( this,ACE_Event_Handler::READ_MASK); return0; } inthandle_input(ACE_HANDLE) { charbuffer[32]={0}; intlen=peer().recv(buffer,255)">sizeof(buffer)-1); if(len>0) { if(peer().send_n(buffer,255)">return-1; // mustreturn-1tocallhandle_close } return0; } else { } } inthandle_close(ACE_HANDLEhandle,ACE_Reactor_Maskclose_mask) { ACE_INET_Addrraddr; peer().get_remote_addr(raddr); ACE_DEBUG((LM_DEBUG,raddr.get_port_number())); peer().close(); return0; } }; typedefACE_Acceptor<My_Svc_Handler,ACE_SOCK_ACCEPTOR>MyAcceptor; char*argv[]) { ACE_INET_Addraddr(1500); MyAcceptorserver; return1; } while(1){ ACE_Reactor::instance()->handle_events(); } server.close(); 说明: 1.使用ACE_Acceptor模板类来定义自己的Acceptor 2.ACE_Reactor::instance()->handle_events()来实现事件分发 3.在Event_Handle里面使用reactor()->register_handler(this,ACE_Event_Handler::READ_MASK);来注册要关心的事件 4.在Event_Handle中使用peer()来获得Sock_Stream来发送接受数据。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |