Java Inflator与Deflator短字符串压缩解压异常问题求助

问题核心原因 #

你的代码存在两个关键问题，直接导致短字符串解压失败：

1. 压缩输出缓冲区容量不足
   你用原字符串长度作为压缩输出数组的大小，但zlib压缩算法（Deflater默认使用）会给压缩数据添加头部信息。当原字符串很短时，压缩后的总数据（头部+压缩内容）长度会超过原字符串长度，此时deflate()无法写出全部压缩数据，得到的压缩字节数组不完整，自然无法正常解压。

2. 未规避压缩数据转字符串的潜在风险
   直接将压缩后的字节数组转成ISO_8859_1字符串，虽然单字节编码理论上不会丢失数据，但压缩后的字节可能包含控制字符或非打印字符，在部分场景下会被意外修改或过滤，间接导致解压失败。

修复方案 #

针对上述问题，调整代码如下：

1. 用动态缓冲区收集压缩数据 #

替换固定大小的字节数组为ByteArrayOutputStream，确保能容纳全部压缩结果，避免缓冲区不足导致的数据截断。

2. 用Base64编码压缩后的字节数组 #

将压缩字节转成Base64字符串，彻底避免非打印字符带来的问题，同时保证字符串的可传输性与兼容性。

3. 解压时循环处理直到完成 #

确保Inflater完全解压所有数据，避免单次inflate()调用无法处理全部内容的情况。

修改后的完整代码 #

import java.io.ByteArrayOutputStream;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
import java.util.zip.Deflater;
import java.util.zip.Inflater;

public class CompressionDeCompression {

    public String compress(String payload) {
        Deflater deflater = new Deflater();
        deflater.setInput(payload.getBytes(StandardCharsets.ISO_8859_1));
        deflater.finish();

        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        while (!deflater.finished()) {
            int count = deflater.deflate(buffer);
            outputStream.write(buffer, 0, count);
        }
        deflater.end();

        return Base64.getEncoder().encodeToString(outputStream.toByteArray());
    }

    public String decompress(String compressedPayload, int originalPayloadSize) {
        byte[] compressedBytes = Base64.getDecoder().decode(compressedPayload);

        Inflater inflater = new Inflater();
        inflater.setInput(compressedBytes);

        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        byte[] buffer = new byte[1024];
        while (!inflater.finished()) {
            try {
                int count = inflater.inflate(buffer);
                outputStream.write(buffer, 0, count);
            } catch (Exception e) {
                throw new RuntimeException("解压失败", e);
            }
        }
        inflater.end();

        return new String(outputStream.toByteArray(), StandardCharsets.ISO_8859_1);
    }
}

验证测试用例 #

修改后的代码可正常处理短字符串，你的测试用例无需修改即可通过：

import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

public class CompressionDeCompressionTest {

    @Test
    void verify() {
        final String payload = "1 2 3 4 5 6 7 8 9 one two apple orange banana leaves ";
        CompressionDeCompression compressionDecompression = new CompressionDeCompression();
        String compressedPayload = compressionDecompression.compress(payload);
        Assertions.assertNotNull(compressedPayload);
        String decompressedPayload = compressionDecompression.decompress(compressedPayload, payload.length());
        Assertions.assertEquals(payload.length(), decompressedPayload.length());
        Assertions.assertEquals(payload, decompressedPayload);
    }
}

补充说明 #

• 当原字符串极短（比如几个字符），zlib压缩后的结果可能比原数据大，这是正常现象——zlib的头部开销无法忽略。如果需要针对短字符串优化，可以判断原长度，小于阈值时直接返回原字符串跳过压缩。
• Base64编码会使字符串长度增加约33%，如果对长度敏感，可以选择其他二进制转字符串方案，但Base64是最通用的兼容性选择。

内容的提问来源于stack exchange，提问作者Raj