1

我有一个 tar.gz 文件的字节数组表示。添加新的配置文件后,我想获取新的 tar.gz 文件的字节数组表示。我想完全在代码本身中执行此操作,而不向本地磁盘创建任何文件。

下面是我在java中的代码

            InputStream fIn = new ByteArrayInputStream(inputBytes);
            BufferedInputStream in = new BufferedInputStream(fIn);
            GzipCompressorInputStream gzIn = new GzipCompressorInputStream(in);
            TarArchiveInputStream tarInputStream = new TarArchiveInputStream(gzIn);

            ByteArrayOutputStream fOut = new ByteArrayOutputStream();
            BufferedOutputStream buffOut = new BufferedOutputStream(fOut);
            GzipCompressorOutputStream gzOut = new GzipCompressorOutputStream(buffOut);
            TarArchiveOutputStream tarOutputStream = new TarArchiveOutputStream(gzOut);

            ArchiveEntry nextEntry;
            while ((nextEntry = tarInputStream.getNextEntry()) != null) {
                tarOutputStream.putArchiveEntry(nextEntry);
                IOUtils.copy(tarInputStream, tarOutputStream);
                tarOutputStream.closeArchiveEntry();
            }
            tarInputStream.close();
            createTarArchiveEntry("config.json", configData, tarOutputStream);
            tarOutputStream.finish();
            // Convert tarOutputStream to byte array and return





    private static void createTarArchiveEntry(String fileName, byte[] configData, TarArchiveOutputStream tOut)
            throws IOException {

        ByteArrayInputStream baOut1 = new ByteArrayInputStream(configData);

        TarArchiveEntry tarEntry = new TarArchiveEntry(fileName);
        tarEntry.setSize(configData.length);
        tOut.putArchiveEntry(tarEntry);
        byte[] buffer = new byte[1024];
        int len;
        while ((len = baOut1.read(buffer)) > 0) {
            tOut.write(buffer, 0, len);
        }
        tOut.closeArchiveEntry();

    }

如何将 tarOutputStream 转换为字节数组?

4

1 回答 1

0

您已经打开了几个OutputStream实例,但还没有关闭它们。或者更准确地说,您没有“刷新”内容,特别是BufferedOutputStream实例。

BufferedOutputStream正在使用内部缓冲区“等待”写入目标的数据OutputStream。它会这样做,直到有理由这样做。这些“原因”之一是调用该BufferedOutputStream.flush()方法:

public void flush() throws IOException

刷新此缓冲输出流。这会强制将任何缓冲的输出字节写出到底层输出流。

另一个“原因”是关闭流,以便在关闭流之前写入剩余字节。

在您的情况下,正在写入的字节仍存储在内部缓冲区中。根据您的代码结构,您可以简单地关闭OutputStream您拥有的所有实例,因此字节最终被写入ByteArrayOutputStream

tarInputStream.close();
createTarArchiveEntry("config.json", configData, tarOutputStream);
tarOutputStream.finish();
// Convert tarOutputStream to byte array and return
tarOutputStream.close();
gzOut.close();
buffOut.close();
fOut.close();

byte[] content = fOut.toByteArray();
于 2021-07-04T07:58:46.703 回答