c# - Protobuf-net 在与泛型一起用于反序列化时要求 TypeModel.CS

Question

我有数十亿个对象，我试图将它们构建在序列化到 HDD 的 B+ 树中。我正在使用 BPlusTree数据结构库和protobuf-net用于序列化/反序列化。在这方面，我将我的类定义为:

    [ProtoContract]
    public class B<C, M>
        where C : IComparable<C>
        where M : IData<C>
    {
        internal B()
        {
            lambda = new List<Lambda<C, M>>();
            omega = 0;
        }

        internal B(C coordinate)
        {
            lambda = new List<Lambda<C, M>>();
            e = coordinate;
            omega = 0;
        }

        [ProtoMember(1)]
        internal C e { set; get; }

        [ProtoMember(2)]
        internal List<Lambda<C, M>> lambda { private set; get; }

        [ProtoMember(3)]
        internal int omega { set; get; }
    }


[ProtoContract]
public class Lambda<C, M>
    where C : IComparable<C>
    where M : IData<C>
{
    internal Lambda() { }

    internal Lambda(char tau, M atI)
    {
        this.tau = tau;
        this.atI = atI;
    }

    [ProtoMember(1)]
    internal char tau { private set; get; }

    [ProtoMember(2)]
    internal M atI { private set; get; }
}

我定义我的序列化器/反序列化器如下:

public class BSerializer<C, M> : ISerializer<B<C, M>>
        where C : IComparable<C>
        where M : IData<C>
    {
        public B<C, M> ReadFrom(System.IO.Stream stream)
        {
            return Serializer.Deserialize<B<C, M>>(stream);
        }

        public void WriteTo(B<C, M> value, System.IO.Stream stream)
        {
            Serializer.Serialize<B<C, M>>(stream, value);
        }
    }

然后我在 B+Tree (This library) 数据结构中使用它们，定义为:

var options = new BPlusTree<C, B<C, M>>.OptionsV2(CSerializer, BSerializer);
var myTree = new BPlusTree<C, B<C, M>>(options);

B+Tree 被定义为键值对的字典。我的key (即 C )是一个整数，序列化器是 BPlusTree 的默认序列化器图书馆。我的Value是自定义对象 B<C,M>使用 protobuf-net 序列化.

我的问题肯定会发生，但几乎是随机发生的；一直在寻找 Keys , 它突然开始反序列化 Value第一次调用B<C, M> ReadFrom(System.IO.Stream stream)它要求 TypeModel.CS和 ProtoReader.CS文件。我从 NuGet 得到了两个包.

Answer 1

检查代码，看起来调用代码假定序列化知道它们自己的长度；来自来源:

foreach (T i in items)
    _serializer.WriteTo(i, io);

Protobuf 消息不会自行终止 - Google protobuf 规范定义了 append===merge。因此，您需要为消息添加前缀。幸运的是，您应该能够切换到 SerializeWithLengthPrefix 和 DeserializeWithLengthPrefix。如果这不起作用，则值得将一个完全可重现的示例放在一起，以便对其进行调查。