c # — получение сообщения Protobuf3 по сети

Я использую Protobuf3 с c # для моего клиента & c ++ для моего сервера, где .proto генерируются из соответствующего компилятора protoc3. Я новичок в использовании буферов протокола Google, где в настоящее время пытаюсь выяснить, как повторно проанализировать полученные на моем сервере байты, которые были отправлены с моего клиента, чтобы превратить его в исходный google :: protobuf :: Message Объект на моем сервере C ++.

Мой клиент отправляет CodedOutputStream в C #:

public PacketHandler()
{
m_client  = GetComponent<ClientObject>();
m_packet  = new byte[m_client.GetServerConnection().GetMaxPacketSize()];
m_ostream = new BinaryWriter(new MemoryStream(m_packet));
}

public void DataToSend(IMessage message)
{
CodedOutputStream output = new CodedOutputStream(m_ostream.BaseStream, true);
output.WriteMessage(message);
output.Flush();
m_client.GetServerConnection().GetClient().Send(m_packet, message.CalculateSize());
}

Кажется, это работает, сообщение, которое отправляется прямо сейчас, представляет собой простое сообщение Ping, которое выглядит так:

// Ping.proto
syntax = "proto3";
package server;

import "BaseMessage.proto";

message Ping {
base.BaseMessage base = 1;
}

message Pong {
base.BaseMessage base = 1;
}

Мой BaseMessage выглядит так:

// BaseMessage.proto
syntax = "proto3";

package base;

message BaseMessage {
uint32 size = 1;
}

Мой план состоит в том, чтобы, надеюсь, расширить все мои сообщения из BaseMessage, чтобы в конечном итоге можно было идентифицировать конкретное сообщение. Как только я получу разбор & повторный разбор разобрался.

Полученное сообщение, которое я получаю на стороне сервера c ++, выглядит следующим образом: \ u0004 \ n \ u0002 \ b

При получении сообщения я пытаюсь повторно проанализировать, используя объект CodedInputStream, пытаясь проанализировать полученные байты.

PacketHandler::PacketHandler(QByteArray& packet, const Manager::ClientPtr client) :
m_packet(packet),
m_client(client)
{
//unsigned char buffer[512] = { 0 };
unsigned char data[packet.size()] = { 0 };
memcpy(data, packet.data(), packet.size());

google::protobuf::uint32 msgSize;
google::protobuf::io::CodedInputStream inputStream(data, packet.size());
//inputStream.ReadVarint32(&msgSize);
//inputStream.ReadRaw(buffer, packet.size());
server::Ping pingMsg;
pingMsg.ParseFromCodedStream(&inputStream);
qDebug() << pingMsg.base().size();
}

Вот где я немного не уверен в том, какой процесс необходимо выполнить, чтобы повторно проанализировать сообщение в конкретном сообщении. Я считаю, что если я использую BaseMessage, который расширяет все сообщения, которые позволят мне идентифицировать конкретное сообщение, чтобы я знал, какое из них создать. Однако в этом текущем тесте, где я знаю, что это будет сообщение Ping, ParseFromCodedStream, похоже, не создает исходное сообщение. Мои рассуждения основаны на том, что во время моего qDebug () pingMsg.base (). Size () не является правильным значением, которое было установлено во время фазы отправки в моем клиенте c #.