ASIO的異步方式
異步方式 和同步方式不同，從來(lái)不花時(shí)間去等那些龜速的IO操作，只是向系統(tǒng)說(shuō)一聲要做什么，然后就可以做其它事去了。
如果系統(tǒng)完成了操作， 系統(tǒng)就會(huì)通過(guò)我之前給它的回調(diào)對(duì)象來(lái)通知我。
在ASIO庫(kù)中，異步方式的函數(shù)或方法名稱前面都有“async_” 前綴，函數(shù)參數(shù)里會(huì)要求放一個(gè)回調(diào)函數(shù)（或仿函數(shù)）。
異步操作執(zhí)行 后不管有沒(méi)有完成都會(huì)立即返回，這時(shí)可以做一些其它事，直到回調(diào)函數(shù)（或仿函數(shù)）被調(diào)用，說(shuō)明異步操作已經(jīng)完成。
在ASIO中很多回調(diào)函數(shù)都只接受一個(gè)boost::system::error_code參數(shù)，在實(shí)際使用時(shí)肯定是不夠的，所以一般 使用仿函數(shù)攜帶一堆相關(guān)數(shù)據(jù)作為回調(diào)，或者使用boost::bind來(lái)綁定一堆數(shù)據(jù)。
另外要注意的是，只有io_service類的run()方法運(yùn)行之后回調(diào)對(duì)象才會(huì)被調(diào)用，否則即使系統(tǒng)已經(jīng)完成了異步操作也不會(huì)有任 務(wù)動(dòng)作。
好了，就介紹到這里，下面是我?guī)?lái)的異步方式TCP Helloworld服務(wù)器端:
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. // 開(kāi)始等待連接（非阻塞）
20. boost::shared_ptr psocket(new tcp::socket(m_iosev));
21. // 觸發(fā)的事件只有error_code參數(shù)，所以用boost::bind把socket綁定進(jìn)去
22. m_acceptor.async_accept(*psocket,
23. boost::bind(&CHelloWorld_Service::accept_handler, this, psocket, _1)
24. );
25. }
26.
?27. // 有客戶端連接時(shí)accept_handler觸發(fā)
28. void accept_handler(boost::shared_ptr psocket, error_code ec)
29. {
30. if(ec) return;
31. // 繼續(xù)等待連接
32. start();
?33. // 顯示遠(yuǎn)程IP
?34. std::cout << psocket->remote_endpoint().address() << std::endl;
35. // 發(fā)送信息(非阻塞)
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. // 異步寫(xiě)操作完成后write_handler觸發(fā)
43. void write_handler(boost::shared_ptr pstr,
44. error_code ec, size_t bytes_transferred)
45. {
46. if(ec)
47. std::cout<< "發(fā)送失敗!" << std::endl;
48. else
49. std::cout<< *pstr << " 已發(fā)送" << 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. // 開(kāi)始等待連接
62. sev.start();
63. iosev.run();
64.
65. return 0;
66.}
在這個(gè)例子中，首先調(diào)用sev.start()開(kāi) 始接受客戶端連接。
由于async_accept調(diào) 用后立即返回，start()方 法 也就馬上完成了。
sev.start()在 瞬間返回后iosev.run()開(kāi) 始執(zhí)行，iosev.run()方法是一個(gè)循環(huán)，負(fù)責(zé)分發(fā)異步回調(diào)事件，
只 有所有異步操作全部完成才會(huì)返回。
這里有個(gè)問(wèn)題，就是要保證start()方法中m_acceptor.async_accept操 作所用的tcp::socket對(duì)象在整個(gè)異步操作期間保持有效
(不 然系統(tǒng)底層異步操作了一半突然發(fā)現(xiàn)tcp::socket沒(méi)了，不是拿人家開(kāi)涮嘛-_-!!!)，
而且客戶端連接進(jìn)來(lái)后這個(gè)tcp::socket對(duì)象還 有用呢。
這里的解決辦法是使用一個(gè)帶計(jì)數(shù)的智能指針boost::shared_ptr，并把這個(gè)指針作為參數(shù)綁定到回調(diào)函數(shù)上。
一旦有客戶連接，我們?cè)趕tart()里給的回調(diào)函數(shù)accept_handler就會(huì)被 調(diào)用，
首先調(diào)用start()繼續(xù)異步等待其 它客戶端的連接，然后使用綁定進(jìn)來(lái)的tcp::socket對(duì)象與當(dāng)前客戶端通信。
發(fā)送數(shù)據(jù)也使用了異步方式(async_write_some)， 同樣要保證在整個(gè)異步發(fā)送期間緩沖區(qū)的有效性，
所以也用boost::bind綁定了boost::shared_ptr。
對(duì)于客戶端也一樣，在connect和read_some方法前加一個(gè)async_前綴，然后加入回調(diào)即可，大家自己練習(xí)寫(xiě)一寫(xiě)。
posted on 2009-08-19 00:36
小王 閱讀(1024)
評(píng)論(0) 編輯 收藏 引用 所屬分類:
網(wǎng)絡(luò)通訊