Asio asyn_read没有被回调

chen1922

初次接触asio，照着例子写了一个，链接的是echo_server
echo_server收到了发送的数据，也返回了.
问题1.io_service在resolver之前就run,为啥会提示boost::system 995错误
问题2.客户端异步发送了,但是没有异步读取。如果改成同步读取又能收到数据

帮忙看下是啥问题。

1. class Client
   
2. {
   
3. public:
   
4.     Client(boost::asio::io_service& io_service)
   
5.         : m_io_service(io_service)
   
6.         , m_socket(io_service)
   
7.     {
   
8.     }
   
9. 
   
10.     void doConnect(boost::asio::ip::tcp::resolver::iterator it)
    
11.     {
    
12.         boost::asio::async_connect(m_socket, it,
    
13.             [this](boost::system::error_code ec, boost::asio::ip::tcp::resolver::iterator)
    
14.             {
    
15.                 if (!ec) {
    
16.                     doRead();
    
17.                 } else {
    
18.                     std::cout << ec;
    
19.                 }
    
20.             });
    
21.     }
    
22. 
    
23.     void doRead()
    
24.     {
    
25.         boost::asio::async_read(m_socket, boost::asio::buffer(m_buffer, 1024),
    
26.             [this](boost::system::error_code ec, std::size_t length)
    
27.             {
    
28.                 if (!ec) {
    
29.                     if (length > 0) {
    
30.                         std::string s(m_buffer.data(), m_buffer.data() + length);
    
31.                         std::cout << "read:" << s << "\n";
    
32.                     }
    
33.                     doRead();
    
34.                 } else {
    
35.                     std::cout << ec;
    
36.                     m_socket.close();
    
37.                 }
    
38.             });
    
39.     }
    
40. 
    
41.     void sendMsg(std::string s)
    
42.     {
    
43.         m_io_service.post([this, s]()
    
44.         {
    
45.             bool write_in_progress = !m_write_msgs.empty();
    
46.             m_write_msgs.push_back(s);
    
47.             if (!write_in_progress) {
    
48.                 doWrite();
    
49.             }
    
50.         });
    
51.     }
    
52. 
    
53.     void doWrite()
    
54.     {
    
55.         boost::asio::async_write(m_socket,
    
56.             boost::asio::buffer(m_write_msgs.front().data(), m_write_msgs.front().length()),
    
57.             [this](boost::system::error_code ec, std::size_t /*length*/)
    
58.             {
    
59.                 if (!ec) {
    
60.                     m_write_msgs.pop_front();
    
61.                     if (!m_write_msgs.empty()) {
    
62.                         doWrite();
    
63.                     }
    
64.                 } else {
    
65.                     m_socket.close();
    
66.                 }
    
67.             });
    
68.     }
    
69. 
    
70.     boost::asio::io_service&        m_io_service;
    
71.     boost::asio::ip::tcp::socket    m_socket;
    
72.     std::array<char, 1024>          m_buffer;
    
73.     std::list<std::string>          m_write_msgs;
    
74. };
    
75. 
    
76. int main()
    
77. {
    
78.     boost::asio::io_service io_service;
    
79.     boost::asio::io_service::work work(io_service);
    
80. //问题1.如果在这里调用run函数，就会提示boost::system 995错误
    
81. //    std::thread t([&io_service]() { io_service.run(); });
    
82. 
    
83.     boost::asio::ip::tcp::resolver resolver(io_service);
    
84.     auto endpoint_it = resolver.resolve({IP, PORT});
    
85. 
    
86.     Client c(io_service);
    
87.     c.doConnect(endpoint_it);
    
88. 
    
89. 
    
90.     c.sendMsg("ssssss");
    
91. //问题2.异步读没有收到，如果改成boost::asio::read_some可以收到数据
    
92. 
    
93.     std::thread t([&io_service]() { io_service.run(); });
    
94.     t.join();
    
95.    
    
96.     //system("pause");
    
97.     return 0;
    
98. }

复制代码

fender0107401

[this] 是什么意思啊，怎么从来没见过？

chen1922

回复 2# fender0107401


    lambda捕获当前类的指针，这样回调函数就能访问类的成员了