使用Asio（Boost）通过网络发送灵活的数据量

我有一个客户端和一个服务器应用程序，它们将通过使用Asio（独立）库相互发送数据。这两个应用程序都包含两个（逻辑）部分：

1. 高级部分：处理复杂的对象，例如用户，权限，...
2. 低级部分：在客户端和服务器之间通过网络发送数据

假设已经使用Protocoll Buffers对复杂对象进行了序列化，并且应用程序的底层部分从高层部分接收数据，如std :: string。我想使用Protocoll Buffers中的此功能来完成此工作：

bool SerializeToString（字符串*输出）const ;：对消息进行序列化并将字节存储在给定的字符串中。注意字节是二进制的，不是文本；我们仅将字符串类用作方便的容器。

并说我在客户端使用async_write传输此数据：

size_t dataLength = strlen(data);

//writes a certain number of bytes of data to a stream.
asio::async_write(mSocket,
                      asio::buffer(data, dataLength),
                      std::bind(&Client::writeCallback, this,
                                std::placeholders::_1,   
                                std::placeholders::_2)); 

如何在服务器端读取此数据？我不知道我将要读取多少数据。因此，这将不起作用（长度未知）：

 asio::async_read(mSocket,
                     asio::buffer(mResponse, length),
                     std::bind(&Server::readCallback, this,
                               std::placeholders::_1,
                               std::placeholders::_2));

解决此问题的最佳方法是什么？我可以想到两种解决方案：

1. 在“结尾”后面附加一个“特殊”字符data并读取，直到到达“数据信号结尾”为止。问题是，如果此字符以data某种方式出现怎么办？我不知道Protocoll Buffers如何序列化我的数据。
2. 发送带有size_of_data + data而不是的二进制字符串data。但是我不知道如何以独立于平台的方式序列化大小，将其添加到二进制数据并再次提取。

编辑：也许我可以用这个：

    uint64_t length = strlen(data);
    uint64_t nwlength = htonl(length);
    uint8_t len[8];
    len[0] = nwlength >> 56;
    len[1] = nwlength >> 48;
    len[2] = nwlength >> 40;
    len[3] = nwlength >> 32;
    len[4] = nwlength >> 24;
    len[5] = nwlength >> 16;
    len[6] = nwlength >> 8;
    len[7] = nwlength >> 0;

    std::string test(len);

    mRequest = data;
    mRequest.insert(0, test);

并发送mRequest到服务器？此代码有任何陷阱或警告吗？之后如何读取服务器端的长度和内容？可能是这样的：

void Server::readHeader(){

    asio::async_read(mSocket,
                     asio::buffer(header, HEADER_LENGTH),
                     std::bind(&Server::readHeaderCallback, this,
                               std::placeholders::_1,
                               std::placeholders::_2),
                     asio::transfer_exactly(HEADER_LENGTH));
}

void Server::readHeaderCallback(const asio::error_code& error,
                                        size_t bytes_transferred){

    if(!error && decodeHeader(header, mResponseLength)){
        //reading header finished, now read the content
        readContent();
    }
    else{
        if(error) std::cout << "Read failed: " << error.message() << "\n";
        else std::cout << "decodeHeader failed \n";       
    }
}

void Server::readContent(){

    asio::async_read(mSocket,
                     asio::buffer(mResponse, mResponseLength),
                     std::bind(&Server::readContentCallback, this,
                               std::placeholders::_1,
                               std::placeholders::_2),
                     asio::transfer_exactly(mResponseLength));
}

void Server::readContentCallback(const asio::error_code& error,
                                         size_t bytes_transferred){
    if (!error){
       //handle content
    }
    else{
        //@todo remove this cout
        std::cout << "Read failed: " << error.message() << "\n";      
    }
}

请注意，我尝试使用transfer_exactly。这样行吗？