我在使用 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 文件中(作为新成员,我可以在每个帖子中拥有一个超链接)。
提前谢谢大家,丹尼尔。