protobufでList <class object>をシリアライズ/デシリアライズする方法は？

Question

List<ArchiveData>をシリアライズしたいですが、ほとんどいつも失敗します。 Protobuff throw例外：

ワイヤタイプが無効です。これは通常、長さを切り捨てたり設定したりせずにファイル を上書きしたことを意味します。 Using Protobuf-net, I suddenly got an exception about an unknown wire-type

私は投稿を読みましたが、解決策を見つけることができません。どのように私はシリアル化し、これを逆シリアル化することができますか？

私のクラスと構造体：

[Serializable, ProtoContract(Name = @"Archive"), ProtoInclude(1, typeof(List<ArchiveData>))] 
public partial class Archive : IExtensible 
{ 
    [ProtoMember(1, IsRequired = true, OverwriteList = true, Name = @"data", DataFormat = DataFormat.Default)] 
    public List<ArchiveData> data { get; set; } 

    public Archive() 
    { 
     data = new List<ArchiveForm.ArchiveData>(); 
    } 

    private IExtension extensionObject; 
    IExtension IExtensible.GetExtensionObject(bool createIfMissing) 
    { 
     return Extensible.GetExtensionObject(ref extensionObject, createIfMissing); 
    } 
} 

public struct ArchiveData 
{ 
    [ProtoMember(1, IsRequired = false, OverwriteList = true, Name = @"sourcefolder", DataFormat = DataFormat.Default)] 
    [global::System.ComponentModel.DefaultValue("")] 
    public string sourcefolder { get; set; } 

    [ProtoMember(2, IsRequired = false, OverwriteList = true, Name = @"destinationfolder", DataFormat = DataFormat.Default)] 
    [global::System.ComponentModel.DefaultValue("")] 
    public string destinationfolder { get; set; } 

    [ProtoMember(3, IsRequired = false, OverwriteList = true, Name = @"period", DataFormat = DataFormat.FixedSize)] 
    [global::System.ComponentModel.DefaultValue((int)0)] 
    public int period { get; set; } 

    public ArchiveData(string sfolder = "", string dfolder = "", int priod = 0) 
    { 
     sourcefolder = sfolder; 
     destinationfolder = dfolder; 
     period = priod; 
    } 
} 

私は次の方法であることをシリアライズ：

public static void Refresh(ref Archive arc) 
{ 
    if (File.Exists(probuffile)) 
    { 
     using (var fs = File.OpenRead(probuffile)) 
     { 
      arc = Serializer.Deserialize<Archive>(fs); 
     } 
    } 
} 

、私は次のような方法であることデシリアライズ：

public static void Update(Archive arc) 
{ 
    using (var fs = File.Create(probuffile)) 
    { 
     Serializer.Serialize<Archive>(fs, arc); 
     fs.SetLength(fs.Position); 
    } 
} 

、私はそれを使用します。

Archive archive = new Archive(); 
//Add some ArchiveData. 
Refresh(ref archive); 

------------------------------編集--------------- ---------------

このセクションは、追加情報として追加されました。次のコードのようなSerializeWithLengthPrefix/DeserializeWithLengthPrefix関数を使用すると、Deserialize関数を使用するファーストクラスのたびに正しく動作します。しかし、それは私がDeserialize関数を使用する2番目のクラスのnullを返します。

[Serializable, ProtoContract(Name = @"OptionData")] 
public class OptionData : IExtensible 
{ 
    [ProtoMember(1, IsRequired = false, OverwriteList = true, Name = @"StartWithWindows", DataFormat = DataFormat.Default)] 
    [DefaultValue(false)] 
    public bool StartWithWindows { get; set; } 

    [ProtoMember(2, IsRequired = false, OverwriteList = true, Name = @"AutoBackup", DataFormat = DataFormat.Default)] 
    [DefaultValue(false)] 
    public bool AutoBackup { get; set; } 

    [ProtoMember(3, IsRequired = false, OverwriteList = true, Name = @"Speed", DataFormat = DataFormat.FixedSize)] 
    [DefaultValue((int)0)] 
    public int Speed { get; set; } 

    private IExtension extensionObject; 
    IExtension IExtensible.GetExtensionObject(bool createIfMissing) 
    { 
     return Extensible.GetExtensionObject(ref extensionObject, createIfMissing); 
    } 
} 

public static void Update(OptionData op) 
{ 
    using (var fs = File.Create(probuffile)) 
    { 
     Serializer.SerializeWithLengthPrefix(fs, op, PrefixStyle.Base128, 3); 
    } 
} 

public static void Update(Archive arc) 
{ 
    using (var fs = File.Create(probuffile)) 
    { 
     Serializer.SerializeWithLengthPrefix<Archive>(fs, arc, PrefixStyle.Base128, 2); 
    } 
} 

public static void Refresh(ref OptionData op) 
{ 
    if (File.Exists(probuffile)) 
    { 
     using (var fs = File.OpenRead(probuffile)) 
     { 
      op = Serializer.DeserializeWithLengthPrefix<OptionData>(fs, PrefixStyle.Base128, 3); 
     } 
    } 
} 

