ASIO的異步方式
異步方式 和同步方式不同，從來不花時間去等那些龜速的IO操作，只是向系統說一聲要做什么，然后就可以做其它事去了。
如果系統完成了操作， 系統就會通過我之前給它的回調對象來通知我。
在ASIO庫中，異步方式的函數或方法名稱前面都有“async_” 前綴，函數參數里會要求放一個回調函數（或仿函數）。
異步操作執行 后不管有沒有完成都會立即返回，這時可以做一些其它事，直到回調函數（或仿函數）被調用，說明異步操作已經完成。
在ASIO中很多回調函數都只接受一個boost::system::error_code參數，在實際使用時肯定是不夠的，所以一般 使用仿函數攜帶一堆相關數據作為回調，或者使用boost::bind來綁定一堆數據。
另外要注意的是，只有io_service類的run()方法運行之后回調對象才會被調用，否則即使系統已經完成了異步操作也不會有任 務動作。
好了，就介紹到這里，下面是我帶來的異步方式TCP Helloworld服務器端:
1.#include
2.#include
3.#include
4.#include
5.#include
6.
7.using namespace boost::asio;
8.using boost::system::error_code;
9.using ip::tcp;
10.
11.struct CHelloWorld_Service{
12. CHelloWorld_Service(io_service &iosev)
13. :m_iosev(iosev),m_acceptor(iosev, tcp::endpoint(tcp::v4(), 1000))
14. {
15. }
16.
17. void start()
18. {
19. // 開始等待連接（非阻塞）
20. boost::shared_ptr psocket(new tcp::socket(m_iosev));
21. // 觸發的事件只有error_code參數，所以用boost::bind把socket綁定進去
22. m_acceptor.async_accept(*psocket,
23. boost::bind(&CHelloWorld_Service::accept_handler, this, psocket, _1)
24. );
25. }
26.
?27. // 有客戶端連接時accept_handler觸發
28. void accept_handler(boost::shared_ptr psocket, error_code ec)
29. {
30. if(ec) return;
31. // 繼續等待連接
32. start();
?33. // 顯示遠程IP
?34. std::cout << psocket->remote_endpoint().address() << std::endl;
35. // 發送信息(非阻塞)
36. boost::shared_ptr pstr(new std::string("hello async world!"));
37. psocket->async_write_some(buffer(*pstr),
38. boost::bind(&CHelloWorld_Service::write_handler, this, pstr, _1, _2)
39. );
?40. }
?41.
42. // 異步寫操作完成后write_handler觸發
43. void write_handler(boost::shared_ptr pstr,
44. error_code ec, size_t bytes_transferred)
45. {
46. if(ec)
47. std::cout<< "發送失敗!" << std::endl;
48. else
49. std::cout<< *pstr << " 已發送" << std::endl;
50. }
51.
52.private:
53. io_service &m_iosev;
54. ip::tcp::acceptor m_acceptor;
55.};
56.
57.int main(int argc, char* argv[])
58.{
59. io_service iosev;
60. CHelloWorld_Service sev(iosev);
?61. // 開始等待連接
62. sev.start();
63. iosev.run();
64.
65. return 0;
66.}
在這個例子中，首先調用sev.start()開 始接受客戶端連接。
由于async_accept調 用后立即返回，start()方 法 也就馬上完成了。
sev.start()在 瞬間返回后iosev.run()開 始執行，iosev.run()方法是一個循環，負責分發異步回調事件，
只 有所有異步操作全部完成才會返回。
這里有個問題，就是要保證start()方法中m_acceptor.async_accept操 作所用的tcp::socket對象在整個異步操作期間保持有效
(不 然系統底層異步操作了一半突然發現tcp::socket沒了，不是拿人家開涮嘛-_-!!!)，
而且客戶端連接進來后這個tcp::socket對象還 有用呢。
這里的解決辦法是使用一個帶計數的智能指針boost::shared_ptr，并把這個指針作為參數綁定到回調函數上。
一旦有客戶連接，我們在start()里給的回調函數accept_handler就會被 調用，
首先調用start()繼續異步等待其 它客戶端的連接，然后使用綁定進來的tcp::socket對象與當前客戶端通信。
發送數據也使用了異步方式(async_write_some)， 同樣要保證在整個異步發送期間緩沖區的有效性，
所以也用boost::bind綁定了boost::shared_ptr。
對于客戶端也一樣，在connect和read_some方法前加一個async_前綴，然后加入回調即可，大家自己練習寫一寫。
posted on 2009-08-19 00:36
小王 閱讀(1029)
評論(0) 編輯 收藏 引用 所屬分類:
網絡通訊