Java.util.zip.DataFormatException：不正确的标头检查

Question

第一篇文章，通常我会在其他帖子中找到我要找的东西，但这次没有：

我正在使用 javas Deflater 和 Inflater 来压缩/解压缩我在正在处理的服务器和客户端应用程序之间发送的一些数据。

它适用于我 99% 的测试。然而，有一个特定的数据集在膨胀时从 inflater.inflate() 方法中抛出此异常：

DataFormatException: incorrect header check

与其他运行相比，数据没有什么特别之处。它只是一堆用逗号分隔的数字“编码”为字符串，然后完成 .getBytes() 。我唯一知道的是这次它有点大。在压缩 -> 解压缩步骤之间的任何地方都没有发生编码。

---

这是向客户端或服务器发送内容的代码。代码是共享的。

OutputStream outputStream = new DataOutputStream(socket.getOutputStream());
byte[] uncompressed = SOMEJSON.toString().getBytes();
int realLength = uncompressed.length;

// compress data
byte[] compressedData = ByteCompression.compress(uncompressed);
int compressedLength = compressedData.length;
    
outputStream.write(ByteBuffer.allocate(Integer.BYTES).putInt(compressedLength).array());
outputStream.write(ByteBuffer.allocate(Integer.BYTES).putInt(realLength).array());
    
outputStream.write(compressedData);
outputStream.flush();

这是接收数据（客户端或服务器）也共享的代码：

DataInputStream dataIn = new DataInputStream(socket.getInputStream());
int compressedLength = dataIn.readInt();
int realLength = dataIn.readInt();

errorhandling.info("Packet Reader", "Expecting " + compressedLength + " (" + realLength + ") bytes.");
byte[] compressedData = new byte[compressedLength];
            
int readBytes = 0;
while (readBytes < compressedLength) {
    int newByteAmount = dataIn.read(compressedData);
                
    // catch nothing being read or end of line
    if (newByteAmount <= 0) {
        break;
    }
    readBytes += newByteAmount;
}
            
if (readBytes != compressedLength) {
    errorhandling.info("Packet Reader", "Read byte amount differs from expected bytes.");
    return new ErrorPacket("Read byte amount differs from expected bytes.").create();
}

byte[] uncompressedData = ByteCompression.decompress(compressedData, realLength);
String packetData = new String(uncompressedData);

以下是压缩和解压缩 byteArray 的方法（您猜对了它的共享）：

public static byte[] compress(byte[] uncompressed) {
        Deflater deflater = new Deflater(Deflater.BEST_COMPRESSION);
        deflater.setInput(uncompressed);
        deflater.finish();

        byte[] compressed = new byte[uncompressed.length];
        int compressedSize = 0;
        while (!deflater.finished()) {
            compressedSize += deflater.deflate(compressed);
        }
        
        deflater.end();

        return Arrays.copyOfRange(compressed, 0, compressedSize);
    }
    
    public static byte[] decompress(byte[] compressed, int realLength) throws DataFormatException {     
        Inflater inflater = new Inflater(true);
        inflater.setInput(compressed);

        byte[] uncompressed = new byte[realLength];
        while (!inflater.finished()) {
            inflater.inflate(uncompressed); // throws DataFormatException: incorrect header check (but only super rarely)
        }
        inflater.end();

        return uncompressed;
    }

---

到目前为止，我已经尝试了不同的压缩级别，并弄乱了 Deflater 和 Inflater（所有组合）的“nowrap”选项：

// [...]
Deflater deflater = new Deflater(Deflater.BEST_COMPRESSION, true);
// [...]
Inflater inflater = new Inflater(true);

但这只会导致这些异常（但同样只针对那个特定的数据集）：

DataFormatException: invalid stored block lengths
DataFormatException: invalid distance code

我很抱歉这堵文字墙，但此时我真的不知道是什么导致了这个问题。

Answer 1

好的，解决方法在这里：

我的假设是这个循环会将新的读取数据附加到它最后停止的字节数组这不是这种情况（它似乎在 2^16 个字节后停止读取，所以这就是我不这样做的原因用较小的数据包解决这个问题）。

这是错误的：

int readBytes = 0;
while (readBytes < compressedLength) {
    int newByteAmount = dataIn.read(compressedData); // focus here!
    readBytes += newByteAmount;
}

所以发生的事情是数据被正确读取但是输出数组正在覆盖自己！！这就是为什么我在开头看到错误的数据，最后看到一堆 00 00（因为它实际上从未到达数组的那部分）！

改用这个解决了我的问题：

dataIn.readFully(compressedData);

我担心的是我看到代码的第一个变体很多。这是我在谷歌上搜索时发现的。