8

我正在使用 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("abcdpqrs@gmail.com");
        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 发送的消息。如何在下面的代码中找出arg被设置为参数的值boost::asio::transfer_at_least？

 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 在读取整个对象后返回？

4

1 回答 1

7

正确，protobuf 没有分隔。不知道消息从字节流结束的地方——即使你已经看过所有你知道的字段，也可能有更多重复的元素，或者有人用你不知道的字段扩展了原型。

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

于 2012-06-08T19:44:56.867 回答