java.io.EOFException：在尝试资源中使用ByteArrayOutputStream时，ZLIB输入流意外结束

Question

我试图读取字节数组的内容创建gzip一个对象，但是当我试图解压缩字节数组的内容我得到一个错误声明：java.io.EOFException：意外结束ZLIB输入流

我试图使用java的try with resources习惯用法来管理流资源，同时压缩和解压缩一个对象，但是如果我将ByteArrayOutputStreamhtml" target="_blank">添加到try with resources块中，另一个流ObjectOutputStream将无法关闭。

我检查了ByteArrayOutputStream的实现，它扩展了AutoCloseable接口，即使其close本身没有执行任何工作，也不应该干扰其他资源的关闭。

我试图压缩对象的代码：

    //This fails
    public static byte[] returnCompressedObject(Object object) {
        try(ByteArrayOutputStream out = new ByteArrayOutputStream();
            GZIPOutputStream gzOut = new GZIPOutputStream(out);
            ObjectOutputStream objOut = new ObjectOutputStream(gzOut)) {
            objOut.writeObject(object);
            return out.toByteArray();
        } catch (IOException e) {
            throw new RuntimeException("Error converting object to bytes ", e);
        }
    }

    //This works with ByteArrayOutputStream moved out of try-with-resources block
    public static byte[] returnCompressedObjectWithByteArrayOutside(Object object) {
        //ByteArrayOutputStream moved out of try-with-resources block
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        try(GZIPOutputStream gzOut = new GZIPOutputStream(out);
            ObjectOutputStream objOut = new ObjectOutputStream(gzOut)) {
            objOut.writeObject(object);
        } catch (IOException e) {
            throw new RuntimeException("Error converting object to bytes ", e);
        }
        return out.toByteArray();
    }

    //This works with explicit close being called on ObjectOutputStream
    public static byte[] returnCompressedObjectWithExplicitClose(Object object) {
        try(ByteArrayOutputStream out = new ByteArrayOutputStream();
            GZIPOutputStream gzOut = new GZIPOutputStream(out);
            ObjectOutputStream objOut = new ObjectOutputStream(gzOut)) {
            objOut.writeObject(object);
            //Explicit close being called on ObjectOutputStream
            objOut.close();
            return out.toByteArray();
        } catch (IOException e) {
            throw new RuntimeException("Error converting object to bytes ", e);
        }

    }

在这些返回中，CompressedObjectWitByteArray外部和返回CompressedObjectWitExpl郊外似乎返回了一个字节数组，我可以使用下面的解压缩方法，但是在解压缩之前使用returCompressedObject最终会抛出异常java.io.EOFException：解压缩期间ZLIB输入流的意外结束用于解压缩的方法：

    public static String decompressUsingGZip(byte[] object) {
        try(ByteArrayInputStream messageInputStream = new ByteArrayInputStream(object);
            GZIPInputStream gzipStream = new GZIPInputStream(messageInputStream);
            InputStreamReader inputStreamReader = new InputStreamReader(gzipStream, StandardCharsets.UTF_8);
            BufferedReader reader = new BufferedReader(inputStreamReader)){
            return reader.lines().collect(Collectors.joining());
        } catch (IOException e) {
            throw new RuntimeException("Error uncompressing object", e);
        }
    }

我试图理解返回压缩对象（returnCompressedObject）为何表现不正常，并关闭了流。

在搜索文档时，我没有找到任何地方提到我们不应该在try with resources中使用ByteArrayOutputStream。

任何帮助理解这种行为的原因是感激。

Answer 1

当您将OutputStream转换为byteArray时，它期望它被关闭。在第三种情况下，您在调用out.toByteArray（）之前显式关闭ObjectOutputStream，这是完全有意义的。在第二种情况下，您将out.toByteArray（）移到了try-cat-out之外，并在try-with资源块中定义了ObjectOutputStream，当try块结束时，它会关闭ObjectOutputStream。因此，当您调用out.toByteArray（）时，ObjectOutputStream已经关闭，因此不再出现问题。

我仍然建议您采用第3种方法或将整个代码包装在另一个try-get块中，并在try-with-资源块中定义ByteArrayOutputStream。因此，此蒸汽将在返回时关闭。

Answer 2

我试图理解返回压缩对象（returnCompressedObject）为何表现不正常，并关闭了流。

它失败是因为GZIPOutputStream有内部缓冲区，该缓冲区没有被刷新。通过关闭它，您强制流执行任何最终操作并写出任何剩余字节。如果不关闭它，您将丢失一些数据，因此出现ZLIB输入流消息的意外结束。