Protobuf C# a Java deserializzazione più messaggi

Question

Sto cercando di analizzare più messaggi di buffer protocollo in java che vengono generati in vb.net

Sto usando l'eccellente protobuf-net per lo streaming di messaggi multipli a Java come sotto:

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

In Java, io sto usando il codice seguente per analizzare i messaggi

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

problema è dopo il primo messaggio viene analizzato, si genera un errore per l'analisi di se cond time con il seguente errore:

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.

Le dimensioni del buffer e le dimensioni del messaggio devono essere uguali? Se sì, allora come dovrei analizzarlo, specialmente per i messaggi di grandi dimensioni.

Answer 1

Il problema è che è necessario leggere direttamente dal flusso originale, non un blocco alla volta. (Anche se sai ogni messaggio è esattamente 4096 byte, non si può essere sicuri di leggere più di tanto in una sola volta) vi suggerisco di utilizzare

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

Nota: TCP è un protocollo di streaming, non un messaggio di protocollo. Hai solo la garanzia di leggere un byte alla volta, e ogni byte extra che ottieni è un bonus.