Java GZIPInputStream读取失败：全零文件格式非法问题求助

核心原因排查 #

你的代码在部分机器上出现读取报错、文件全零的问题，大概率是以下几点原因：

• 写入异常未清理空文件：Files.newOutputStream默认会创建新文件（若不存在）或截断现有文件为零长度。如果写入过程抛出IO异常，catch块仅打印错误但保留了空文件，后续读取这个空文件自然会触发gzip格式错误。
• GZIP缓冲区未完全写入：虽然try-with-resources会自动关闭流，但在某些JVM环境下，GZIPOutputStream的收尾校验信息可能因缓冲区未强制刷新而未写入文件。
• 路径拼接错误：如果newFile方法未正确处理文件夹与文件名的分隔（比如没加系统分隔符），可能导致写入和读取的不是同一个文件，读取到的是历史遗留的空文件。

修复后的代码 #

写入方法优化 #

public static void write_SerialisedCompressed_Object(String folder, String fileName, Object objectToBeSerialised) {
    File node = newFile(folder, fileName);
    boolean writeSuccess = false;
    try (OutputStream os = Files.newOutputStream(node.toPath());
         GZIPOutputStream gOS = new GZIPOutputStream(os);
         ObjectOutputStream oOS = new ObjectOutputStream(gOS)) {
        oOS.writeObject(objectToBeSerialised);
        // 手动刷新并完成GZIP压缩，确保尾部校验信息写入
        oOS.flush();
        gOS.finish();
        writeSuccess = true;
    } catch (IOException ex) {
        Base.print(ex.getMessage(), Base.TEXT_TYPE.ERROR);
    } finally {
        // 写入失败时删除空文件，避免后续读取报错
        if (!writeSuccess && node.exists()) {
            try {
                Files.delete(node.toPath());
            } catch (IOException e) {
                Base.print("Failed to delete empty file: " + e.getMessage(), Base.TEXT_TYPE.ERROR);
            }
        }
    }
}

读取方法补充校验 #

public static Object readCompressedSerialisedObject_File(String folder, String fileName) {
    File node = newFile(folder, fileName);
    // 先校验文件状态，提前拦截空文件/不存在的情况
    if (!node.exists() || node.length() == 0) {
        String error = "File not exists or empty: " + folder + fileName;
        Base.print(error, Base.TEXT_TYPE.ERROR);
        throw new RuntimeException(error);
    }
    try (InputStream is = Files.newInputStream(node.toPath());
         GZIPInputStream gIS = new GZIPInputStream(is);
         ObjectInputStream oIS = new ObjectInputStream(gIS)) {
        return oIS.readObject();
    } catch (Exception ex) {
        String error = "Error in: " + folder + fileName + " readCompressedSerialisedObject_File " + ex.getMessage() + " " + ex.getClass() + " " + ex.getCause();
        Base.print(error, Base.TEXT_TYPE.ERROR);
        throw new RuntimeException(error);
    }
}

额外检查项 #

1. 验证newFile方法逻辑：确保它正确处理路径拼接，避免因分隔符问题导致文件路径错误，示例实现：

   private static File newFile(String folder, String fileName) {
       File dir = new File(folder);
       // 确保目标文件夹存在
       if (!dir.exists()) {
           dir.mkdirs();
       }
       // 用File构造方法自动处理系统分隔符，避免拼接错误
       return new File(dir, fileName);
   }
   

2. 检查对象序列化合法性：确保要写入的对象（包括其所有嵌套字段）都实现了Serializable接口，否则写入时会抛出NotSerializableException，直接导致文件为空。

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