本文详解 go 中对 *bytes.reader 数据进行 gzip 压缩（zip）和解压缩（unzip）的完整流程，重点解决因未显式关闭 gzip.writer 导致的 unexpected eof 错误，并提供可直接复用的健壮实现。
本文详解 go 中对 *bytes.reader 数据进行 gzip 压缩（zip）和解压缩（unzip）的完整流程，重点解决因未显式关闭 gzip.writer 导致的 unexpected eof 错误，并提供可直接复用的健壮实现。
在 Go 中使用 gzip 对内存中的字节数据进行压缩/解压缩时，一个常见却容易被忽视的关键点是：gzip.Writer 必须显式调用 Close() 方法，才能确保所有压缩数据（包括尾部校验和及长度信息）被完整写入底层缓冲区。若仅依赖 defer writer.Close() 或完全遗漏该调用，buff.Bytes() 将返回不完整的压缩流——缺少 gzip 尾部（footer），导致后续 gzip.NewReader 解析时触发 unexpected EOF。
以下是修正后的完整实现示例（含 Zip 与 UnZip 方法）：
package main
import (
"bytes"
"compress/gzip"
"fmt"
"io"
)
type File struct {
Name string
Body *bytes.Reader
}
func (f *File) Zip() error {
var buff bytes.Buffer // 使用 bytes.Buffer 替代 NewBuffer(nil)，更清晰
gw := gzip.NewWriter(&buff)
// 注意：此处不能用 defer gw.Close() —— 它会在函数返回前关闭，但我们需要在 Close 后立即读取数据
if _, err := io.Copy(gw, f.Body); err != nil {
return err
}
if err := gw.Close(); err != nil { // ✅ 关键：显式关闭以刷新并写入 footer
return err
}
f.Body = bytes.NewReader(buff.Bytes())
f.Name += ".gz"
return nil
}
func (f *File) UnZip() error {
gr, err := gzip.NewReader(f.Body)
if err != nil {
return fmt.Errorf("failed to create gzip reader: %w", err)
}
defer gr.Close() // 解压后关闭 reader，释放资源
var buff bytes.Buffer
if _, err := io.Copy(&buff, gr); err != nil {
return err
}
f.Body = bytes.NewReader(buff.Bytes())
f.Name = f.Name[:len(f.Name)-3] // 移除 ".gz" 后缀（简单处理，生产环境建议更严谨的截断逻辑）
return nil
}
关键注意事项：
- ✅ gzip.Writer.Close() 不可省略：它会 flush 剩余压缩数据并写入 8 字节的 gzip 尾部（包含 CRC32 和 uncompressed size），缺失则解压失败；
- ❌ 避免 defer gw.Close() 在 Zip() 中：defer 会在函数末尾执行，但 buff.Bytes() 需在 Close() 之后 调用，否则获取的是未完成的数据；
- ✅ 使用 io.Copy 替代 WriteTo：更符合流式处理习惯，且兼容任意 io.Reader；
- ⚠️ UnZip() 中务必 defer gr.Close()：防止 goroutine 泄漏（gzip.Reader 内部可能启动 goroutine 用于并发解压）；
- ? 可逆性验证：连续调用 Zip() → UnZip() → Zip() 应保持数据一致性（原始内容不变）。
通过严格遵循“压缩后显式关闭、解压后及时清理”的原则，即可稳定实现内存中 *bytes.Reader 的无损 gzip 循环压缩/解压缩。
