服务器到Android设备的数据传输与压缩策略

package main

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

// CompressData compresses a byte slice using gzip.
func CompressData(data []byte) ([]byte, error) {
    var b bytes.Buffer
    gz := gzip.NewWriter(&b)
    if _, err := gz.Write(data); err != nil {
        return nil, fmt.Errorf("failed to write data to gzip writer: %w", err)
    }
    if err := gz.Close(); err != nil {
        return nil, fmt.Errorf("failed to close gzip writer: %w", err)
    }
    return b.Bytes(), nil
}

func main() {
    originalData := []byte("This is some sample text data that we want to compress. It can be quite long and repetitive for better compression ratios.")
    fmt.Printf("Original data size: %d bytes\n", len(originalData))

    compressedData, err := CompressData(originalData)
    if err != nil {
        log.Fatalf("Error compressing data: %v", err)
    }
    fmt.Printf("Compressed data size: %d bytes\n", len(compressedData))
    // In a real server, you would send 'compressedData' over the network.
}

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.zip.GZIPInputStream;

public class GzipDecompressor {

    // DecompressData decompresses a byte array using gzip.
    public static byte[] decompressData(byte[] compressedData) throws IOException {
        if (compressedData == null || compressedData.length == 0) {
            return new byte[0];
        }

        ByteArrayOutputStream bos = new ByteArrayOutputStream();
        ByteArrayInputStream bis = new ByteArrayInputStream(compressedData);
        GZIPInputStream gis = null;
        try {
            gis = new GZIPInputStream(bis);
            byte[] buffer = new byte[1024];
            int len;
            while ((len = gis.read(buffer)) != -1) {
                bos.write(buffer, 0, len);
            }
            return bos.toByteArray();
        } finally {
            if (gis != null) {
                try {
                    gis.close();
                } catch (IOException e) {
                    // Log or handle the exception
                }
            }
            try {
                bis.close();
            } catch (IOException e) {
                // Log or handle the exception
            }
            try {
                bos.close();
            } catch (IOException e) {
                // Log or handle the exception
            }
        }
    }

    public static void main(String[] args) {
        // Assume 'compressedData' is received from the server
        byte[] compressedDataFromServer = new byte[]{ /* ... your compressed bytes ... */ };

        try {
            byte[] decompressedData = decompressData(compressedDataFromServer);
            String originalText = new String(decompressedData, "UTF-8");
            System.out.println("Decompressed text: " + originalText);
        } catch (IOException e) {
            System.err.println("Error decompressing data: " + e.getMessage());
        }
    }
}