共计 2797 个字符，预计需要花费 7 分钟才能阅读完成。
| 导读 | 在应用程序中使用 PipedInputStream 类与 PipedOutputStream 类来创建管道之间的通信，一个 PipedInputStream 实例化对象和一个 PipedOutputStream 实例化对象进行连接产生一个通信管道。 |
在应用程序中使用 PipedInputStream 类与 PipedOutputStream 类来创建管道之间的通信，一个 PipedInputStream 实例化对象和一个 PipedOutputStream 实例化对象进行连接产生一个通信管道。PipedInputStream 用来从管道中读取写入的数据，PipedOutputStream 是向管道中写入数据。通过线程之间的通信使用 PipedInputStream 类与 PipedOutputStream 类。使用 PipedInputStream 类与 PipedOutputStream 类学习管道流之间的通信。接下来小编带大家一起来学习!
1.PipedInputStream 类管道输入流，它是可以连接管道输出流，管道输入流提供了要写入管道输出流的所有数据的字节。
2.PipedInputStream 类构造方法：
(1)public PipedInputStream(): 创建管道输入流对象，这个对象它尚未连接。
(2)public PipedInputStream(PipedOutputStream out): 创建一个管道输入流，它被连接到参数 out 指定的管道输出流。如下所示：
PipedInputStream pis=new PipedInputStream();3.PipedInputStream 类方法有：
(1)int read(): 读取数据的下一个字节。
(2)int read(byte []b,int off,int len): 读取 len 个字节数据到一个字节数组，off 参数表示偏移量，len 表示读取数据的长度。
(3)void receive(int b): 接受一个字节的数据。
(4)void connect(PipedOutputStream src): 表示管道输入流连接到管道输出流 src
(5)int available(): 表示没有什么阻碍从输入流中读取字节数。
(6)void close(): 表示关闭流。
1.PipedOutputStream 类是管道输出流，它是可以用于向管道中写入数据。
2.PipedOutputStream 类构造方法：
(1)public PipedOutputStream()：创建管道输出流对象，这个对象它尚未连接。
(2)public PipedOutputStream(PipedInputStream in): 创建一个管道输出流，它被连接到参数 in 指定的管道输入流。如下所示：
PipedOutputStream pos=new PipedOutputStream();3.PipedOutputStream 类方法有：
(1)void close(): 表示关闭流。
(2)void connect(PipedInputStream snk): 表示管道输出流连接到管道输入流中。
(3)void flush()：刷新输出流并强制的写出任何缓冲的输出字节。
(4)void write(int b): 写入指定字节到管道输出流。
(5)void write(byte [] b，int off，int len): 写入 len 个字节的指定字节数组从偏移量 off 开始到管道输出流。
1. 代码实现：
import java.io.*;
public class P22 {public static void main(String[] args) throws Exception {
// 创建 PipedInputStream 对象
final PipedInputStream in=new PipedInputStream();
final PipedOutputStream out=new PipedOutputStream();
// 两个类进行连接
in.connect(out);
new Thread(new Runnable(){public void run(){BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
// 通过键盘读取数据写入管道流
PrintStream ps=new PrintStream(out);
System.out.print(Thread.currentThread().getName()+"请输入内容:");
try {ps.println(br.readLine());
} catch (IOException e) {e.printStackTrace();
}
}
},"发送数据的线程").start();
new Thread(new Runnable(){public void run(){BufferedReader br=new BufferedReader(new InputStreamReader(in));
try {System.out.println(Thread.currentThread().getName()+"收到的内容："+br.readLine());
} catch (IOException e) {e.printStackTrace();
}
}
},"接受数据的线程").start();}
}运行的结果如下图所示：
上面代码中使用一个 PipedInputStream 对象和一个 PipedOutputStream 对象进行连接产生一个通信管道。，写两个线程，一个线程用于键盘输入的数据管道输出流，另一个线程用来管道读取写入的数据。使用这两个类来实现线程之间的通信。
本文主要介绍了 PipedInputStream 类、PipedOutputStream 类、使用 PipedInputStream 类与 PipedOutputStream 类学习管道流之间的通信。PipedInputStream 类管道输入流，它是可以连接管道输出流，管道输入流提供了要写入管道输出流的所有数据的字节。PipedInputStream 介绍了它的构造方法和方法。PipedOutputStream 类是管道输出流，它是可以用于向管道中写入数据。PipedOutputStream 介绍了它的构造方法和方法。使用 PipedInputStream 类与 PipedOutputStream 类学习管道流之间的通信。希望大家通过本文的学习，对你有所帮助!
