来自 ZipInputStream 的 XMLEventReader 关闭流

Question

我想流式传输包含几个非常大（~1GByte）的 XML 文件的 ZIP 文件。我可以将每个 zip 文件中的数据读入缓冲区并从中创建一个 XMLStream - 但为了节省内存，我更愿意动态处理数据。

@Test
public void zipStreamTest() throws IOException, XMLStreamException {
    FileInputStream fis = new FileInputStream("archive.zip");
    ZipInputStream zis = new ZipInputStream(fis);
    ZipEntry ei;

    while ((ei = zis.getNextEntry()) != null){      
        XMLEventReader xr = XMLInputFactory.newInstance().createXMLEventReader(zis);
        while (reader.hasNext()) {
            XMLEvent xe = xr.nextEvent();
            // do some xml event processing..
        }
        zis.closeEntry();
    }
    zis.close();
}

问题：我在执行zis.closeEntry(); 时得到java.io.IOException: Stream closed。当我删除该行时，zis.getNextEntry() 会引发相同的错误，如果它们仍然自动打开，则会关闭以前的条目。

我的 XML 流阅读器似乎在 XML 文件的末尾中断了流，因此无法处理 zip 的其余部分。

我是有实现错误还是我对流如何工作的概念不正确？

注意：要使这个最小的可复制示例，您只需要一个 zip 文件“archive.zip”，其中包含任何有效的 XML 文件（zip 中没有子目录！）。然后，您可以使用 JUnit 运行 sn-p。

Answer 1

我建议使用ZipFile 而不是ZipInputStream，正如answer by Alexandra Dudkina 中所建议的那样。

但是，如果您正在处理数据流，例如下载，因此想继续使用ZipInputStream，您应该将它包装在CloseShieldInputStream from Apache Commons IO¹ 内的getNextEntry() 循环中：

while ((ei = zis.getNextEntry()) != null) {
    XMLEventReader xr = XMLInputFactory.newInstance().createXMLEventReader(new CloseShieldInputStream(zis));
    // Process XML here
    zis.closeEntry();
}

^{1) 或您选择的第三方库中的其他类似帮助类。}

Answer 2

您可以尝试使用 java.util.zip.ZipFile 为每个条目打开单独的 InputStream：

@Test
public void zipStreamTest() throws Exception {
        ZipFile zipFile = new ZipFile("archive.zip");
        Iterator<? extends ZipEntry> iterator = zipFile.entries().asIterator();
        while (iterator.hasNext()) {
            ZipEntry ze = iterator.next();
            try (InputStream zis = zipFile.getInputStream(ze)) {
                XMLEventReader reader = XMLInputFactory.newInstance().createXMLEventReader(zis);
                while (reader.hasNext()) {
                    XMLEvent xe = reader.nextEvent();
                    // do some xml event processing
                }
                reader.close();
            }
        }
    }