Asio asyn_read沒(méi)有被回調(diào)

chen1922

初次接觸asio，照著例子寫(xiě)了一個(gè)，鏈接的是echo_server
echo_server收到了發(fā)送的數(shù)據(jù)，也返回了.
問(wèn)題1.io_service在resolver之前就run,為啥會(huì)提示boost::system 995錯(cuò)誤
問(wèn)題2.客戶端異步發(fā)送了,但是沒(méi)有異步讀取。如果改成同步讀取又能收到數(shù)據(jù)

幫忙看下是啥問(wèn)題。

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. //問(wèn)題1.如果在這里調(diào)用run函數(shù)，就會(huì)提示boost::system 995錯(cuò)誤
    
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. //問(wèn)題2.異步讀沒(méi)有收到，如果改成boost::asio::read_some可以收到數(shù)據(jù)
    
92. 
    
93.     std::thread t([&io_service]() { io_service.run(); });
    
94.     t.join();
    
95.    
    
96.     //system("pause");
    
97.     return 0;
    
98. }

復(fù)制代碼

fender0107401

[this] 是什么意思啊，怎么從來(lái)沒(méi)見(jiàn)過(guò)？

chen1922

回復(fù) 2# fender0107401


    lambda捕獲當(dāng)前類的指針，這樣回調(diào)函數(shù)就能訪問(wèn)類的成員了