boost::async_write 写入一段时间后失败

Question

我有一个非常特殊的问题。我编写了一个服务器，将从第三方接收的数据写入连接的客户端。服务器向客户端写入数据一段时间正常，但过了一段时间后，async_write 要么失败，要么写入永远不会返回。对于我的程序，如果 async_write 永远不会返回，则不会发生后续写入，并且我的服务器将从第三方接收的数据排队，直到一切崩溃。

我已在下面包含我的代码：

void ClientPartitionServer::HandleSignal(const CommonSessionMessage& message, int transferSize) {
  boost::lock_guard<boost::mutex> lock(m_mutex);
  if(m_clientSockets.size() != 0) {
    TransferToQueueBuffer(message.GetData(), transferSize);
  }
  if(m_writeCompleteFlag) {
    // TransferToWriteBuffer();
    for(vector<boost::asio::ip::tcp::socket*>::const_iterator i = m_clientSockets.begin(); i != m_clientSockets.end(); ++i) {
      WriteToClient(*i);
    }
  }
}

void ClientPartitionServer::WriteToClient(boost::asio::ip::tcp::socket* clientSocket) {
  m_writeCompleteFlag = false;
  cout << "Iniating write: " << m_identifier << endl;
  boost::asio::async_write(
    *clientSocket,
    boost::asio::buffer(m_queueBuffer.get(), m_queueBufferSize),
    boost::bind(
      &ClientPartitionServer::HandleWrite, this,
      boost::asio::placeholders::error,
      boost::asio::placeholders::bytes_transferred
  ));
}

void ClientPartitionServer::HandleWrite(const boost::system::error_code& ec, size_t bytes_transferred) {
  boost::lock_guard<boost::mutex> lock(m_mutex);
  if(ec != 0) {
    cerr << "Error writing to client: " << ec.message() << " " << m_identifier << endl;
    // return;
    cout << "HandleWrite Error" << endl;
    exit(0);
  }
  cout << "Write complete: " << m_identifier << endl;
  m_writeCompleteFlag = true;
  m_queueBuffer.reset();
  m_queueBufferSize = 0;
}

任何帮助将不胜感激。

谢谢。

Answer 1

如果没有看到所有代码，很难说，但对我来说，您在多个（甚至一个）WriteToClient 调用中持有互斥体是一个危险信号。通常，在 I/O 上持有任何类型的锁（甚至像这里的异步锁），往好里说都会对性能造成影响，往坏里说，会在负载下导致奇怪的死锁。例如，如果异步写入内联完成并且您在同一线程/调用堆栈中的 HandleWrite 上被回调，会发生什么？

我会尝试重构它，以便在写入调用期间释放锁。

无论解决方案是什么，更一般的建议是：

• 不要跨 I/O 锁定，
• 添加一些诊断输出 - 什么
  线程调用每个处理程序，并在
  什么顺序？
• 一旦你点击了就尝试调试
  静态。应该可以
  从
  诊断死锁
  进程状态。

Answer 2

使用链来序列化对特定连接对象的访问。特别是，请查看 strand::wrap ()。要查看使用链的其他示例，请查看 aa 几个不同的 定时器示例 （尽管该代码适用于任何 async_*() 调用）。

Answer 3

首先，我不同意指出跨异步操作持有锁是一个问题的评论。

持有锁：

1. 任何调用回调的函数都是不好的。

2. 任何阻塞操作都是不好的。

async_write 明确保证既不阻塞也不调用处理程序，因此对我来说持有锁看起来很好。

但是，我发现您的代码中存在一个错误，该错误违反了 async_write 的另一项要求。在调用完成处理程序之前，您不能调用 async_write。这就是你违反的。

每当调用其中一个处理程序时，m_writeCompleteFlag 就会设置为 true。这意味着您可能会违反高负载下其他一些 N-1 套接字的 async_write 规则。