boost :: asio :: read_asyncを使ってProtobufオブジェクトを読む

Question

私はクライアントとサーバがgoogle proto-buffersを使ってシリアル化されたメッセージを交換するBoost asioを使ってアプリケーションを書いています。ネットワーク経由で送信されるシリアライズされたメッセージのサイズは何か分かりません。 proto-bufオブジェクトにはデリミタがないようです。

ここには、.protoファイルの内容があります。私はブースト:: ASIO :: async_readを使用して、上記送信されたメッセージを読んでいたクライアントでは、サーバ

 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)); 

から書いていますどのようにここで

package tutorial; 

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

です。下のコードで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が返されるようにするにはどうすればよいですか？

Answer 1

正しい、protobufsは区切られません。たとえあなたが知っているすべてのフィールドを見たとしても、繰り返しの要素が多いか、誰かがあなたが知らないフィールドでプロトタイプを拡張したとしても、メッセージがただのバイトストリームから終わるところを知ることはできません。

一般的な解決策は、フレームに長さ（通常はVarIntとしてエンコードされます）をプレフィックスに付けることです。 LevelDBとSzlは両方ともこのアプローチを使用します。 VarIntは、一意にバイトごとにデコードすることができます。その後、完全なメッセージを解析する前に、読み取るバイト数を知ることができます。