asio::async_write 的坑

梦想游戏人
目录:
C/C++
同一个socket 的async_write操作内部是调用async_write_some 去执行的,在WriteDone之前,如果再次调用async_write 会导致 发送的stream顺序错乱, 典型复现是,
boost::asio::async_write(socket, buffer(xxx, 1024000), yield[ec]);
boost::asio::async_write(socket, buffer(buf, 32), std::bind(&Session::write, this, std::placeholders::_1, std::placeholders::_2));

客户端收到的 数据就会乱掉,

解决方案:

添加发送队列就好了

void CAsioSession4S::HandleWriteDone(const boost::system::error_code &ec)
{
	if (this->_sending != nullptr)
	{
		delete this->_sending;
		this->_sending = nullptr;
	}
	//error will disconnected
	if (ec)
	{
		while (!_sendQueue.empty())
		{
			delete _sendQueue.front();
			_sendQueue.pop();
		}
		this->Disconnect();
		return;
	}
	//检查发送队列
	if (!_sendQueue.empty())
	{
		this->_sending = _sendQueue.front();
		_sendQueue.pop();
		boost::asio::async_write((*_socket.get()), this->_sending->send, std::bind(&CAsioSession4S::HandleWriteDone, this->shared_from_this(), std::placeholders::_1));
	}
}
Scroll Up