使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信

后台回复“Java”即可获赠Java学习资料

大家好，我是Java进阶者。

前言

在应用程序中使用PipedInputStream类与PipedOutputStream类来创建管道之间的通信，一个PipedInputStream实例化对象和一个PipedOutputStream实例化对象进行连接产生一个通信管道。PipedInputStream用来从管道中读取写入的数据，PipedOutputStream是向管道中写入数据。通过线程之间的通信使用PipedInputStream类与PipedOutputStream类。使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信。接下来小编带大家一起来学习！

一、PipedInputStream类

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():表示关闭流。

二、PipedOutputStream类

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开始到管道输出流。

三、使用PipedInputStream类与PipedOutputStream类学习管道流之间的通信案例

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类学习管道流之间的通信。希望大家通过本文的学习，对你有所帮助！

    我是Java进阶者，希望大家通过本文的学习，对你有所帮助！欢迎大家加我微信，有问题可以随时帮大家解决噢，交个朋友也好哇~

------------------- End -------------------

往期精彩文章推荐：

• 浅谈Java字符串的截取和分割、比较字符串

• 一篇文章教会你使用Java内部类、成员内部类、静态内部类和方法内部类

• 一篇文章带你了解Java选择排序和垃圾回收机制

• 从Java角度看冒泡排序和多维数组
  

欢迎大家点赞，留言，转发，转载，感谢大家的相伴与支持

想加入Java学习群请在后台回复【入群】

万水千山总是情，点个【在看】行不行