Boost asio async_write 回调不会被调用

Question

我正在尝试编写一个简单的服务器来异步发送消息，但是我的 async_write 回调没有被调用。顺便说一句，数据已成功传输到客户端。

首先，我的服务器初始化代码：

void Server::start()
{
    ioService = new boost::asio::io_service();
    acceptor = new tcp::acceptor(*ioService, tcp::endpoint(tcp::v4(), port));

    serverRunning = true;

    serverThread = new boost::thread(&Server::run, this);
    startAccept();
}

我的开始接受和接受处理程序方法：

void Server::startAccept()
{
    serverSocket = new tcp::socket(acceptor->get_io_service());

    acceptor->async_accept(*serverSocket,
        boost::bind(&Server::handleAccept, shared_from_this(),
            boost::asio::placeholders::error));
}

void Server::handleAccept( const boost::system::error_code& error )
{
    changeState(Connected);
}

handleAccept 方法在我连接时被调用，changeState 方法现在什么都不做。客户端连接后，我将一些数据放到toSend向量中，服务器的线程发送它们：

void Server::run(){
    while( serverRunning ){
        ioService->poll();

        if (toSend.size()>0 ){
            mtx.lock();
            for (int i=0; i<toSend.size(); i++){
              cout << "async write" << endl;
                boost::asio::async_write(*serverSocket, boost::asio::buffer(toSend.at(i)),
                        boost::bind(&Server::handleSend, shared_from_this(),
                            toSend.at(i),
                            boost::asio::placeholders::error,
                            boost::asio::placeholders::bytes_transferred));
            }
            toSend.clear();
            mtx.unlock();
        }
        usleep(1000);
    }
}

我可以看到标准输出上出现“异步写入”消息，并且客户端也收到了数据。我的 handleSend 方法现在只是一些 cout，但它永远不会被调用。为什么？

Answer 1

如果你真的想手动 poll io_service，在它得到一些工作后执行此操作，然后调用 reset between the iterations。

此外，不要循环调用asio::async_write - 数据不会以正确的顺序到达。相反，要么准备一个缓冲区序列并立即发送，要么链接async_write - 完成处理程序 - async_write，如示例中所示。