Чтение из ZipInputStream в ByteArrayOutputStream

Ваш цикл выглядит корректным — что возвращает следующий код (только сам по себе)?

zipStream.read(tempBuffer)

если он возвращает -1, то zipStream закрывается до того, как вы его получите, и все ставки сняты. Пришло время использовать ваш отладчик и убедиться, что то, что вам передается, действительно допустимо.

Когда вы вызываете getNextEntry(), возвращает ли она значение и являются ли данные в записи значимыми (т. е. возвращает ли getCompressedSize() допустимое значение)? ЕСЛИ вы просто читаете Zip-файл, в который не встроены zip-записи для упреждающего чтения, тогда ZipInputStream вам не подойдет.

Несколько полезных фактов о формате Zip:

Каждый файл, встроенный в zip-файл, имеет заголовок. Этот заголовок может содержать полезную информацию (например, сжатую длину потока, его смещение в файле, CRC) — или он может содержать некоторые магические значения, которые в основном говорят: «Информации нет в заголовке потока, вы должны проверить Zip пост-амбула'.

Затем каждый zip-файл имеет таблицу, прикрепленную к концу файла, которая содержит все записи zip вместе с реальными данными. Таблица в конце обязательна, и значения в ней должны быть правильными. Напротив, значения, встроенные в поток, не должны предоставляться.

Если вы используете ZipFile, он читает таблицу в конце zip. Если вы используете ZipInputStream, я подозреваю, что getNextEntry() пытается использовать записи, встроенные в поток. Если эти значения не указаны, то ZipInputStream не знает, какой длины может быть поток. Алгоритм inflate является самозавершающимся (на самом деле вам не нужно знать несжатую длину выходного потока, чтобы полностью восстановить вывод), но возможно, что Java-версия этого ридера не очень хорошо справляется с этой ситуацией.

Я скажу, что довольно необычно иметь сервлет, возвращающий ZipInputStream (гораздо чаще получать inflatorInputStream, если вы собираетесь получать сжатый контент.

Вероятно, вы пробовали читать из FileInputStream вот так:

ZipInputStream in = new ZipInputStream(new FileInputStream(...));

Это не будет работать, так как zip-архив может содержать несколько файлов, и вам нужно указать, какой файл читать.

Вы можете использовать java.util.zip.ZipFile и такую ​​библиотеку, как IOUtils из Apache Commons IO или ByteStreams из Guava, которые помогут вам скопировать поток.

Пример:

ByteArrayOutputStream out = new ByteArrayOutputStream();
try (ZipFile zipFile = new ZipFile("foo.zip")) {
    ZipEntry zipEntry = zipFile.getEntry("fileInTheZip.txt");

    try (InputStream in = zipFile.getInputStream(zipEntry)) {
        IOUtils.copy(in, out);
    }
}

Я бы использовал IOUtils из проект Commons.io.

IOUtils.copy(zipStream, byteArrayOutputStream);

Вы пропустили звонок

Запись ZipEntry = (ZipEntry) zipStream.getNextEntry();

для позиционирования первого байта, распакованного из первой записи.

 ByteArrayOutputStream streamBuilder = new ByteArrayOutputStream();
 int bytesRead;
 byte[] tempBuffer = new byte[8192*2];
 ZipEntry entry = (ZipEntry) zipStream.getNextEntry();
 try {
     while ( (bytesRead = zipStream.read(tempBuffer)) != -1 ){
        streamBuilder.write(tempBuffer, 0, bytesRead);
     }
 } catch (IOException e) {
      ...
 }

Вы можете реализовать свою собственную оболочку вокруг ZipInputStream, которая игнорирует функцию close(), и передать ее сторонней библиотеке.

thirdPartyLib.handleZipData(new CloseIgnoringInputStream(zipStream));


class CloseIgnoringInputStream extends InputStream
{
    private ZipInputStream stream;

    public CloseIgnoringInputStream(ZipInputStream inStream)
    {
        stream = inStream;
    }

    public int read() throws IOException {
        return stream.read();
    }

    public void close()
    {
        //ignore
    }

    public void reallyClose() throws IOException
    {
        stream.close();
    }
}

Я бы вызывал getNextEntry() в ZipInputStream, пока он не окажется в нужной записи (используйте ZipEntry.getName() и т. д.). Вызов getNextEntry() переместит «курсор» к началу возвращаемой записи. Затем используйте ZipEntry.getSize(), чтобы определить, сколько байтов вы должны прочитать, используя zipInputStream.read().

Непонятно, как вы получили zipStream. Это должно работать, когда вы получаете это так:

  zipStream = zipFile.getInputStream(zipEntry)

Непонятно, как вы получили zipStream. Это должно работать, когда вы получаете это так:

  zipStream = zipFile.getInputStream(zipEntry)

Если вы получаете ZipInputStream из ZipFile, вы можете получить один поток для сторонней библиотеки, позволить ей использовать его, и вы получите другой входной поток, используя код ранее.

Помните, что поток ввода — это курсор. Если у вас есть все данные (например, ZipFile), вы можете запросить N курсоров над ним.

Другой случай - если у вас есть только входной поток "GZip", только заархивированный поток байтов. В этом случае ваш буфер ByteArrayOutputStream имеет смысл.

Пожалуйста, попробуйте код ниже

private static byte[] getZipArchiveContent(File zipName) throws WorkflowServiceBusinessException {

  BufferedInputStream buffer = null;
  FileInputStream fileStream = null;
  ByteArrayOutputStream byteOut = null;
  byte data[] = new byte[BUFFER];

  try {
   try {
    fileStream = new FileInputStream(zipName);
    buffer = new BufferedInputStream(fileStream);
    byteOut = new ByteArrayOutputStream();

    int count;
    while((count = buffer.read(data, 0, BUFFER)) != -1) {
     byteOut.write(data, 0, count);
    }
   } catch(Exception e) {
    throw new WorkflowServiceBusinessException(e.getMessage(), e);
   } finally {
    if(null != fileStream) {
     fileStream.close();
    }
    if(null != buffer) {
     buffer.close();
    }
    if(null != byteOut) {
     byteOut.close();
    }
   }
  } catch(Exception e) {
   throw new WorkflowServiceBusinessException(e.getMessage(), e);
  }
  return byteOut.toByteArray();

 }

Проверьте, находится ли входной поток в начале.

В остальном, как реализация: я не думаю, что вам нужно писать в поток результатов, пока вы читаете, если только вы не обрабатываете именно этот поток в другом потоке.

Просто создайте массив байтов, прочитайте входной поток, затем создайте выходной поток.