Java从ZipInputStream条目创建InputStream

我想编写一个从单个 InputStream 读取 ZIP 内的多个 XML 文件的方法。

该方法将打开一个 ZipInputStream，并在每个 xml 文件上获取相应的 InputStream，并将其提供给我的 XML 解析器。这是该方法的框架：

private void readZip(InputStream is) throws IOException {

    ZipInputStream zis = new ZipInputStream(is);
    ZipEntry entry = zis.getNextEntry();

    while (entry != null) {

        if (entry.getName().endsWith(".xml")) {

            // READ THE STREAM
        }
        entry = zis.getNextEntry();
    }
}

有问题的部分是“// READ THE STREAM”。我有一个可行的解决方案，其中包括创建一个 ByteArrayInputStream，并将其提供给我的解析器。但它使用缓冲区，对于大文件，我会收到 OutOfMemoryError 错误。这是代码，如果有人仍然感兴趣的话：

int count;
byte buffer[] = new byte[2048];
ByteArrayOutputStream out = new ByteArrayOutputStream();
while ((count = zis.read(buffer)) != -1) { out.write(buffer, 0, count); }       
InputStream is = new ByteArrayInputStream(out.toByteArray());

理想的解决方案是向解析器提供原始的 ZipInputStream。它应该可以工作，因为如果我只是用扫描仪打印条目内容它就可以工作：

Scanner sc = new Scanner(zis);
while (sc.hasNextLine())
{
    System.out.println(sc.nextLine());
}

但是...我当前使用的解析器（jdom2，但我也尝试使用 javax.xml.parsers.DocumentBuilderFactory）在解析数据后关闭流：/ 。所以我无法获取下一个条目并继续。

所以最后的问题是：

• 有人知道不关闭其流的 DOM 解析器吗？
• 还有另一种方法可以从 ZipEntry 获得 InputStream 吗？

Thanks.

Tim 解决方案的一个小改进：必须在 close() 之前调用 allowedToBeClosed() 的问题是，它使得在处理异常时正确关闭 ZipInputStream 变得很棘手，并且会破坏 Java 7 的 try-with-resources 语句。

我建议创建一个包装类，如下所示：

public class UncloseableInputStream extends InputStream {
  private final InputStream input;

  public UncloseableInputStream(InputStream input) {
    this.input = input;
  }

  @Override
  public void close() throws IOException {} // do not close the wrapped stream

  @Override
  public int read() throws IOException {
    return input.read();
  }

  // delegate all other InputStream methods as with read above
}

然后可以安全地使用如下：

try (ZipInputStream zipIn = new ZipInputStream(...))
{
  DocumentBuilder db = DocumentBuilderFactory.newInstance().newDocumentBuilder();
  ZipEntry entry;
  while (null != (entry = zipIn.getNextEntry()))
  {
    if ("file.xml".equals(entry.getName())
    {
      Document doc = db.parse(new UncloseableInputStream(zipIn));
    }
  }
}