boost:asio::async_write：数据已发送但未调用处理程序

Posted 2023-04-14

【中文标题】boost:asio::async_write：数据已发送但未调用处理程序

【英文标题】：boost:asio::async_write: Data sent but handler not called

【发布时间】：2016-02-29 11:27:40

【问题描述】：

我有以下类定义：

// SocketTypeT may be e.g. 'boost::asio::ip::tcp::socket'
template<class SocketTypeT> 
class Socket : public SocketTypeT, public boost::enable_shared_from_this< Socket<SocketTypeT> > 
[...]

在这个类中，我有以下方法'writeAsync'：

void writeAsync(const std::string& strData)                
            boost::asio::async_write(*this, boost::asio::buffer(strData),                                   
                                    boost::bind(&Socket::handle_write_async,
                                    shared_from_this(),
                                    boost::asio::placeholders::error,
                                    boost::asio::placeholders::bytes_transferred));

最后是“writeAsync”中使用的处理程序（也是类成员函数）：

void handle_write_async(const boost::system::error_code& ec, std::size_t cntBytesSent) 
    cout << "handle_write_async" << endl;
    if (m_pSocketAsyncObserver) 
        m_pSocketAsyncObserver->handleAsyncWrite(connectionClosed, cntBytesSent, ec);
    

问题：

数据已成功传输到服务器，但从未调用过“handle_write_async”。这可能是什么原因？

【问题讨论】：

该代码表面上看起来没问题 - 你是在 io_service 上调用 run() 吗？

缺少对 run() 的调用。但即使调用运行结果也是一样的。调用顺序是否相关，例如我必须在使用io_service-object 初始化boost::asio::ip::tcp::socket 之前调用run 吗？

io_service::run() 是调度所有异步操作所必需的。通常你可以设置好所有东西（socket、connect等）然后调用run（因为它是一个阻塞操作——除非你在另一个线程中这样做。）

在我的情况下，对my_io_service.run() 的调用不会阻塞？

你必须在调用 async_write 之后调用 run。 Run 基本上意味着“运行作业并调用处理程序，直到没有剩余”，所以如果你在 async_write 之前调用它，就没有什么可做的了。如果这仍然不起作用，您能否提供您的完整示例以便我们进行调查？

【参考方案1】：

要连续执行run，您需要提供io_service::work 对象。请阅读this question