使用boost::asio::read_async读取Protobuf对象

Question

我正在使用Boost asio编写一个应用程序，其中客户端和服务器通过使用Google Proto-buffers序列化的消息进行交换。我不知道在网络上传输的序列化消息的大小。似乎Proto-buf对象没有任何分隔符。

以下是.proto文件的内容。

 package tutorial;

message Person {
        required string name = 1;
        required int32 id = 2;
        optional string email = 3;
}

以下是我从服务器编写的方式

        tutorial::Person p;
        p.set_name("abcd pqrs");
        p.set_id(123456);
        p.set_email("[e-mail]");
        write(p);

        boost::asio::streambuf b;
        std::ostream os(&b);
        p.SerializeToOstream(&os);
        boost::asio::async_write(socket_, b,
                        boost::bind(&Server::handle_write, this,
                                boost::asio::placeholders::error));

在客户端中，我使用boost::asio::async_read读取上面发送的消息。在下面的代码中，如何找出作为参数设置为boost::asio::transfer_at_least的arg的值?

 boost::asio::async_read(socket_, response_,
                            boost::asio::transfer_at_least(arg),
                            boost::bind(&Client::handle_read_header, this,
                                    boost::asio::placeholders::error));

否则我怎样才能确保boost::async_read在读取完整个对象后返回？

- bisarch

---

我不知道答案，但我也很感兴趣，所以点赞。 - John Dibling

你解决了你的问题吗？我非常感兴趣，但仍然没有明确的决定是否将protobuf和boost::asio结合在一起。 - Vitaly Isaev

Answer 1

没错，protobufs没有分隔符。仅凭字节流无法确定消息的结束位置——即使您已经看到了所有您知道的字段，可能还有更多的重复元素或某人使用一个您不知道的字段扩展了proto。

一个常见的解决方案是在帧前加上长度（通常编码为VarInt）。例如，LevelDB和Szl都使用这种方法。 VarInt可以通过逐字节进行无歧义解码，然后您就知道在解析完整个消息之前需要读取多少个字节。

- ephemient

---

参见https://dev59.com/xHE95IYBdhLWcg3wXsuR，一些API具有分隔符写入/读取功能，正如答案中提到的，您可以轻松地自行实现这些功能。 - Andreas