Protobuf C# để java deserializing nhiều thông điệp

Question

Tôi cố gắng để phân tích nhiều thông điệp giao thức đệm trong java được tạo ra trong vb.net

Tôi đang sử dụng tuyệt vời protobuf-net stream nhiều tin nhắn cho java theo dưới đây:

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

Trong Java, tôi đang sử dụng đoạn mã sau để phân tích các thông điệp

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

vấn đề là sau khi thông điệp đầu tiên được phân tách, nó throws lỗi cho phân tích cú pháp se thời gian có lỗi sau:

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.

Kích thước bộ đệm và kích cỡ thư có giống nhau không? Nếu có, thì làm thế nào tôi nên phân tích nó, đặc biệt là cho các tin nhắn lớn.

Answer 1

Vấn đề là bạn cần phải đọc trực tiếp từ luồng gốc, chứ không phải từng khối tại một thời điểm. (Ngay cả khi bạn biết mọi thư là chính xác 4096 byte, bạn không thể chắc chắn đọc nhiều thư đó cùng một lúc) Tôi khuyên bạn nên sử dụng

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

Lưu ý: TCP là giao thức thư. Bạn chỉ được đảm bảo đọc một byte tại một thời điểm và bất kỳ byte thừa nào bạn nhận được đều là tiền thưởng.