package main
import (
    "bytes"
    "compress/gzip"
    "encoding/json"
)
func main() {
}
type anyStruct struct {
}
// 壓縮 與json搭配使用
func MarshalToJsonWithGzip(jsonData anyStruct) []byte {
    dataAfterMarshal, _ := json.Marshal(jsonData)
    dataAfterGzip, err := Encode(dataAfterMarshal)
    if err != nil {
        return nil
    }
    return dataAfterGzip
}
// 解壓 與json搭配使用
func UnmarshalDataFromJsonWithGzip(msg []byte) (*anyStruct, error) {
    dataAfterDecode, err := Decode(msg)
    if err != nil {
        return nil, err
    }
    data := &anyStruct{}
    err = json.Unmarshal(dataAfterDecode, data)
    if err != nil {
        return nil, err
    }
    return data, nil
}
// Gzip用法 壓縮數(shù)據(jù)
func Encode(input []byte) ([]byte, error) {
    // 創(chuàng)建一個(gè)新的 byte 輸出流
    var buf bytes.Buffer
    // 創(chuàng)建一個(gè)新的 gzip 輸出流
    gzipWriter := gzip.NewWriter(&buf)
    // 將 input byte 數(shù)組寫(xiě)入到此輸出流中
    _, err := gzipWriter.Write(input)
    if err != nil {
        _ = gzipWriter.Close()
        return nil, err
    }
    if err := gzipWriter.Close(); err != nil {
        return nil, err
    }
    // 返回壓縮后的 bytes 數(shù)組
    return buf.Bytes(), nil
}
// Gzip用法 解壓數(shù)據(jù)
func Decode(input []byte) ([]byte, error) {
    // 創(chuàng)建一個(gè)新的 gzip.Reader
    bytesReader := bytes.NewReader(input)
    gzipReader, err := gzip.NewReader(bytesReader)
    if err != nil {
        return nil, err
    }
    defer func() {
        // defer 中關(guān)閉 gzipReader
        _ = gzipReader.Close()
    }()
    buf := new(bytes.Buffer)
    // 從 Reader 中讀取出數(shù)據(jù)
    if _, err := buf.ReadFrom(gzipReader); err != nil {
        return nil, err
    }
    return buf.Bytes(), nil
}