ASIO的同步方式
Boost.Asio是一個跨平臺的網(wǎng)絡(luò)及底層IO的C++編程庫，它使用現(xiàn)代C++手法實現(xiàn)了統(tǒng)一的異步調(diào)用模型。
頭文件 #include
名空間 using namespace boost::asio;
ASIO庫能夠使用TCP、UDP、ICMP、串口來發(fā)送/接收數(shù)據(jù)，
下面先介紹TCP協(xié)議的讀寫操作對于讀寫方式，ASIO支持同步和異步兩種方式，
首先登場的是同步方式，
下面請同步方式自我介紹一下：大家好！我是同步方式！我的主要特點就是執(zhí)著！
所有的操作都要完成或出錯才會返回，不過偶的執(zhí)著被大家稱之為阻塞，實在是郁悶~~（場下一片噓聲），
其實這樣 也是有好處的，比如邏輯清晰，編程比較容易。
在服務(wù)器端，我會做個socket交給acceptor對象，讓它一直等客戶端連進(jìn)來，連上以后再通過這個socket與客戶端通信，
而所有的通信都是以阻塞方式進(jìn)行的，讀完或?qū)懲瓴艜祷亍Ｔ诳蛻舳艘惨粯樱?br>這時我會拿著socket去連接服務(wù)器，當(dāng)然也是連上或出錯了才返回，最后也是以阻塞的方式和服務(wù)器通信。
有人認(rèn)為同步方式?jīng)]有異步方式高效，其實這是片面的理解。
在單線程的情況下可能確實如此，我不能利用耗時的網(wǎng)絡(luò)操作這段時間做別的事 情，不是好的統(tǒng)籌方法。
不過這個問題可以通過多線程來避免，比如在服務(wù)器端讓其中一個線程負(fù)責(zé)等待客戶端連接，連接進(jìn)來后把socket交給另外的線程去 和客戶端通信，這樣與一個客戶端通信的同時也能接受其它客戶端的連接，主線程也完全被解放了出來。
我的介紹就有這里，謝謝大家！好，感謝同步方式的自我介紹，
現(xiàn)在放出同步方式的演示代碼(起立鼓掌!):
服務(wù)器端
1.#include
2.#include
3.
4.using namespace boost::asio;
5.
6.int main(int argc, char* argv[])
7.{
8. // 所有asio類都需要io_service對象
9. io_service iosev;
10. ip::tcp::acceptor acceptor(iosev,
11. ip::tcp::endpoint(ip::tcp::v4(), 1000));
12. for(;;)
13. {
14. // socket對象
15. ip::tcp::socket socket(iosev);
16. // 等待直到客戶端連接進(jìn)來
17. acceptor.accept(socket);
18. // 顯示連接進(jìn)來的客戶端
19. std::cout << socket.remote_endpoint().address() << std::endl;
20. // 向客戶端發(fā)送hello world!
21. boost::system::error_code ec;
22. socket.write_some(buffer("hello world!"), ec);
23.
24. // 如果出錯，打印出錯信息
25. if(ec)
26. {
27. std::cout <<
28. boost::system::system_error(ec).what() << std::endl;
29. break;
30. }
31. // 與當(dāng)前客戶交互完成后循環(huán)繼續(xù)等待下一客戶連接
32. }
33. return 0;
34.}
客戶端
1.#include
2.#include
3.
4.using namespace boost::asio;
5.
6.int main(int argc, char* argv[])
7.{
8. // 所有asio類都需要io_service對象
9. io_service iosev;
10. // socket對象
11. ip::tcp::socket socket(iosev);
12. // 連接端點，這里使用了本機(jī)連接，可以修改IP地址測試遠(yuǎn)程連接
13. ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 1000);
14. // 連接服務(wù)器
15. boost::system::error_code ec;
16. socket.connect(ep,ec);
17. // 如果出錯，打印出錯信息
18. if(ec)
19. {
20. std::cout << boost::system::system_error(ec).what() << std::endl;
21. return -1; 22. }
23. // 接收數(shù)據(jù)
24. char buf[100];
25. size_t len=socket.read_some(buffer(buf), ec);
26. std::cout.write(buf, len);
27.
28. return 0;
29.}
從演示代碼可以得知
•ASIO的TCP協(xié)議通過boost::asio::ip名 空間下的tcp類進(jìn)行通信。
•IP地址（address,address_v4,address_v6）、 端口號和協(xié)議版本組成一個端點（tcp:: endpoint）。
用于在服務(wù)器端生成tcp::acceptor對 象，并在指定端口上等待連接；或者在客戶端連接到指定地址的服務(wù)器上。
•socket是 服務(wù)器與客戶端通信的橋梁，連接成功后所有的讀寫都是通過socket對 象實現(xiàn)的，當(dāng)socket析 構(gòu)后，連接自動斷 開。
•ASIO讀寫所用的緩沖區(qū)用buffer函 數(shù)生成，這個函數(shù)生成的是一個ASIO內(nèi)部使用的緩沖區(qū)類，它能把數(shù)組、指針（同時指定大 小）、std::vector、std::string、boost::array包裝成緩沖區(qū)類。
•ASIO中的函數(shù)、類方法都接受一個boost::system::error_code類 型的數(shù)據(jù)，用于提供出錯碼。
它可以轉(zhuǎn)換成bool測試是否出錯，并通過boost::system::system_error類 獲得詳細(xì)的出錯信息。
另外，也可以不向ASIO的函數(shù)或方法提供 boost::system::error_code，這時如果出錯的話就會直 接拋出異常，異常類型就是boost::system:: system_error(它是從std::runtime_error繼承的)。
posted on 2009-08-19 00:29
小王 閱讀(665)
評論(0) 編輯 收藏 引用 所屬分類:
網(wǎng)絡(luò)通訊