我正在尝试使用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;
}