Java-管道流通信

喜欢ヅ旅行 2022-04-16 00:38 173阅读 0赞

**管道流分为管道输入流和管道输出流，它是一种比较特殊的流，必须先建立连接才能进行彼此间通信。**

**PipedInputStream 用于向管道中写入数据。**

**PipedOutputStream 用于从管道中读取写入的数据。**

package io;
    
    import java.io.*;
    
    public class Piped {
    	public static void main(String[] args) throws Exception {
    		
    		final PipedInputStream pis = new PipedInputStream();// 创建PipedInputStream对象
    		final PipedOutputStream pos = new PipedOutputStream();
    		
    		// PipedInputStream和PipedOutputStream建立连接，也可写成pos.connect(pis)
    		pis.connect(pos);
    		
    		/**
    		 * run方法写入内容
    		 */
    		new Thread(new Runnable() { // 内部类创建一个线程
    			public void run() {
    				BufferedReader br = new BufferedReader(
    						new InputStreamReader(System.in));
    				// 将从键盘读取的数据写入管道流
    				PrintStream ps = new PrintStream(pos);
    				while (true) {
    					try {
    						System.out.print(Thread.currentThread()
    								.getName() + "要求输入内容：");
    						ps.println(br.readLine());
    						Thread.sleep(1000);
    					} catch (Exception e) {
    						e.printStackTrace();
    					}
    				}
    			}
    		}, "发送数据的线程").start();
    		
    		/**
    		 * run方法输出内容
    		 */
    		new Thread(new Runnable() {
    			public void run() {
    				// 下面的代码是从管道流中读出数据，每读一行数据输出一次
    				BufferedReader br = new BufferedReader(
    						new InputStreamReader(pis));
    				while (true) {
    					try {
    						System.out.println(Thread.currentThread().getName()
    								+ "收到的内容：" + br.readLine());
    					} catch (IOException e) {
    						e.printStackTrace();
    					}
    				}
    			}
    		}, "接收数据的线程").start();
    	}
    }

![20181114211024550.png][]

[20181114211024550.png]: /images/20220416/b0d5479f2080432b9dcc2cc23d19932d.png