4

我有一个大InputStream的包含 gzip 的数据。

我无法直接修改 InputStream 中的数据。InputStream稍后使用它的代码需要未经修改的压缩数据。如果需要,我可以将其换成InputStreamInputStream的,但数据必须保持压缩状态。

InputStream出于调试目的,我需要打印出未压缩的内容。

将 my 中的未压缩数据打印InputStream到 a的最简单方法是什么PrintStream,而不是不可撤销地解压缩InputStream本身并且不将整个内容读入内存?

4

1 回答 1

1

这就是我的做法。

// http://stackoverflow.com/a/12107486/82156
public static InputStream wrapInputStreamAndCopyToOutputStream(InputStream in, final boolean gzipped, final OutputStream out) throws IOException {
    // Create a tee-splitter for the other reader.
    final PipedInputStream inCopy = new PipedInputStream();
    final TeeInputStream inWrapper = new TeeInputStream(in, new PipedOutputStream(inCopy));

    new Thread(Thread.currentThread().getName() + "-log-writer") {
        @Override
        public void run() {
            try {
                IOUtils.copy(gzipped ? new GZIPInputStream(inCopy) : inCopy, new BufferedOutputStream(out));
            } catch (IOException e) {
                Log.e(TAG, e);
            }
        }
    }.start();
    return inWrapper;
}

此方法包装原始 InputStream 并返回包装器,从现在开始您需要使用它(不要使用原始 InputStream)。然后,它使用Apache Commons TeeInputStream使用线程将数据复制到 PipedOutputStream,并在此过程中可选地对其进行解压缩。

要使用,只需执行以下操作:

InputStream inputStream = ...; // your original inputstream
inputStream = wrapInputStreamAndCopyToOutputStream(inputStream,true,System.out); // wrap your inputStream and copy the data to System.out

doSomethingWithInputStream(inputStream); // Consume the wrapped InputStream like you were already going to do

后台线程将一直存在,直到前台线程消耗整个输入流,以块的形式缓冲输出并定期将其写入 System.out 直到全部完成。

于 2013-02-01T01:31:49.923 回答