如何在 Java 中使用管道将输出流转换为输入流？

将OutputStream 转换为InputStream：阐释

在编码领域，通常需要将数据从OutputStream 重定向到InputStream。这种复杂的转换虽然不像相反的那么简单，但可以通过巧妙地利用管道来实现。

解码管道的力量

Java 的 java.io. PipedInputStream 和 java.io.PipedOutputStream 类成为此转换过程中的关键角色。它们在 OutputStream 和 InputStream 之间建立单向管道，从而实现数据的无缝传输，而不会产生大量内存开销。

Lambda 驱动的代码可轻松转换

以下内容代码片段利用 lambda 来简化转换：

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();

Try-with-Resources：一种优雅的方法

另外，try-with-resources 提供了一种优雅的语法用于管理资源：

PipedInputStream in = new PipedInputStream();
new Thread(new Runnable() {
    public void run () {
        // try-with-resources here
        // placing the try block outside the Thread will prematurely close the PipedOutputStream
        try (final PipedOutputStream out = new PipedOutputStream(in)) {
            // write the original OutputStream to the PipedOutputStream
            originalByteArrayOutputStream.writeTo(out);
        } catch (IOException e) {
            // logging and exception handling should go here
        }
    }
}).start();

其他注意事项

如果您无法控制 OutputStream 的创建，则可能会遇到 ClosedPipeException。要解决此问题，请反转构造函数：

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

管道转换的优点

这种转换方法在内存效率方面表现出色。与创建数据重复副本的其他技术不同，管道仅在流之间建立连接，而不消耗额外的内存。此外，在单独的线程中异步执行可确保最小的延迟并减少资源使用。

以上是如何在 Java 中使用管道将输出流转换为输入流？的详细内容。更多信息请关注PHP中文网其他相关文章！