如何在InputStream中实现数据的压缩和解压

在Java中，可以使用java.util.zip包中的类来实现对InputStream中数据的压缩和解压。以下是一个简单的示例，展示了如何使用GZIP格式进行压缩和解压缩。

首先，需要导入相关的类：

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

接下来，实现压缩和解压缩的方法：

public class CompressionExample {

    public static InputStream compress(InputStream inputStream) throws IOException {
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
        GZIPOutputStream gzipOutputStream = new GZIPOutputStream(byteArrayOutputStream);

        byte[] buffer = new byte[1024];
        int len;
        while ((len = inputStream.read(buffer)) != -1) {
            gzipOutputStream.write(buffer, 0, len);
        }

        gzipOutputStream.close();
        inputStream.close();

        return new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
    }

    public static InputStream decompress(InputStream inputStream) throws IOException {
        GZIPInputStream gzipInputStream = new GZIPInputStream(inputStream);
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

        byte[] buffer = new byte[1024];
        int len;
        while ((len = gzipInputStream.read(buffer)) != -1) {
            byteArrayOutputStream.write(buffer, 0, len);
        }

        gzipInputStream.close();
        inputStream.close();

        return new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
    }
}

这里的compress方法接收一个InputStream，然后使用GZIPOutputStream将其压缩为GZIP格式。decompress方法接收一个GZIP格式的InputStream，然后使用GZIPInputStream将其解压缩。

以下是如何使用这些方法的示例：

public static void main(String[] args) throws IOException {
    // 原始数据
    String originalData = "https://www.yisu.com/ask/This is a test string for compression and decompression.";
    InputStream originalInputStream = new ByteArrayInputStream(originalData.getBytes());

    // 压缩数据
    InputStream compressedInputStream = compress(originalInputStream);

    // 解压缩数据
    InputStream decompressedInputStream = decompress(compressedInputStream);

    // 读取解压缩后的数据
    BufferedReader reader = new BufferedReader(new InputStreamReader(decompressedInputStream));
    String line;
    while ((line = reader.readLine()) != null) {
        System.out.println(line);
    }
}

这个示例首先创建了一个包含原始数据的InputStream，然后使用compress方法将其压缩。接着，使用decompress方法将压缩后的数据解压缩。最后，读取解压缩后的数据并打印出来。