“同步刷新”对于 Zlib 放气

Question

我需要一个 zlib deflate 压缩流。在我的实现中，我必须在整个会话中使用单个流。在此会话期间，小块数据将通过压缩流传递。每次传递一个块时，都必须立即以压缩形式发送。

我的第一次尝试是使用 DeflateStream，但是当我发送第一个块时，它的压缩数据不会出现，直到我关闭流。

阅读zlib刷新模式，似乎有一种特定的模式我需要。

1. 我是否使用正确的类（DeflateStream）进行 zlib deflate 压缩？
2. 如何启用“同步刷新”行为？

Answer 1

DotNetZip 项目有一个子模块 Zlib，其中包含自己的 DeflateStream 实现。

此实现还有另一个名为 FlushMode 的属性：

DeflateStream deflate = new DeflateStream(stream, CompressionMode.Compress);
deflate.FlushMode = FlushType.Sync;
deflate.Write (data, 0, data.Length);
//No call to deflate.Flush() needed, automatically flushed on every write.

Answer 2

它确实只在关闭时刷新。您每次都需要使用不同的 DeflateStream 实例，将 true 传递给 重载的构造函数告诉它不在关闭 DeflateStream 时关闭底层流。

Answer 3

要回答有关如何启用“同步刷新”行为的问题，您应该查看 zlib 源代码中的 zpipe.c 示例。
将第一行替换为如下所示的第二行

Deflate() 将在每次输出缓冲区已满时返回
或者当输入缓冲区为空时同时附加到
压缩流 一个空的文字块，也称为
“同步刷新”，除了最后的 Z_FINISH 标志。

    flush = feof(source) ? Z_FINISH : Z_NO_FLUSH;
    flush = feof(source) ? Z_FINISH : Z_SYNC_FLUSH;
    ret = deflate(&strm, flush);