protobuf-csharp-端口

Question

我正在使用 Jon Skeet（优秀）将 Google 的 Protocol Buffers 移植到 C#/.Net。

为了练习，我编写了一个虚拟即时通讯应用程序，它通过套接字发送一些消息。我的消息定义如下：-

message InstantMessage {<br/>
  required string Message = 1;<br/>
  required int64 TimeStampTicks = 2; <br/>
}

当发送者序列化消息时，它发送的非常优雅：-

        ...
        InstantMessage.Builder imBuild = new InstantMessage.Builder();

        imBuild.Message = txtEnterText.Text;
        imBuild.TimeStampTicks = DateTime.Now.Ticks;

        InstantMessage im = imBuild.BuildPartial();

        im.WriteTo(networkStream);
        ...

这非常有效。但在另一端，我无法让 ParseFrom 正常工作。

我想使用：-

InstantMessage im = InstantMessage.ParseFrom(networkStream);

但我必须将其读取为字节，然后从这里解析它。由于多种原因，这显然并不理想。当前代码是：-

while (true)
        {
            Byte[] byteArray = new Byte[10000000];

            int intMsgLength;
            int runningMsgLength = 0;

            DateTime start = DateTime.Now;

            while (true)
            {
                runningMsgLength += networkStream.Read(byteArray, runningMsgLength, 10000000 - runningMsgLength);

                if (!networkStream.DataAvailable)
                    break;

            }

            InstantMessage im = InstantMessage.ParseFrom(byteArray.Take(runningMsgLength).ToArray());

当我尝试使用 ParseFrom 时，即使我知道正在传输有效的 GB 消息，控制也不会返回到调用方法。

任何建议将不胜感激，

PW

Answer 1

抱歉花了一些时间来回答这个问题。正如 Marc 所说，协议缓冲区没有终止符，并且除非嵌套，否则它们没有长度前缀。但是，您可以自己添加长度前缀。如果您查看 MessageStreamIterator 和 MessageStreamWriter，您就会明白我是如何做到这一点的 - 基本上我假装我正在消息中间，将嵌套消息写入字段 1。不幸的是，当阅读消息，我必须使用内部详细信息（BuildImpl）。

现在有另一个 API 可以执行此操作：IMessage.WriteDelimitedTo 和 IBuilder.MergeDelimitedFrom。这可能是您目前想要的，但我似乎记得在检测流的结尾方面有一个小问题（即，当没有其他消息可供读取时）。我不记得目前是否有修复程序 - 我感觉它在 Java 版本中发生了变化，而且我可能还没有移植该更改。无论如何，这绝对是值得关注的领域。

Answer 2

Protobuf 没有终止符 - 因此要么关闭流，要么使用您自己的长度前缀等。Protobuf-net 通过 SerializeWithLenghtPrefix / DeserializeWithLengthPrefix 轻松公开这一点。

简单地说：如果没有这个，它就无法知道每条消息在哪里结束，因此不断尝试读取到流的末尾。