0

我正在尝试使用protobuf-net和 通过 tcp 连接发送序列化的压缩数据GzipStream

从 zipstream 中反序列化或读取只是阻塞并且没有完成。

为了测试它,我选择尝试使用更简单FileStream的方法来查看数据实际上正在被压缩和写入,事实就是如此。然而,该行Console.writeLine(inPerson1.name)抛出一个Object reference not set exception,因为它似乎没有从 zipstream 中读取任何数据。

关于为什么或我做错了什么的任何想法?

代码:

public void TestZipToFile(){
  var person1 = new Person { id = 1, name = "Pete" };
  var person2 = new Person { id = 2, name = "Sarah" };
  using (var file = File.Create("people.bin"))
  {
    GZipStream zs = new GZipStream(file, CompressionMode.Compress);
    Serializer.SerializeWithLengthPrefix<Person>(zs, person1, PrefixStyle.Fixed32);//.Serialize(file, foo);
    Serializer.SerializeWithLengthPrefix<Person>(zs, person2, PrefixStyle.Fixed32);//.Serialize(file, foo);
  }
  Person inPerson1 = null;
  Person inPerson2 = null;
  using (var file = File.OpenRead("people.bin"))
  {
    GZipStream ozs = new GZipStream(file, CompressionMode.Decompress);
    inPerson1 = Serializer.DeserializeWithLengthPrefix<Person>(ozs,PrefixStyle.Fixed32);//.Deserialize<Foo>(file);
    inPerson2 = Serializer.DeserializeWithLengthPrefix<Person>(ozs, PrefixStyle.Fixed32);//.Deserialize<Foo>(file);
  }
  Console.WriteLine(inPerson1.name);
  Console.WriteLine(inPerson2.name);
}

[ProtoContract]
public class Person
{
  [ProtoMember(1)
  public int id;
  [ProtoMember(2)]
  public string name;
}
4

1 回答 1

2

你永远不会关闭输出GZipStream,所以我怀疑它最终永远不会向底层流写入任何内容。您应该using为每个GZipStream以及FileStream.

于 2012-07-01T18:55:14.700 回答