C#中ZlibStream的WriteAsync方法偶现无限挂起问题求助

我写了两段C#异步代码，用于解压从MySQL数据库读取的Blob数据（应用的主要瓶颈是网络速度，所以选择在客户端解压）。但遇到一个奇怪的问题：针对某段特定输入数据，Write操作会无限挂起直到程序终止。这段数据本身是正常的——用Python或C++的zlib库可以正常解压；而且测试无效数据时，代码会抛出异常而非挂起。排除了数据长度的问题，更长的数组都能正常处理，且问题可复现，推测和特定字节数组有关，但暂时没找到差异。更换实现方式后问题依旧。

第一段代码 #

private static async Task<byte[]> DecompressBlob(byte[] y)
{
    using (var output = new MemoryStream())
    {
        using (var decompressor = new ZlibStream(output, CompressionMode.Decompress))
        {                
            await decompressor.WriteAsync(y, 4, y.Length - 4);
        }

        return output.ToArray();
    }
}

第二段代码 #

private static async Task CopyStream(Stream src, Stream dest)
{
    byte[] buffer = new byte[1024];
    int len;
    while ((len = await src.ReadAsync(buffer, 0, buffer.Length)) > 0)
    {
        await dest.WriteAsync(buffer, 0, len);
    }
    await dest.FlushAsync();
}

private static async Task<byte[]> DecompressBlob(byte[] y)
{                                            
    // Convert to a stream
    var byteStreamCompressed = new System.IO.MemoryStream(y);

    byteStreamCompressed.Seek(4, System.IO.SeekOrigin.Begin);
    var byteStreamDecompressed = new System.IO.MemoryStream();
    var zOut = new ZlibStream(byteStreamDecompressed, CompressionMode.Decompress, true);
    await CopyStream(byteStreamCompressed, zOut);

    return byteStreamDecompressed.ToArray();
}

1. ZlibStream未触发解压结束逻辑 #

zlib解压需要明确的结束信号来完成解码流程。异步场景下，如果没有正确关闭ZlibStream，它会一直等待后续输入数据，导致挂起。

解决办法：

• 第二段代码中，将ZlibStream放入using块中，利用其自动Dispose触发结束处理；或者手动调用Close()/Dispose()：

private static async Task<byte[]> DecompressBlob(byte[] y)
{                                            
    using var byteStreamCompressed = new MemoryStream(y);
    byteStreamCompressed.Seek(4, SeekOrigin.Begin);
    using var byteStreamDecompressed = new MemoryStream();
    using var zOut = new ZlibStream(byteStreamDecompressed, CompressionMode.Decompress, true);
    await CopyStream(byteStreamCompressed, zOut);
    // 确保解压流程完成
    zOut.Close();
    return byteStreamDecompressed.ToArray();
}

• 第一段代码中，在写入后手动调用Flush()，再让using块自动Dispose：

private static async Task<byte[]> DecompressBlob(byte[] y)
{
    using (var output = new MemoryStream())
    {
        using (var decompressor = new ZlibStream(output, CompressionMode.Decompress))
        {                
            await decompressor.WriteAsync(y, 4, y.Length - 4);
            decompressor.Flush();
        }
        return output.ToArray();
    }
}

2. 前4字节的跳过逻辑错误 #

确认MySQL中存储的Blob数据前4字节是否确实是自定义头，而非zlib压缩数据的一部分。zlib数据通常以2字节的头标识（比如0x78 0x9C、0x78 DA等），如果跳过4字节后破坏了zlib的完整头，可能导致解压流无法识别结束标记，进而无限等待。

解决办法：
用十六进制编辑器查看有问题的字节数组，跳过4字节后检查前两个字节是否符合zlib的有效头格式。如果不符合，说明跳过的字节数有误，调整Seek的偏移量。

3. 异步流的缓冲区处理问题 #

异步写入时，缓冲区的数据可能没有被完全提交到解压流，导致解压逻辑无法处理完所有数据。可以尝试增大缓冲区大小，或者在拷贝完成后强制刷新流。

解决办法：
修改CopyStream方法的缓冲区大小（比如改为4096或8192），并确保在拷贝完成后刷新解压流：

private static async Task CopyStream(Stream src, Stream dest)
{
    byte[] buffer = new byte[8192]; // 增大缓冲区
    int len;
    while ((len = await src.ReadAsync(buffer, 0, buffer.Length)) > 0)
    {
        await dest.WriteAsync(buffer, 0, len);
        await dest.FlushAsync(); // 每次写入后刷新
    }
}

4. 替换更可靠的zlib实现 #

如果系统自带的ZlibStream存在异步场景的兼容性问题，可以尝试使用第三方库的异步解压API，这类库通常对各种边缘场景处理更完善。

内容的提问来源于stack exchange，提问作者Harry Adams