Protobuf C# java Deserialisieren mehr Nachrichten

Question

ich mehr Protokollpuffer Nachrichten in Java zu analysieren versuchen, die in vb.net erzeugt werden

ich das hervorragende protobuf-net nach unten mehr Nachrichten auf Java streamen bin mit:

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

In Java, ich folgenden Code verwenden die Nachrichten

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

Problem ist nach dem ersten Nachricht wird analysiert, zu analysieren, wirft es Fehler für das Parsen se Zeit mit folgendem Fehler:

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.

Sollte die Puffergröße und die Nachrichtengröße gleich sein? Wenn ja, wie soll ich es analysieren, besonders für große Nachrichten.

Answer 1

Das Problem ist, dass Sie direkt aus dem ursprünglichen Stream lesen müssen, nicht einen Block zu einer Zeit. (Auch wenn Sie wissen, jede Nachricht genau 4096 Bytes, man kann nicht sicher sein, dass viel auf einmal lesen) Ich schlage vor, Sie

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

verwenden Hinweis: TCP ist ein Streaming-Protokoll, kein Nachrichtenprotokoll. Sie können nur ein Byte nach dem anderen lesen, und jedes zusätzliche Byte, das Sie erhalten, ist ein Bonus.