public static void Refresh(ref Archive arc) 
{ 
    if (File.Exists(probuffile)) 
    { 
     using (var fs = File.OpenRead(probuffile)) 
     { 
      arc = Serializer.DeserializeWithLengthPrefix<Archive>(fs, PrefixStyle.Base128, 2); 
     } 
    } 
} 

Answer 1

私は喜んで助けてくれるが、失敗するのは苦労している。あなたは言う、「それはほとんど常に失敗」が、次の実行可能なコンソールEXERは正常に動作し、様々なサイズのデータ​​の大規模な範囲を書き込みます

using ProtoBuf; 
using System; 
using System.Collections.Generic; 
using System.IO; 
static class P 
{ 
    static void Main() 
    { 
     var random = new Random(12345); 
     // start with 100 
     var archive = CreateData(random, 100); 
     Update(archive); 
     Refresh(ref archive); 

     // make it bigger 
     archive = CreateData(random, 200); 
     Update(archive); 
     Refresh(ref archive); 

     // make it smaller 
     archive = CreateData(random, 50); 
     Update(archive); 
     Refresh(ref archive); 

     // go wild 
     for (int i = 0; i < 1000; i++) 
     { 
      archive = CreateData(random, random.Next(0, 500)); 
      Update(archive); 
      Refresh(ref archive); 
     } 

    } 
    static Archive CreateData(Random random, int dataCount) 
    { 
     var archive = new Archive(); 
     var data = archive.data; 
     for (int i = 0; i < dataCount; i++) 
     { 
      data.Add(new ArchiveData 
      { 
       period = random.Next(10000), 
       sourcefolder = CreateString(random, 50), 
       destinationfolder = CreateString(random, 50) 
      }); 
     } 
     return archive; 
    } 

    private static unsafe string CreateString(Random random, int maxLength) 
    { 
     const string Alphabet = "abcdefghijklmnopqrstuvwxyz"; 
     int len = random.Next(maxLength + 1); 
     char* chars = stackalloc char[len]; 
     for (int i = 0; i < len; i++) 
     { 
      chars[i] = Alphabet[random.Next(Alphabet.Length)]; 
     } 
     return new string(chars, 0, len); 
    } 

    static string probuffile = "my.bin"; 
    public static void Refresh(ref Archive arc) 
    { 
     if (File.Exists(probuffile)) 
     { 
      using (var fs = File.OpenRead(probuffile)) 
      { 
       arc = Serializer.Deserialize<Archive>(fs); 
       Console.WriteLine("Read: {0} items, {1} bytes", arc.data.Count, fs.Length); 
      } 
     } 
    } 

    public static void Update(Archive arc) 
    { 
     using (var fs = File.Create(probuffile)) 
     { 
      Serializer.Serialize<Archive>(fs, arc); 
      fs.SetLength(fs.Position); 
      Console.WriteLine("Wrote: {0} items, {1} bytes", arc.data.Count, fs.Length); 
     } 
    } 
} 

[Serializable, ProtoContract(Name = @"Archive"), ProtoInclude(1, typeof(List<ArchiveData>))] 
public partial class Archive : IExtensible 
{ 
    [ProtoMember(1, IsRequired = true, OverwriteList = true, Name = @"data", DataFormat = DataFormat.Default)] 
    public List<ArchiveData> data { get; set; } 

    public Archive() 
    { 
     data = new List<ArchiveData>(); 
    } 

    private IExtension extensionObject; 
    IExtension IExtensible.GetExtensionObject(bool createIfMissing) 
    { 
     return Extensible.GetExtensionObject(ref extensionObject, createIfMissing); 
    } 
} 
[ProtoContract] 
public struct ArchiveData 
{ 
    [ProtoMember(1, IsRequired = false, OverwriteList = true, Name = @"sourcefolder", DataFormat = DataFormat.Default)] 
    [global::System.ComponentModel.DefaultValue("")] 
    public string sourcefolder { get; set; } 

    [ProtoMember(2, IsRequired = false, OverwriteList = true, Name = @"destinationfolder", DataFormat = DataFormat.Default)] 
    [global::System.ComponentModel.DefaultValue("")] 
    public string destinationfolder { get; set; } 

    [ProtoMember(3, IsRequired = false, OverwriteList = true, Name = @"period", DataFormat = DataFormat.FixedSize)] 
    [global::System.ComponentModel.DefaultValue((int)0)] 
    public int period { get; set; } 

    public ArchiveData(string sfolder = "", string dfolder = "", int priod = 0) 
    { 
     sourcefolder = sfolder; 
     destinationfolder = dfolder; 
     period = priod; 
    } 
} 

私はどんな違いがあなたの実際のコードの間であることを推測していると上記の例も問題の原因です。違うものを見つけるのを手伝ってくれたら、私は合理的にできるのですが、助けてくれると嬉しいです。

小さなメモ：Createを使用する場合、実際には既存のデータを捨てるため、実際に長さを設定する必要はありません。あなたが長さを心配する必要がある主な時間は、人々が既存のファイルを上書きするのにOpenWriteを使用して、のデータがすでにそこにあるよりも少なくてと書いているときです。しかし、明示的に、私は疑問に任意の `一覧