韩国精品主播一区二区在线观看,欧美成在线视频,欧美日韩国产大片

ACE_Reactor Server一例,刊誤修正版

#ifdef?_DEBUG

#pragma?comment?(lib, " aced.lib " )

#else

#pragma?comment?(lib, " ace.lib " )

#endif

#include? " ace/Reactor.h "

#include? " ace/SOCK_Acceptor.h "

#define ?PORT_NO?19998

typedef?ACE_SOCK_Acceptor?Acceptor;

// forward?declaration

class ?My_Accept_Handler;

class ?My_Input_Handler: public ?ACE_Event_Handler

{

public :

???? // construcor

????My_Input_Handler()

???? {

????????ACE_DEBUG((LM_DEBUG, " Constructor\n " ));

????}

???? // Called?back?to?handle?any?input?received

???? int ?handle_input(ACE_HANDLE)

???? {

???????? // receive?the?data

????????peer().recv_n(data, 12 );

????????ACE_DEBUG((LM_DEBUG, " %s\n " ,data));

???????? // ?do?something?with?the?input?received.

???????? // ?

???????? // ?keep?yourself?registerd?with?the?reator

???????? return ? 0 ;

????}

???? // Used?by?the?reactor?to?determine?the?underlying?handle

????ACE_HANDLE?get_handle()?? const ?

???? {

???????? return ? this -> peer_.get_handle();

????}

???? // Returns?a?reference?to?the?underlying?stream.

????ACE_SOCK_Stream & ?peer()

???? {

???????? return ? this -> peer_;

????}

private :

????ACE_SOCK_Stream?peer_;

???? char ?data?[ 12 ];

} ;

class ?My_Accept_Handler: public ?ACE_Event_Handler

{

public :

???? // Constructor

????My_Accept_Handler(ACE_Addr? & addr)

???? {

???????? this -> open(addr);

????}

???? // Open?the?peer_acceptor?so?it?starts?to?"listen"

???? // for?incoming?clients

???? int ?open(ACE_Addr? & addr)

???? {

????????peer_acceptor.open(addr);

???????? return ? 0 ;

????}

???? // Overload?the?handle?input?method

???? int ?handle_input(ACE_HANDLE?handle)

???? {

???????? // Client?has?requested?connection?to?server.

???????? // Create?a?handler?to?handle?the?connection

????????My_Input_Handler? * eh? = ? new ?My_Input_Handler();

???????? // Accept?the?connection?"into"?the?Event?Handler

???????? if ( this -> peer_acceptor.accept(eh -> peer(), // stream

???????????? 0 , // remote?address

???????????? 0 , // timeout

???????????? 1 )? == ? - 1 ) // restart?if?interrupted

????????????ACE_DEBUG((LM_ERROR, " Error?in?connection?\n " ));

????????

????????ACE_DEBUG((LM_DEBUG, " Connection?established\n " ));

???????? // Register?the?input?event?handler?for?reading?

????????ACE_Reactor::instance() -> register_handler(eh,ACE_Event_Handler::READ_MASK);

???????? // Unregister?as?the?acceptor?is?not?expecting?new?clients

???????? return ? - 1 ;

????}

???? // Used?by?the?reactor?to?determine?the?underlying?handle

????ACE_HANDLE?get_handle( void )? const

???? {

???????? return ? this -> peer_acceptor.get_handle();

????}

private :

????Acceptor?peer_acceptor;

} ;

int ?ACE_TMAIN( int ?argc, char ? * argv[])

{

???? // Create?an?address?on?which?to?receive?connections

????ACE_INET_Addr?addr(PORT_NO);

???? // Create?the?Accept?Handler?which?automatically?begins?to?"listen"

???? // for?client?requests?for?connections

????My_Accept_Handler? * eh = new ?My_Accept_Handler(addr);

???? // Register?the?reator?to?call?back?when?incoming?client?connects?

????ACE_Reactor::instance() -> register_handler(eh,ACE_Event_Handler::ACCEPT_MASK);

???? // Start?the?event?loop

???? while ( 1 )

????????ACE_Reactor::instance() -> handle_events();

}

書的幾個印刷錯誤,修改后放在上面

測試說明
運行程序后,在19998端口等待客戶的連接
建立連接后,收到12個字符號,回顯示在屏幕上

telnet 127.0.0.1 19998
通過控制臺輸入字符,查看對端顯示

posted on 2006-04-12 17:28 Stone Jiang 閱讀(690) 評論(0) 編輯收藏引用所屬分類: ACE

只有注冊用戶登錄后才能發表評論。
【推薦】100%開源！大型工業跨平臺軟件C++源碼提供，建模，組態！

相關文章: ACE小技巧：在ACE_Acceptor框架中，自定義服務處理器的創建小技巧: 當ACE_Svc_Handler關閉時使用的默認行為小技巧: ACE_Svc_Handler的初始化 ACE_Hash_Map的使用示例關于ACE_Thread_Mutex的回復再次獲得互斥體,為什么沒有死鎖 ACE應用程序鏈接錯誤 error LNK2019 的解決辦法 Visual C++下ACE動態服務配置入門關于ACE_Task::last_thread() 在Linux下安裝ACE菜鳥指南

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

Focus on ACE

公告

常用鏈接

留言簿(1)

隨筆分類(74)

隨筆檔案(64)

文章檔案(3)

收藏夾(4)

ACE論壇

網上鄰居

最新隨筆

搜索

積分與排名

最新隨筆

最新評論

閱讀排行榜

評論排行榜