使用管道流构建线程信息通道 | 带你学《Java语言高级特性》之六十二

上一篇：运用内存操作流实现IO操作 | 带你学《Java语言高级特性》之六十一
在之前学习的几种IO流中不难发现，它们在面对线程间通信问题的时候显然无法实现IO操作，这时需要用到本节介绍的管道流来进行处理。

【本节目标】
通过阅读本节内容，你将了解到几种管道流实现类的继承关系及其相关方法的功能，并结合实例代码实现线程间的数据通信工作。

管道流

管道流主要功能是实现两个线程之间的IO处理操作。

管道流

对于管道流也分为两类：

字节管道流：PipedOutputStream、PipedInputStream
  |- 连接处理：public void connect(PipedInputStream snk) throws IOException；
字符管道流：PipedWriter、PipedReader
  |- 连接处理：public void connect(PipedReader snk) throws IOException；

PipedOutputStream

PipedInputStream

PipedWriter

PipedReader

范例：实现管道操作

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
 class JavaAPIDemo {
    public static void main(String[] args) throws Exception {
        SendThread send=new SendThread();
        ReceiveThread receive=new ReceiveThread();
        send.getOutput().connect(receive.getInput());//进行管道连接
        new Thread(send,"消息发送线程").start();
        new Thread(receive,"消息接收线程").start();
    }
}
class SendThread implements Runnable{
    private PipedOutputStream output;  //管道输出流

    public SendThread() {
        this.output = new PipedOutputStream();  //实例化管道输出流
    }
    @Override
    public void run() {
        try {    //利用管道实现数据的发送处理
             this.output.write(("【信息发送 - "+Thread.currentThread().getName()+"】www.mldn.cn\n").getBytes());
        }catch (IOException e){
             e.printStackTrace();
        }
        try {
            this.output.close();
        }catch (IOException e){
            e.printStackTrace();
        }
    }
    public PipedOutputStream getOutput(){
        return output;
    }
}
class ReceiveThread implements Runnable{
    private PipedInputStream input;

    public ReceiveThread() {
        this.input = new PipedInputStream();
    }
    @Override
    public void run() {
          byte[] data = new byte[1024];
          int len = 0;
        ByteArrayOutputStream bos = new ByteArrayOutputStream();//所有的数据保存到内存输出流
        try {
             while ((len = input.read(data)) != -1) {
                bos.write(data, 0, len);  //所有的数据保存在内存流里面
            }
            System.out.println("{" +Thread.currentThread().getName()+"接收消息}\n"+ new String(bos.toByteArray()));
            bos.close();
         } catch (IOException e) {
              e.printStackTrace();
         } 
         try {
            this.input.close();
         } catch (IOException e) {
              e.printStackTrace();
         } 
    }
    public PipedInputStream getInput() {
        return input;
    }
}

执行结果:
{消息接收线程接收消息}【信息发送 - 消息发送线程】www.mldn.cn

管道就类似于在医院打点滴的效果，一个负责发送，一个负责接收，中间靠一个管道连接。

想学习更多的Java的课程吗？从小白到大神，从入门到精通，更多精彩不容错过！免费为您提供更多的学习资源。
本内容视频来源于阿里云大学

下一篇：“一目十行”的RandomAccessFile类 | 带你学《Java语言高级特性》之六十三
更多Java面向对象编程文章查看此处