Boost.Asio同步通讯

Question

我在使用 asio 时遇到问题。 我的客户端/服务器应用程序仅需要同步通信。 因此，使用 boost 主页中的同步示例，我设置了两个程序来发送和接收数据。 他们的代码如下：

void vReceive(tcp::socket & socket, std::string & szDest){
    char szTmp_Buf [BUF_LEN + 1];
    szDest = "";
    std::cout << "Entering vReceive . . ." << std::endl;

    for (;;){
      char szBuf [BUF_LEN];
      boost::system::error_code error;
      uInt uiBytes_Recv = socket.read_some(boost::asio::buffer(szBuf), error);
      std::cout << " Read " << uiBytes_Recv << " bytes" << std::endl;
      if (error == boost::asio::error::eof)
         break; // Connection closed cleanly by peer.
      else if (error)
         throw boost::system::system_error(error); // Some other error.

      memcpy((void*) szTmp_Buf, (void*) szBuf, uiBytes_Recv );
      szTmp_Buf[ uiBytes_Recv ] = '\0';
      szDest += szTmp_Buf;
      };
      std::cout << "Received" << szDest << std::endl;
      std::cout << "Leaving vReceive . . ." << std::endl << std::endl;
   };

void vSend(tcp::socket & socket, std::string & szSrc){
    std::cout << "Entering vSend . . . " << std::endl;
    std::cout << "Sending " << szSrc << std::endl;
    boost::system::error_code ignored_error;
    boost::asio::write(socket, boost::asio::buffer(szSrc), boost::asio::transfer_all(), ignored_error);
    std::cout << "Leaving vSend . . . " << std::endl << std::endl;
    };

这些过程只是从 boost 示例中提取的代码行的包装。

在我的测试应用程序中，客户端调用

std::string szDate;
vReceive(socket, szDate);
vSend(socket, std::string("Chop Suey!") );
vReceive(socket, szDate);
vSend(socket, std::string("Halo"));

和服务器调用

std::string message = make_daytime_string();
std::string szReceived;
vSend(socket, message);
vReceive(socket, szReceived);
vSend(socket, message);
vReceive(socket, szReceived);

只是为了测试功能。 问题是两个应用程序在第一次信息交换后都会冻结，正如我在下面的图片。 客户端的 vReceive() 过程似乎没有完成，而 vSend() 在服务器端完成。 那么，有人知道可能出了什么问题吗？

以防万一有人想要复制该问题，我将完整的源代码上传到同一服务器，其中图片位于 asio_problem.rar 文件中（作为新成员，我可以为每个帖子添加一个超链接）。

谢谢大家， 丹尼尔.

Answer 1

我认为你的问题出在这里：

for (;;){
  /* snipped */

  if (error == boost::asio::error::eof)
     break; // Connection closed cleanly by peer.
  else if (error)
     throw boost::system::system_error(error); // Some other error.

  /* snipped */
}

你无限循环直到连接关闭（打破循环的唯一方法是如果你从套接字收到 EOF 错误），但 vSend 永远不会关闭套接字。 这意味着客户端中的 vReceive 将永远等待，始终期待更多数据。 将 socket.close() 放入 vSend 应该可以很好地实现这一目的。

当然，这意味着您的客户端和服务器在每次调用 vReceive 和 vSend 后都需要重新打开套接字。 如果这不合需要，那么我建议发送方使用其他一些方法来通知接收方不再发送数据。

我不确定您对通过线路发送的数据是否有任何限制，但是可以在消息开头发送“数据长度”值，或者在消息末尾发送某种“数据结束”哨兵值会给你一个漂亮、清晰的指示，告诉你何时停止监听更多数据。

这种方法还有一个额外的好处，那就是让您有理由使用 ASIO 的 read_until （或类似）功能来处理等待数据结束的逻辑。