java - 如何将输出流转换为输入流？

Question

我正处于开发阶段，我有两个模块，其中一个模块的输出为 OutputStream ，第二个仅接受 InputStream .

你知道如何转换OutputStream至InputStream (反之亦然，我的意思是这样)这样我就能够连接这两个部分？

Answer 1

似乎有很多链接和其他类似的东西，但没有使用管道的实际代码。使用的优势java.io.PipedInputStream和 java.io.PipedOutputStream就是没有额外消耗内存。 ByteArrayOutputStream.toByteArray() 返回原始缓冲区的副本，因此这意味着无论内存中有什么，现在都有它的两个副本。然后写入 InputStream 意味着您现在拥有数据的三个副本。

使用lambdas的代码(向评论中的@John Manko致敬):

PipedInputStream in = new PipedInputStream();
final PipedOutputStream out = new PipedOutputStream(in);
// in a background thread, write the given output stream to the
// PipedOutputStream for consumption
new Thread(() -> {originalOutputStream.writeTo(out);}).start();

@John Manko 指出的一件事是，在某些情况下，当您无法控制 OutputStream 的创建时，您可能最终会遇到创建者可能会清理的情况过早地创建OutputStream对象。如果您收到 ClosedPipeException，那么您应该尝试反转构造函数:

PipedInputStream in = new PipedInputStream(out);
new Thread(() -> {originalOutputStream.writeTo(out);}).start();

请注意，您也可以反转下面示例的构造函数。

也感谢 @AlexK 纠正我启动 Thread 而不是仅仅启动 Runnable。

<小时/>

使用try-with-resources的代码:

// take the copy of the stream and re-write it to an InputStream
PipedInputStream in = new PipedInputStream();
    new Thread(new Runnable() {
        public void run () {
            // try-with-resources here
            // putting the try block outside the Thread will cause the
            // PipedOutputStream resource to close before the Runnable finishes
            try (final PipedOutputStream out = new PipedOutputStream(in)) {
                // write the original OutputStream to the PipedOutputStream
                // note that in order for the below method to work, you need
                // to ensure that the data has finished writing to the
                // ByteArrayOutputStream
                originalByteArrayOutputStream.writeTo(out);
            }
            catch (IOException e) {
                // logging and exception handling should go here
            }
        }
    }).start();

<小时/>

我写的原始代码:

// take the copy of the stream and re-write it to an InputStream
PipedInputStream in = new PipedInputStream();
final PipedOutputStream out = new PipedOutputStream(in);
new Thread(new Runnable() {
    public void run () {
        try {
            // write the original OutputStream to the PipedOutputStream
            // note that in order for the below method to work, you need
            // to ensure that the data has finished writing to the
            // ByteArrayOutputStream
            originalByteArrayOutputStream.writeTo(out);
        }
        catch (IOException e) {
            // logging and exception handling should go here
        }
        finally {
            // close the PipedOutputStream here because we're done writing data
            // once this thread has completed its run
            if (out != null) {
                // close the PipedOutputStream cleanly
                out.close();
            }
        }   
    }
}).start();

这段代码假设originalByteArrayOutputStream是一个ByteArrayOutputStream，因为它通常是唯一可用的输出流，除非您正在写入文件。这样做的好处在于，由于它位于单独的线程中，因此它也是并行工作的，因此无论消耗输入流什么内容也将从旧输出流中流出。这是有益的，因为缓冲区可以保持较小，并且延迟和内存使用量都会减少。

如果您没有 ByteArrayOutputStream，则必须使用 write() 之一，而不是使用 writeTo() java.io.OutputStream 类中的 code> 方法或子类中可用的其他方法之一。