如何将 protobuf 序列化内容直接写入 SharpZipLib 流
本文关键字:SharpZipLib protobuf 序列化 | 更新日期: 2023-09-27 18:36:56
是否可以将protobuf序列化的内容直接写入SharpZipLib流?当我尝试这样做时,看起来提供的流没有填充来自 protobuf 的数据。稍后我需要从提供的 Zip 流中取回反序列化的实体。我的代码如下所示:
private byte[] ZipContent(T2 content)
{
const short COMPRESSION_LEVEL = 4; // 0-9
const string ENTRY_NAME = "DefaultEntryName";
byte[] result = null;
if (content == null)
return result;
IStreamSerializerProto<T2> serializer = this.GetSerializer(content.GetType());
using (MemoryStream outputStream = new MemoryStream())
{
using (ZipOutputStream zipOutputStream = new ZipOutputStream(outputStream))
{
zipOutputStream.SetLevel(COMPRESSION_LEVEL);
ZipEntry entry = new ZipEntry(ENTRY_NAME);
entry.DateTime = DateTime.Now;
zipOutputStream.PutNextEntry(entry);
serializer.Serialize(zipOutputStream, content);
}
result = outputStream.ToArray();
}
return result;
}
private class ProtobufStreamSerializer<T3> : IStreamSerializerProto<T3>
{
public ProtobufStreamSerializer()
{
ProtoBuf.Serializer.PrepareSerializer<T3>();
}
public void Serialize(Stream outputStream, T3 content)
{
Serializer.Serialize(outputStream, content);
}
public T3 Deserialize(Stream inputStream)
{
T3 deserializedObj;
using (inputStream)
{
deserializedObj = ProtoBuf.Serializer.Deserialize<T3>(inputStream);
}
return deserializedObj;
}
}
我正在尝试序列化的类的示例:
[Serializable]
[ProtoContract]
public class Model
{
[XmlElement("ModelCode")]
[ProtoMember(1)]
public int ModelCode { get; set; }
...
}
我相信这就是问题所在(在问题的原始代码中):
public void Serialize(Stream outputStream, T3 content)
{
using (var stream = new MemoryStream())
{
Serializer.Serialize(stream, content);
}
}
您完全忽略了outputStream
,而是将数据写入一个新的MemoryStream
然后被忽略。
我怀疑你只是想要:
public void Serialize(Stream outputStream, T3 content)
{
Serializer.Serialize(outputStream, content);
}
我还建议从您的Deserialize
方法中删除 using
语句:我希望调用方在完成输入流后负责处理输入流。您的方法可以简化为:
public T3 Deserialize(Stream inputStream)
{
return ProtoBuf.Serializer.Deserialize<T3>(inputStream);
}
代码(Jon 指出的编辑)看起来不错。在这里它正在工作:
static void Main()
{
var obj = new Bar{ X = 123, Y = "abc" };
var wrapper = new Foo<Bar>();
var blob = wrapper.ZipContent(obj);
var clone = wrapper.UnzipContent(blob);
}
其中Bar
:
[ProtoContract]
class Bar
{
[ProtoMember(1)]
public int X { get; set; }
[ProtoMember(2)]
public string Y { get; set; }
}
Foo<T>
是你的类(我不知道名字),我在那里添加了:
public T2 UnzipContent(byte[] data)
{
using(var ms = new MemoryStream(data))
using(var zip = new ZipInputStream(ms))
{
var entry = zip.GetNextEntry();
var serializer = this.GetSerializer(typeof(T2));
return serializer.Deserialize(zip);
}
}
另外,请注意压缩是双刃剑。在我上面给出的例子中,底层大小(即如果我们只写入MemoryStream
)是 7 个字节。 ZipInputStream
将这 7 个字节"压缩"为 179 个字节。压缩在较大的对象上效果最佳,通常是在有大量文本内容时。