Go语言 compress/gzip 包：高效实现数据压缩与解压缩教程

package main

import (
    "bytes"
    "compress/gzip"
    "fmt"
    "log"
)

func main() {
    // 待压缩的原始数据
    originalData := []byte("hello, world\nThis is a test string for gzip compression.")

    // 创建一个bytes.Buffer用于存储压缩后的数据
    var compressedBuffer bytes.Buffer

    // 创建一个gzip.Writer，将压缩数据写入到compressedBuffer
    gzipWriter := gzip.NewWriter(&compressedBuffer)

    // 将原始数据写入gzipWriter进行压缩
    _, err := gzipWriter.Write(originalData)
    if err != nil {
        log.Fatalf("写入数据失败: %v", err)
    }

    // 必须关闭gzipWriter，以确保所有缓冲数据都被写入到底层写入器
    // 并且Gzip文件的末尾标记被正确写入
    err = gzipWriter.Close()
    if err != nil {
        log.Fatalf("关闭gzip写入器失败: %v", err)
    }

    fmt.Printf("原始数据大小: %d 字节\n", len(originalData))
    fmt.Printf("压缩后数据大小: %d 字节\n", compressedBuffer.Len())
    fmt.Printf("压缩后数据 (Hex): %x\n", compressedBuffer.Bytes())
}

package main

import (
    "bytes"
    "compress/gzip"
    "fmt"
    "io"
    "log"
)

func main() {
    // 假设这是从某个地方获取到的压缩数据 (这里为了演示，直接使用上一节的压缩结果)
    // 实际应用中，这可能是从网络或文件读取的字节切片
    compressedDataHex := "1f8b08000000000000ffcb48cdc9c9d751c82f4b2d52c8492c4107000000ffff070014f3640228000000" // 这是一个简化示例，实际应使用完整的压缩字节
    // 为了演示方便，我们直接构建一个包含压缩数据的bytes.Buffer
    var compressedBuffer bytes.Buffer
    // 实际使用中，compressedBuffer会由压缩操作填充
    // 这里为了独立演示解压，我们手动填充一个简单的Gzip压缩数据
    // "hello, world" 压缩后的一个简化版本，实际压缩结果会更长
    compressedBuffer.Write([]byte{
        0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0xff, 0xcb, 0x48, 0xcd, 0xc9, 0xc9, 0xd7,
        0x51, 0xc8, 0x2f, 0x4b, 0x2d, 0x52, 0xc8, 0x49, 0x2c, 0x41, 0x07, 0x00, 0x00, 0x00, 0xff, 0xff,
        0x07, 0x00, 0x14, 0xf3, 0x64, 0x02, 0x28, 0x00, 0x00, 0x00, // 这是一个模拟的Gzip压缩数据
    })

    // 创建一个gzip.Reader，从compressedBuffer读取压缩数据
    gzipReader, err := gzip.NewReader(&compressedBuffer)
    if err != nil {
        log.Fatalf("创建gzip读取器失败: %v", err)
    }
    defer func() {
        if closeErr := gzipReader.Close(); closeErr != nil {
            log.Printf("关闭gzip读取器失败: %v", closeErr)
        }
    }()

    // 将解压后的数据读取到一个bytes.Buffer中
    var decompressedBuffer bytes.Buffer
    _, err = io.Copy(&decompressedBuffer, gzipReader)
    if err != nil {
        log.Fatalf("读取解压数据失败: %v", err)
    }

    fmt.Printf("解压后数据: %s\n", decompressedBuffer.String())
}

package main

import (
    "compress/gzip"
    "fmt"
    "log"
    "os"
)

func main() {
    outputFileName := "output.txt.gz"
    originalContent := "This is some content that will be compressed and written to a gzip file.\n" +
        "It can be multiple lines of text, or any binary data."

    // 1. 创建或打开一个文件用于写入压缩数据
    file, err := os.Create(outputFileName)
    if err != nil {
        log.Fatalf("创建文件 %s 失败: %v", outputFileName, err)
    }
    defer func() {
        if closeErr := file.Close(); closeErr != nil {
            log.Printf("关闭文件 %s 失败: %v", outputFileName, closeErr)
        }
    }()

    // 2. 创建一个gzip.Writer，将数据写入到文件中
    // 默认压缩级别为DefaultCompression
    gzipWriter := gzip.NewWriter(file)
    defer func() {
        // 必须关闭gzipWriter，以确保所有缓冲数据都被写入文件
        // 并且Gzip文件的末尾标记被正确写入
        if closeErr := gzipWriter.Close(); closeErr != nil {
            log.Printf("关闭gzip写入器失败: %v", closeErr)
        }
    }()

    // 3. 将原始内容写入gzipWriter进行压缩
    _, err = gzipWriter.Write([]byte(originalContent))
    if err != nil {
        log.Fatalf("写入数据到gzip文件失败: %v", err)
    }

    fmt.Printf("数据已成功压缩并写入到文件: %s\n", outputFileName)
}

package main

import (
    "compress/gzip"
    "fmt"
    "io"
    "log"
    "os"
)

func main() {
    inputFileName := "output.txt.gz" // 假设此文件已由上一步骤创建

    // 1. 打开Gzip压缩文件
    file, err := os.Open(inputFileName)
    if err != nil {
        log.Fatalf("打开文件 %s 失败: %v", inputFileName, err)
    }
    defer func() {
        if closeErr := file.Close(); closeErr != nil {
            log.Printf("关闭文件 %s 失败: %v", inputFileName, closeErr)
        }
    }()

    // 2. 创建一个gzip.Reader，从文件中读取压缩数据
    gzipReader, err := gzip.NewReader(file)
    if err != nil {
        log.Fatalf("创建gzip读取器失败: %v", err)
    }
    defer func() {
        // 必须关闭gzipReader，以释放资源并验证Gzip流的完整性
        if closeErr := gzipReader.Close(); closeErr != nil {
            log.Printf("关闭gzip读取器失败: %v", closeErr)
        }
    }()

    // 3. 将解压后的数据复制到标准输出或另一个文件
    fmt.Printf("正在从 %s 解压数据:\n", inputFileName)
    _, err = io.Copy(os.Stdout, gzipReader)
    if err != nil {
        log.Fatalf("读取解压数据失败: %v", err)
    }
    fmt.Println("\n数据解压完成。")
}