《C++Boost库asio》第九篇

dnfpk001

Echo服务器对应的C++客户端 ：
（对照上一篇来学习，接收和发送的顺序是一样的）

1. 
   
2. // Echo服务器对应的C++客户端 ：
   
3. // 同步的，阻塞式的客户端
   
4. #include <iostream>
   
5. #include <cstdlib>
   
6. #include <cstring>
   
7. #include <boost\asio.hpp>
   
8. #include <boost\array.hpp>
   
9. 
   
10. //不用UDP协议的原因是包的大小有限制，然后有可能是乱序，
    
11. // 重发，丢包都有可能，有TCP还是比较简单安全的
    
12. 
    
13. using boost::asio::ip::tcp;
    
14. 
    
15. enum { max_length = 1024 };
    
16. 
    
17. int main()
    
18. {
    
19.         boost::asio::io_service io_service;
    
20. 
    
21.         tcp::socket s(io_service);
    
22.         tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 2001);
    
23.         s.connect(ep);
    
24. 
    
25.         //在这里，3次握手成功
    
26. 
    
27.         size_t request_length = 1024;
    
28.         char reply[max_length];
    
29.         size_t reply_length;
    
30.         // --接收服务器发来的当前时间 ;       
    
31. 
    
32. 
    
33.         boost::array<char, 128> buf;//字节流缓存
    
34.         boost::system::error_code error;//错误码的形式来返回错误，而不是用抛出异常的方式
    
35.         size_t len = s.read_some(boost::asio::buffer(buf), error);//开始读取服务器发来的数据
    
36.         if (error == boost::asio::error::eof)
    
37.         {
    
38.                 return 0;// 服务器关闭了连接，客户端可以直接退出了
    
39.         }
    
40.         else if (error)
    
41.         {
    
42.                 throw boost::system::system_error(error);//一些其他的错误
    
43.         }
    
44.         std::cout << "Reply is :";
    
45.         std::cout.write(buf.data(), len);//输出到控制台
    
46. 
    
47. 
    
48.         // --发消息给服务器 ;
    
49.         std::cout << "Enter message:";
    
50.         char request[max_length];
    
51.         std::cin.getline(request, max_length);//输入
    
52.         request_length = std::strlen(request);
    
53.         boost::asio::write(s, boost::asio::buffer(request, request_length)); // 出错会抛出异常;
    
54. 
    
55.         // --接收服务器发来的消息 ;
    
56.         //错了会抛异常，真正收到request_length多长度的数据后才会往下走，否则一直等待
    
57.         reply_length = boost::asio::read(s, boost::asio::buffer(reply,request_length));
    
58.         std::cout << "Reply is :";
    
59.         std::cout.write(reply, reply_length);//输出到控制台
    
60. 
    
61. 
    
62.         getchar();
    
63.         system("pause");
    
64.     return 0;
    
65. }
    

复制代码