Я использую protobuf для сериализации сообщения, которое я отправляю через сокетное соединение в C++. Для связи я хотел бы добавить заголовок к сообщениям, указывающий длину сообщения. Что вы думаете об этой реализации? Я провел небольшое исследование, и вот что я собрал.
Есть ли более приятный способ сделать это? Может ли эта реализация вызвать какие-либо проблемы? Я знаю, что есть поддержка API для Java, но, к сожалению, нет для C++.
bool send_message(int socket, my_protobuf::Message message)
{
google::protobuf::uint32 message_length = message.ByteSize();
int prefix_length = sizeof(message_length);
int buffer_length = prefix_length + message_length;
google::protobuf::uint8 buffer[buffer_length];
google::protobuf::io::ArrayOutputStream array_output(buffer, buffer_length);
google::protobuf::io::CodedOutputStream coded_output(&array_output);
coded_output.WriteLittleEndian32(message_length);
message.SerializeToCodedStream(&coded_output);
int sent_bytes = write(socket, buffer, buffer_length);
if (sent_bytes != buffer_length) {
return false;
}
return true;
}
bool recv_message(int socket, my_protobuf::Message *message)
{
google::protobuf::uint32 message_length;
int prefix_length = sizeof(message_length);
google::protobuf::uint8 prefix[prefix_length];
if (prefix_length != read(socket, prefix, prefix_length)) {
return false;
}
google::protobuf::io::CodedInputStream::ReadLittleEndian32FromArray(prefix,
&message_length);
google::protobuf::uint8 buffer[message_length];
if (message_length != read(socket, buffer, message_length)) {
return false;
}
google::protobuf::io::ArrayInputStream array_input(buffer, message_length);
google::protobuf::io::CodedInputStream coded_input(&array_input);
if (!message->ParseFromCodedStream(&coded_input)) {
return false;
}
return true;
}