派生类型的 Protobuf-net StackOverflow 异常

Protobuf-net StackOverflow exception with Derived Types

我正在尝试使用 protobuf-net 通过单个通道发送混合消息类型。我从各种来源整理了以下示例,它在第一次反序列化时抛出了 Whosebug 异常。

我这样做的方式正确吗?

FWIW 它创建的文件的十六进制内容是 "A2 06 02 08 02 08 01 AA 06 02 08 04 08 03"

谢谢,格雷格

[ProtoContract(ImplicitFields = ImplicitFields.AllFields)]
[ProtoInclude(100, typeof(Derived1))]
[ProtoInclude(101, typeof(Derived2))]
public class Base { public int Old; }

[ProtoContract(ImplicitFields = ImplicitFields.AllFields)]
public class Derived1 : Base { public int New1; }
[ProtoContract(ImplicitFields = ImplicitFields.AllFields)]
public class Derived2 : Base { public int New2; }  

class Program
{
    static void Main(string[] args)
    {

        Base b1 = new Derived1() { Old = 1, New1 = 2 };
        Base b2 = new Derived2() { Old = 3, New2 = 4 };

        using (var fs = File.Create(@"C:\test.bin"))
        {
            Serializer.Serialize(fs, b1);
            Serializer.Serialize(fs, b2);
        }

        Base msg3, msg4;
        using (var fs = File.OpenRead(@"C:\test.bin"))
        {
            msg3 = Serializer.Deserialize<Base>(fs);  
            msg4 = Serializer.Deserialize<Base>(fs);
        }

        Console.WriteLine(((Derived1)msg3).New1);
        Console.WriteLine(((Derived2)msg4).New2);
        Console.ReadLine();
    }
}

我预计这里的问题是 framing; protobuf(格式,而不是库)由 google 设计为可附加的,其中 append===merge。如果您序列化消息 A,然后立即序列化消息 B,然后反序列化整个消息:您得到 一个 消息,而不是两个。这显然很可能导致意外结果、错误解释的数据和错误。

那么,诀窍就是将消息框起来,以便您可以单独处理它们。幸运的是,protobuf-net 正是为此目的提供了 SerializeWithLengthPrefixDeserializeWithLengthPrefix 方法。在序列化过程中,这会在每条消息前面加上一个标记,以指示后面数据的长度。在反序列化过程中,首先读取长度前缀,允许为每条消息消耗正确数量的数据。

支持长度前缀的多种布局和样式;最重要的是它们在序列化和反序列化步骤之间匹配。如果您希望数据是 "pure protobuf"(即在另一个平台上可解析为外部消息上的 repeated 字段),那么 "base-128, field 1" 是一个不错的选择。

这很好用:

using (var fs = File.Create(@"test.bin"))
{
    Serializer.SerializeWithLengthPrefix(fs, b1, PrefixStyle.Base128, 1);
    Serializer.SerializeWithLengthPrefix(fs, b2, PrefixStyle.Base128, 1);
}

Base msg3, msg4;
using (var fs = File.OpenRead(@"test.bin"))
{
    msg3 = Serializer.DeserializeWithLengthPrefix<Base>(fs, PrefixStyle.Base128, 1);
    msg4 = Serializer.DeserializeWithLengthPrefix<Base>(fs, PrefixStyle.Base128, 1);
}

我在反序列化时遇到了同样的问题,v2.1.0-alpha-1 版本修复了这个问题。

https://github.com/mgravell/protobuf-net/releases

此致,

Pluc