Protobuf C# для Java десериализация несколько сообщений

Question

Я пытаюсь разобрать несколько сообщений буфера протокола в Java, которые генерируются в vb.net

Я использую отличную Protobuf-сеть для потоковой передачи несколько сообщений на Java как на ниже:

ProtoBuf.Serializer.SerializeWithLengthPrefix(Of Msg)(postStream, msg, 
     ProtoBuf.PrefixStyle.Base128) 

в Java, я использую следующий код для разбора сообщений

final byte[] buffer = new byte[4096]; 
for (int c = ins.read(buffer); c >= 0; c = ins.read(buffer)) { 
    Msg msg = Msg.parseDelimitedFrom(new ByteArrayInputStream(buffer)); 
} 

Проблема в том, после того, как первое сообщение обрабатывается, он выдает ошибку синтаксического анализа себе cond со следующей погрешностью:

com.google.protobuf.InvalidProtocolBufferException: While parsing a protocol message, the input ended unexpectedly in the middle of a field. This could mean either than the input has been truncated or that an embedded message misreported its own length.

Если размер буфера и размер сообщения одинаковы? Если да, то как его разобрать, особенно для больших сообщений.

Answer 1

Проблема в том, что вам нужно читать непосредственно из исходного потока, а не по блоку за раз. (Даже если вы знаете, каждое сообщение ровно 4096 байт, вы не можете быть уверены, чтобы прочитать, что много сразу) я предлагаю вам использовать

while(stream still open) { 
    Msg msg = Msg.parseDelimitedFrom(ins); 
} 

Примечание: TCP является протоколом потоковой передачи, а не протокол обмена сообщениями. Вам гарантировано только чтение одного байта за раз, и любые дополнительные байты, которые вы получаете, являются бонусом.