在 C# 中发送/接收 GZip 压缩的 MSMQ 消息

Question

我正在尝试将大对象（> 30MB）发送到 MSMQ 队列。由于我们要发送的数据量很大，因此我们的想法是在发送对象之前对其进行 GZip，然后在接收端将其解压缩。

但是，将压缩流写入 message.BodyStream 属性似乎可以工作，但不能从那里读取它。 我不知道出了什么问题。

Message l_QueueMessage = new Message();
l_QueueMessage.Priority = priority;

using (MessageQueue l_Queue = CreateQueue())
{
    GZipStream stream = new GZipStream(l_QueueMessage.BodyStream, CompressionMode.Compress);

    Formatter.Serialize(stream, message);

    l_Queue.Send(l_QueueMessage);
}

Formatter 是 BinaryFormatter 类型的全局属性。这用于序列化/反序列化为我们想要发送/接收的对象类型，例如“ProductItem”。

接收端看起来像这样：

GZipStream stream = new GZipStream(l_Message.BodyStream, CompressionMode.Decompress);

object decompressedObject = Formatter.Deserialize(stream);

ProductItem l_Item = decompressedObject as ProductItem;

m_ProductReceived(sender, new MessageReceivedEventArgs<ProductItem>(l_Item));

l_ProductQueue.BeginReceive();

我尝试反序列化时收到 EndOfStreamException "{"Unable to read except the end of the stream."} 在 System.IO.BinaryReader.ReadByte()

使用 messageBodyStream 属性实际上绕过了 message.Formatter，我没有将其初始化为任何内容，因为我正在将自己的 ser/deser 机制与 GZipStream 一起使用。但是，我不确定这是否是正确的方法。

我缺少什么？ 谢谢！

Answer 1

在您的原始代码中，问题是您需要关闭GZipStream才能正确写入GZip页脚，然后才能发送它。如果不这样做，您最终会发送无法反序列化的字节。这也是为什么稍后发送的新代码可以工作的原因。

Answer 2

好的，我成功了。关键是将接收器上的解压流转换为 byte[] 数组。然后反序列化开始工作。

发送方代码（请注意，在发送消息之前流已关闭）：

using (MessageQueue l_Queue = CreateQueue())
{
    using (GZipStream stream = new GZipStream(l_QueueMessage.BodyStream, CompressionMode.Compress, true))
    {
        Formatter.Serialize(stream, message);
    }

    l_Queue.Send(l_QueueMessage);
}

接收端（请注意我如何将流转换为 byte[]，然后反序列化）：

using (GZipStream stream = new GZipStream(l_QueueMessage.BodyStream, CompressionMode.Decompress))
{
    byte[] bytes = ReadFully(stream);

    using (MemoryStream ms = new MemoryStream(bytes))
    {
        decompressedObject = Formatter.Deserialize(ms);
    }
}

不知道为什么使用 ReadFully() 函数而不是 Stream.CopyTo() 可以工作。
有人吗？

顺便说一句，ReadFully() 是一个从 Stream 中创建 byte[] 的函数。我必须将此归功于 Jon Skeet，网址为 http://www.yoda.arachsys.com/ csharp/readbinary.html。谢谢！

Answer 3

尝试将压缩和发送分开：

byte[] binaryBuffer = null;
using (MemoryStream compressedBody = new MemoryStream()) 
{
    using(GZipStream stream = new GZipStream(compressedBody, CompressionMode.Compress))
    {
        Formatter.Serialize(compressedBody, message); 
        binaryBuffer = compressedBody.GetBuffer();
    }
}

using (MessageQueue l_Queue = CreateQueue())        
{            
    l_QueueMessage.BodyStream.Write(binaryBuffer, 0, binaryBuffer.Length);
    l_QueueMessage.BodyStream.Seek(0, SeekOrigin.Begin);
    l_Queue.Send(l_QueueMessage);
}