Lectura de objetos Protobuf usando boost :: asio :: read_async

Question

Estoy escribiendo una aplicación usando Boost asio en la que el cliente y el servidor intercambian mensajes que se serializan utilizando los proto-buffers de Google. No sé cuál es el tamaño del mensaje serializado que se envía a través de la red. Parece que los objetos proto-buf no tienen ningún delimitador.

Aquí están los contenidos del archivo .proto.

package tutorial; 

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

Así es como estoy escribiendo desde el servidor

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

En el cliente que estoy leyendo el mensaje enviado anteriormente usando ASIO impulso :: :: async_read. ¿Cómo puedo averiguar que el valor de arg se establezca como argumento en boost::asio::transfer_at_least, en el código siguiente?

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

O bien, ¿cómo puedo asegurarme de que boost :: async_read regrese después de leer todo el objeto?

Answer 1

Correcto, los protobufs no están delimitados. No hay forma de saber dónde termina un mensaje simplemente de una corriente secundaria: incluso si ha visto todos los campos que conoce, tal vez haya más elementos repetidos o alguien haya extendido el protocolo con un campo que desconoce.

Una solución común es prefijar marcos con longitudes (comúnmente codificadas como VarInt s). LevelDB y Szl ambos usan este enfoque, por ejemplo. A VarInt se puede decodificar de manera inequívoca byte por byte, y luego se sabe cuántos bytes más leer antes de analizar su mensaje completo.