boost::asio::async_write异步写入操作的顺序保证问题咨询

核心结论 #

Boost.Asio不保证连续调用两次async_write能严格按照调用顺序将数据写入套接字。直接像你那样连续发起两个异步写入操作，data2的部分字节可能会先于data1的部分字节被发送，导致数据错乱。

原因 #

async_write是异步操作，调用后会立即返回，底层IO服务会调度操作的执行时机。两次异步写入请求会被放入IO服务的任务队列，但调度顺序不一定和调用顺序完全一致；同时，如果套接字发送缓冲区有剩余空间，后续的写入操作可能抢先写入部分数据，破坏顺序。

确保写入顺序的方法 #

• 链式回调调用：在第一个async_write的完成回调中发起第二个写入操作，确保第一个写入完全完成后才开始第二个。示例代码：

  boost::asio::async_write(socket, boost::asio::buffer(data1),
      [&](const boost::system::error_code& ec, std::size_t bytes) {
          if (!ec) { // 第一个写入成功完成后再发起第二个
              boost::asio::async_write(socket, boost::asio::buffer(data2), function);
          }
      });
  

• 维护写入队列：如果需要处理多次写入请求，可以维护一个待发送数据的队列。每次仅当当前没有正在进行的写入操作时，从队列取出数据发起async_write；在写入完成的回调中，继续处理队列中的下一个数据。这种方式避免了深层嵌套回调，适合复杂的写入场景。

• 合并缓冲区：如果data1和data2逻辑上是连续的，可以将它们合并为一个连续的缓冲区序列，然后调用一次async_write。比如使用boost::asio::buffer_sequence组合多个缓冲区：

  std::vector<boost::asio::const_buffer> buffers;
  buffers.push_back(boost::asio::buffer(data1));
  buffers.push_back(boost::asio::buffer(data2));
  boost::asio::async_write(socket, buffers, function);
  

内容的提问来源于stack exchange，提问作者Joseph Conrad