如何使用 boost 冲洗插座

Question

我正在实现一个使用 boost 向客户端发送 xml 的服务器。我面临的问题是缓冲区不会立即发送并累积到一个点然后发送整个内容。这会导致我的客户端出现问题，当它解析 xml 时，它可能有不完整的 xml 标签（不完整的消息）。 boost 有没有办法在需要发送消息时刷新套接字？下面是服务器的写入代码。

void 
ClientConnection::handle_write(const boost::system::error_code& error)
{

    if (!error)
    {

        m_push_message_queue.pop_front ();
        if (!m_push_message_queue.empty () && !m_disconnected)
        {

             boost::asio::async_write(m_socket,
            boost::asio::buffer(m_push_message_queue.front().data(), 
                        m_push_message_queue.front().length()),
                boost::bind(&ClientConnection::handle_write, this,
                boost::asio::placeholders::error));
        }
    }
    else
    {
      std::err << "Error writting out message...\n";
      m_disconnected = true;
      m_server->DisconnectedClient (this);

    }
}

Answer 1

通常，当使用 TCP 字节流创建应用程序时，发送方会发送固定长度的标头，以便接收方知道需要多少字节。然后接收器读取那么多字节并将生成的缓冲区解析为 XML 对象。

Answer 2

我假设你正在使用 TCP 连接。 TCP 是流类型，因此您不能假设您的数据包将来自一个大数据包。您需要修复您的通信设计，首先发送大小长度（如 San Miller 答案），或者在发送所有 xml 数据后发送标志或分隔符。

Answer 3

假设您肯定要清除套接字上的一些数据，您可以执行以下操作：

void fulsh_socket()
{
    boost::asio::streambuf b;
    boost::asio::streambuf::mutable_buffers_type bufs = b.prepare(BUFFER_SIZE);
    std::size_t bytes = socket_.receive(bufs); // !!! This will block until some data becomes available
    b.commit(bytes);
    boost::asio::socket_base::bytes_readable command(true);
    socket_.io_control(command); 

    while(command.get())
    {
        bufs = b.prepare(BUFFER_SIZE);
        bytes = socket_.receive(bufs);
        b.commit(bytes);
        socket_.io_control(command); // reset for bytes pending
    }
    return;
}

其中 socket_ 是一个成员变量。

华泰