c# - protobuf-csharp-端口

Question

我正在使用 Jon Skeet 的(优秀的)谷歌 Protocol Buffers 端口到 C#/.Net。

为了练习，我编写了一个虚拟的 Instant Messenger 应用程序，它可以通过套接字发送一些消息。我有一个消息定义如下:-

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 消息，控制也不会返回到调用方法。

如有任何建议，我们将不胜感激，

私服

Answer 1

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

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