如何在 Java 中使用 PipedOutputStream 实现线程间字节数据的单向异步传输

Java中的PipedOutputStream属于字节管道输出流，专门用于和PipedInputStream配合实现线程间的单向字节数据异步传输，它可以在一个线程中写入数据，另一个线程中读取数据，无需额外的共享变量或锁机制就能完成跨线程的数据传递。

PipedOutputStream 核心原理说明

PipedOutputStream本身并不直接存储数据，它需要和PipedInputStream绑定之后才能工作。当调用PipedOutputStream的write方法写入字节数据时，数据会被传递到绑定的PipedInputStream内部的缓冲区中，读取线程可以通过PipedInputStream的read方法从缓冲区获取数据。整个过程是异步的，写入线程和读取线程不需要严格同步执行，只要管道没有被关闭，写入的数据都会被暂存到缓冲区等待读取。

核心特性

• 单向传输：只能从PipedOutputStream端写入，PipedInputStream端读取，不支持反向传输
• 异步执行：写入线程和读取线程可以独立运行，不需要互相等待
• 缓冲区机制：内部自带默认大小为1024字节的缓冲区，缓冲区满时写入线程会阻塞，缓冲区空时读取线程会阻塞
• 线程绑定：一个PipedOutputStream只能和一个PipedInputStream配对，反之亦然

基础使用步骤

第一步：创建配对管道流

可以先创建PipedInputStream，再通过构造函数或者connect方法将PipedOutputStream和PipedInputStream绑定，两种方式效果一致。

import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.io.IOException;

public class PipeDemo {
    public static void main(String[] args) throws IOException {
        // 方式1：先创建输入流，再绑定输出流
        PipedInputStream pipedInputStream = new PipedInputStream();
        PipedOutputStream pipedOutputStream = new PipedOutputStream(pipedInputStream);
        
        // 方式2：先创建两个流，再手动连接
        // PipedInputStream pipedInputStream = new PipedInputStream();
        // PipedOutputStream pipedOutputStream = new PipedOutputStream();
        // pipedOutputStream.connect(pipedInputStream);
    }
}

第二步：定义写入线程

写入线程中持有PipedOutputStream实例，在run方法中调用write方法写入字节数据，写入完成后关闭流释放资源。

class WriteThread extends Thread {
    private PipedOutputStream outputStream;
    
    public WriteThread(PipedOutputStream outputStream) {
        this.outputStream = outputStream;
    }
    
    @Override
    public void run() {
        try {
            // 写入字节数据，这里是写入字符串的字节形式
            String data = "这是要传输的字节数据";
            outputStream.write(data.getBytes());
            // 写入完成关闭流
            outputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

第三步：定义读取线程

读取线程中持有PipedInputStream实例，在run方法中循环调用read方法读取数据，直到返回-1表示流已经结束。

class ReadThread extends Thread {
    private PipedInputStream inputStream;
    
    public ReadThread(PipedInputStream inputStream) {
        this.inputStream = inputStream;
    }
    
    @Override
    public void run() {
        try {
            int readLen;
            byte[] buffer = new byte[1024];
            // 循环读取数据，返回-1表示流已关闭
            while ((readLen = inputStream.read(buffer)) != -1) {
                String result = new String(buffer, 0, readLen);
                System.out.println("读取到数据：" + result);
            }
            // 读取完成关闭流
            inputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

第四步：启动线程完成传输

在主线程中创建管道流、初始化两个线程并启动，写入线程写入数据后，读取线程会自动从管道中获取到数据。

public class PipeDemo {
    public static void main(String[] args) throws IOException {
        PipedInputStream pipedInputStream = new PipedInputStream();
        PipedOutputStream pipedOutputStream = new PipedOutputStream(pipedInputStream);
        
        // 启动读取线程，先启动读取线程避免写入时管道未就绪
        ReadThread readThread = new ReadThread(pipedInputStream);
        readThread.start();
        
        // 启动写入线程
        WriteThread writeThread = new WriteThread(pipedOutputStream);
        writeThread.start();
    }
}

常见问题与注意事项

线程启动顺序问题

建议先启动读取线程，再启动写入线程。如果先启动写入线程，而此时读取线程还没有开始执行，写入的数据会先进入缓冲区，只要缓冲区没有满就不会报错，但如果写入速度远快于读取速度，缓冲区满了之后写入线程会阻塞，直到读取线程消费数据后才会继续。不过如果管道没有绑定就调用write方法，会直接抛出IOException。

缓冲区大小设置

默认的PipedInputStream缓冲区大小是1024字节，如果需要传输更大的数据，可以在创建PipedInputStream时指定缓冲区大小：

// 创建缓冲区大小为4096字节的输入流
PipedInputStream pipedInputStream = new PipedInputStream(4096);

流关闭的影响

当PipedOutputStream关闭后，写入端无法再写入数据，此时PipedInputStream读取完缓冲区剩余数据后会返回-1，表示传输结束。如果PipedInputStream先被关闭，写入端再调用write方法会抛出IOException。

异常处理

管道传输过程中如果其中一个线程抛出异常导致流被关闭，另一个线程的操作也会受到影响，因此在实际开发中需要做好异常捕获，避免一个线程的异常影响整个传输流程。

适用场景说明

PipedOutputStream适合用在两个线程之间需要简单单向传递字节数据的场景，比如线程A生成字节数据，线程B需要异步处理这些数据，不需要复杂的同步控制。如果是需要传递对象或者更复杂的数据结构，可以考虑使用PipedWriter和PipedReader实现字符流传输，或者使用其他线程通信方式比如BlockingQueue等。

PipedOutputStreamJava线程通信字节流传输线程异步修改时间：2026-06-22 15:07:05