很难理解带有 async_read 和 async_write 的 Boost ASIO TCP 的一些概念

我很难理解使用 async_read 和 async_write 时构建 tcp 客户端的正确方法。这examples http://www.boost.org/doc/libs/1_38_0/doc/html/boost_asio/example/echo/async_tcp_echo_server.cpp似乎在连接后执行 async_read，然后在处理程序中执行 async_write。

就我的客户端和服务器而言，当客户端连接时，它需要检查要写入的消息队列，并检查是否需要读取任何内容。我遇到困难的一件事是理解这是如何异步工作的。

我设想的是在 async_connect 处理程序中，如果 sendQueue 中有任何内容，线程将调用 async_write 并一遍又一遍地调用 async_read 。或者它应该在执行 async_read 之前检查是否有任何内容可供读取？ 下面是我正在谈论的一个例子。

void BoostTCPConnection::connectHandler()
{
    setRunning(true);
    while (isRunning())
    {
        //If send Queue has messages
        if ( sendSize > 0)
        {
            //Calls to async_write
            send();
        }

        boost::shared_ptr<std::vector<char> > sizeBuffer(new std::vector<char>(4));
        boost::asio::async_read(socket_, boost::asio::buffer(data, size), boost::bind(&BoostTCPConnection::handleReceive, shared_from_this(), boost::asio::placeholders::error, sizeBuffer));

   }    
}

void BoostTCPConnection::handleReceive(const boost::system::error_code& error, boost::shared_ptr<std::vector<char> > sizeBuffer)
{

    if (error)
    {
        //Handle Error
        return;
    }

    size_t messageSize(0);
    memcpy((void*)(&messageSize),(void*)sizeBuffer.data(),4);

    boost::shared_ptr<std::vector<char> > message(new std::vector<char>(messageSize) );

    //Will this create a race condition with other reads?
    //Should a regular read happen here
    boost::asio::async_read(socket_, boost::asio::buffer(data, size), 
                    boost::bind(&BoostTCPConnection::handleReceiveMessage, shared_from_this(),
                    boost::asio::placeholders::error, message));

}

void BoostTCPConnection::handleReceiveMessage(const boost::system::error_code& error, boost::shared_ptr<std::vector<char> > rcvBuffer)
{
    if (error)
    {
        //Handle Error
        return;
    }

    boost::shared_ptr<std::string> message(new std::string(rcvBuffer.begin(),rcvBuffer.end())); 
    receivedMsgs_.push_back(message);
}

void BoostTCPConnection::handleWrite(const boost::system::error_code& error,size_t bytes_transferred)
{
    //Success
    if (error.value() == 0) 
        return;
    //else handleError


}

从概念上讲，async_read等待接收数据。当您希望在收到数据后发生某些事情并且读取尚未挂起时，您应该随时调用它。相似地，async_write等待数据写入。当您需要写入数据并且写入尚未挂起时，您应该调用它。

你应该打电话async_read当您完成连接时。在你之前async_read处理程序返回，它可能应该调用async_read again.

当您需要写入连接时，您应该调用async_write（如果写入尚未挂起）。在你的async_writehandler，如果你还需要写更多，你应该调用async_write again.

如果没有待读的内容，您可以致电async_read在您的写入处理程序中，如果您希望在完成写入后继续读取。您也可以始终保持读取状态。这取决于你。

在打电话之前你不应该检查是否有任何内容要阅读async_read。要点是async_read是为了当有东西可读时完成它。这是一种等待的同时做其他事情的明智方式。