c# - GZip/Deflate 压缩适用于 .NetCore 2.0 但不适用于 .Net 4.6.2

Question

我已经编写了一些代码来使用 Gzip 或 Deflate(都在 System.IO.Compression 中)压缩和解压缩数据，并且我已经在 .NetCore 项目中对其进行了测试，它工作正常并且所有测试用例都通过了。因此，我在 .Net 4.6.2 项目中回收了相同的代码，尽管 msdn 文档说它是兼容的，但我仍然无法使其正常工作。这是我遇到问题的代码部分

public virtual byte[] Encode<TObject>(TObject objectToEncode) where TObject : class, new()
    {

        if (objectToEncode == null) throw new ArgumentNullException(nameof(objectToEncode));

        byte[] jsonResult = null;
        using (var ms = new MemoryStream())
        {

            //Generazione del Json
            using (var textWriter = new StreamWriter(ms, System.Text.Encoding.UTF8))
            {
                using (var jsonWriter = new JsonTextWriter(textWriter))
                {
                    JsonSerializer serializer = new JsonSerializer();
                    serializer.Serialize(jsonWriter, objectToEncode, objectToEncode.GetType());
                    jsonWriter.Flush();
                    textWriter.Flush();
                    ms.Flush();
                    //Compressione Json   
                    jsonResult = ms.ToArray();
                }
            }
        }
        using (var msResult = new MemoryStream())
        {
            using (var encodingStream = GenerateEncodingStream(msResult))
            {
                encodingStream.Write(jsonResult, 0, Convert.ToInt32(jsonResult.Length));
                encodingStream.Flush();
                msResult.Position = 0;
                return msResult.ToArray();
            }
        }
    }

GenerateEncondingStream 只需调用 DeflateStream 或 Gzipstream 的构造函数，具体取决于您选择的那些。

问题:如果我使用 Deflate，msResult.Lenght 是 0 个单元格，而如果我使用 GZip Length msResult.Length 是相同数据集的 10 个单元格(在 .NetCore 项目中都是 211 个)。

大量使用 Flush() 是为了确保每个流都在应有的位置完全刷新。.Net 4.6.2 有问题还是我的代码有误？感谢您的帮助!

编辑:同样的问题，但有解压缩和反序列化:如果我解压缩然后在关闭所有流后反序列化，我的性能比下面列出的使用封装流的版本高 10%。下面的代码在解压缩时反序列化失败。我没主意了，因为10%效率的版本是 Not Acceptable ...

public virtual async Task<object> DecodeAsync(byte[] encodedObject, Type decodedObjectType, CancellationToken cancellationToken)
    {           
        cancellationToken.ThrowIfCancellationRequested();

        if (encodedObject == null) throw new ArgumentNullException(nameof(encodedObject));

        if (encodedObject.Length == 0) throw new ArgumentException(nameof(encodedObject));

        using (var compressedStream = new MemoryStream(encodedObject))
        {
            using (var csStream = GenerateDecodingStream(compressedStream))
            {
                using (var decompressedStream = new MemoryStream())
                {
                    using (StreamReader sr = new StreamReader(decompressedStream, System.Text.Encoding.UTF8))
                    {
                        using (var reader = new JsonTextReader(sr))
                        {
                            JsonSerializer serializer = new JsonSerializer();
                            return serializer.Deserialize(reader, decodedObjectType);

                        }
                    }
                }
            }
        }
    }

Answer 1

在reference source of DeflateStream , Flush() 什么都不做。

在反射器中查看，常规 .NET Framework Flush() 也是如此。所以基本上，Flush() 不想刷新 - 大概是为了最大限度地提高压缩效率。相反，刷新仅在数据大小足够大或处置时发生。

相比之下，在 .NET Core 源代码中，Flush() actually flushes .

因此:将您的 .ToArray() 调用移动到 after 您关闭了包装 MemoryStream 的一切>.

所以:

using (var ms = new MemoryStream())
{

    //Generazione del Json
    using (var textWriter = new StreamWriter(ms, System.Text.Encoding.UTF8))
    {
        using (var jsonWriter = new JsonTextWriter(textWriter))
        {
            JsonSerializer serializer = new JsonSerializer();
            serializer.Serialize(jsonWriter, objectToEncode, objectToEncode.GetType());                    
        }
    }
    jsonResult = ms.ToArray();
}
using (var msResult = new MemoryStream())
{
    using (var encodingStream = GenerateEncodingStream(msResult))
    {
        encodingStream.Write(jsonResult, 0, Convert.ToInt32(jsonResult.Length));                
    }
    return msResult.ToArray();
}