怎么利用PipedStream管道流在两个Java线程间传输字节数据-java教程-PHP中文网

PipedInputStream和PipedOutputStream是Java中用于线程间字节传输的阻塞式管道流，需成对绑定、分线程读写，通过1024字节缓冲区自动传递数据，写满或无数据时分别阻塞，异常关闭可触发EOF或异常通知。

怎么利用pipedstream管道流在两个java线程间传输字节数据

PipedStream（准确说是 PipedInputStream 和 PipedOutputStream）是 Java 标准库中专为**线程间字节数据传输**设计的一对管道流。它们必须成对使用，且需在不同线程中操作：一个线程写入 PipedOutputStream，另一个线程从关联的 PipedInputStream 读取，数据通过内存缓冲区自动传递。

核心机制：绑定与阻塞

两个流必须通过 connect() 方法或构造函数绑定（推荐用构造函数直接关联），形成“管道”。一旦绑定：

写线程调用 write() 时，若读线程未及时读取，写操作会**阻塞**，直到缓冲区有空闲空间；
读线程调用 read() 时，若管道中无数据，读操作会**阻塞**，直到有数据写入或流关闭；
缓冲区默认大小为 1024 字节，可构造时指定；
任一线程异常关闭输出流（或抛出 IOException），输入流会感知到 EOF 或异常，避免死锁。

典型使用步骤

按顺序执行以下操作，确保线程安全和正确性：

Java调试

通过 JDWP 实现 Java 远程调试：连接远程 JVM、设置断点、单步执行代码、查看变量值、获取调用栈。适用于需要调试远程 Java 应用、排查运行时状态、追踪代码执行流程的场景。术语注解 JDWP：Java Debug Wire Protocol，Java 调试有线协议（Java 远程调试底层通信协议） remote JVM：远程 Java 虚拟机 step through code：代码单步调试（步入 / 步过 / 步出调试） inspect variables：变量查看 / 变量检视 stac

下载

创建一对绑定的流：PipedInputStream pis = new PipedInputStream();，PipedOutputStream pos = new PipedOutputStream(pis);（或反过来，用 pis.connect(pos)）；
启动读线程：在新线程中打开 pis，循环调用 read() 或 read(byte[])，处理接收到的字节；
启动写线程：在另一线程中向 pos 写入字节（如 pos.write(data)），写完可调用 pos.close() 通知读端结束；
注意异常捕获：I/O 异常（如 IOException）可能由对方线程关闭流触发，需在读/写循环中妥善处理。

简单示例：字符串传输

以下代码演示主线程写入字符串，子线程读取并打印：

// 创建管道
PipedInputStream pis = new PipedInputStream();
PipedOutputStream pos = new PipedOutputStream(pis);

// 启动读线程
new Thread(() -> {
    try (PipedInputStream in = pis) {
        int b;
        while ((b = in.read()) != -1) {
            System.out.print((char) b);
        }
        System.out.println(" —— 读取完成");
    } catch (IOException e) {
        System.err.println("读取异常: " + e.getMessage());
    }
}).start();

// 主线程写入
try (PipedOutputStream out = pos) {
    out.write("Hello, PipedStream!".getBytes(StandardCharsets.UTF_8));
} catch (IOException e) {
    System.err.println("写入异常: " + e.getMessage());
}

运行后输出：Hello, PipedStream! —— 读取完成。注意：必须先启动读线程再写入，否则写线程可能因缓冲区满而永久阻塞（除非设置超时或合理控制写入量）。