如何检查boost socket write_some方法是否结束

Question

我正在尝试使用 boost socket 发送一些数据。 TCPClient 类的作用是使连接 cna 可以发送数据抛出 sendMessage 方法。

当我在代码下执行时，它不起作用。但是，当我调试它时它可以工作。 我认为问题在于时机。

删除[] 消息；在发送消息之前工作。（只是我的想法）

所以，我想检查是否发送了 msg。 或任何其他好方法。

客户端 main() 代码

TCPClient *client = new TCPClient(ip, port);
client->sendMessage((char *)msg, 64 + headerLength + bodyLength);
delete[] msg;

下面的代码是snedMessage方法。

void TCPClient::sendMessage(const char *message, int totalLength) throw(boost::system::system_error) {

if(false == isConnected())
    setConnection();

boost::system::error_code error;
this->socket.get()->write_some(boost::asio::buffer(message, totalLength), error);

if(error){
        //do something
}

}

Answer 1

您的sendMessage() 函数编写不正确。您不能期望套接字会一次发送所有数据，您需要一个尝试发送的循环，检查发送了多少字节，如有必要，偏移缓冲区（当然并相应地更新totalLength）并重复直到所有数据已发送。如果有错误条件，则中断。您尝试只发送一次，忽略结果并假设如果没有错误则所有数据都已发送。这不是个案。流套接字一次可以发送一两个或任意数量的字节，您的代码需要处理。

你的代码应该是这样的：

while( totalLength ) {
    boost::system::error_code error;
    auto sz = this->socket.get()->write_some(boost::asio::buffer(message, totalLength), error);

    if(error){
        //do something and interrupt the loop
    }
    totalLength -= sz;
    message += sz;
}