[[433836]]

大家好，我是Java進(jìn)階者。

前言

在應(yīng)用程序中使用PipedInputStream類與PipedOutputStream類來(lái)創(chuàng)建管道之間的通信，一個(gè)PipedInputStream實(shí)例化對(duì)象和一個(gè)PipedOutputStream實(shí)例化對(duì)象進(jìn)行連接產(chǎn)生一個(gè)通信管道。PipedInputStream用來(lái)從管道中讀取寫(xiě)入的數(shù)據(jù)，PipedOutputStream是向管道中寫(xiě)入數(shù)據(jù)。通過(guò)線程之間的通信使用PipedInputStream類與PipedOutputStream類。使用PipedInputStream類與PipedOutputStream類學(xué)習(xí)管道流之間的通信。接下來(lái)小編帶大家一起來(lái)學(xué)習(xí)!

一、PipedInputStream類

1.PipedInputStream類管道輸入流，它是可以連接管道輸出流，管道輸入流提供了要寫(xiě)入管道輸出流的所有數(shù)據(jù)的字節(jié)。

2.PipedInputStream類構(gòu)造方法：

(1)public PipedInputStream():創(chuàng)建管道輸入流對(duì)象，這個(gè)對(duì)象它尚未連接。

(2)public PipedInputStream(PipedOutputStream out):創(chuàng)建一個(gè)管道輸入流，它被連接到參數(shù)out指定的管道輸出流。如下所示：

PipedInputStream pis=new PipedInputStream(); 

3.PipedInputStream類方法有：

(1)int read():讀取數(shù)據(jù)的下一個(gè)字節(jié)。

(2)int read(byte []b,int off,int len):讀取len個(gè)字節(jié)數(shù)據(jù)到一個(gè)字節(jié)數(shù)組，off參數(shù)表示偏移量，len表示讀取數(shù)據(jù)的長(zhǎng)度。

(3)void receive(int b):接受一個(gè)字節(jié)的數(shù)據(jù)。

(4)void connect(PipedOutputStream src):表示管道輸入流連接到管道輸出流src

(5)int available():表示沒(méi)有什么阻礙從輸入流中讀取字節(jié)數(shù)。

(6)void close():表示關(guān)閉流。

二、PipedOutputStream類

1.PipedOutputStream類是管道輸出流，它是可以用于向管道中寫(xiě)入數(shù)據(jù)。

2.PipedOutputStream類構(gòu)造方法：

(1)public PipedOutputStream()：創(chuàng)建管道輸出流對(duì)象，這個(gè)對(duì)象它尚未連接。

(2)public PipedOutputStream(PipedInputStream in):創(chuàng)建一個(gè)管道輸出流，它被連接到參數(shù)in指定的管道輸入流。如下所示：

PipedOutputStream pos=new PipedOutputStream(); 

3.PipedOutputStream類方法有：

(1)void close():表示關(guān)閉流。

(2)void connect(PipedInputStream snk):表示管道輸出流連接到管道輸入流中。

(3)void flush()：刷新輸出流并強(qiáng)制的寫(xiě)出任何緩沖的輸出字節(jié)。

(4)void write(int b):寫(xiě)入指定字節(jié)到管道輸出流。

(5)void write(byte [] b，int off，int len):寫(xiě)入len個(gè)字節(jié)的指定字節(jié)數(shù)組從偏移量off開(kāi)始到管道輸出流。

三、使用PipedInputStream類與PipedOutputStream類學(xué)習(xí)管道流之間的通信案例

1.代碼實(shí)現(xiàn)：

import java.io.*; 
 
public class P22 { 
public static void main(String[] args) throws Exception { 
//創(chuàng)建PipedInputStream對(duì)象 
final PipedInputStream in=new PipedInputStream(); 
final PipedOutputStream out=new PipedOutputStream(); 
//兩個(gè)類進(jìn)行連接 
in.connect(out); 
new Thread(new Runnable(){ 
        public void run(){ 
            BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); 
            //通過(guò)鍵盤(pán)讀取數(shù)據(jù)寫(xiě)入管道流 
            PrintStream ps=new PrintStream(out); 
            System.out.print(Thread.currentThread().getName()+"請(qǐng)輸入內(nèi)容:"); 
            try { 
                ps.println(br.readLine()); 
            } catch (IOException e) { 
                e.printStackTrace(); 
            } 
        } 
},"發(fā)送數(shù)據(jù)的線程").start(); 
new Thread(new Runnable(){ 
        public void run(){ 
            BufferedReader br=new BufferedReader(new InputStreamReader(in)); 
            try { 
                System.out.println(Thread.currentThread().getName()+"收到的內(nèi)容："+br.readLine()); 
            } catch (IOException e) { 
                e.printStackTrace(); 
            } 
        } 
},"接受數(shù)據(jù)的線程").start(); 
  } 
} 

運(yùn)行的結(jié)果如下圖所示：

上面代碼中使用一個(gè)PipedInputStream對(duì)象和一個(gè)PipedOutputStream對(duì)象進(jìn)行連接產(chǎn)生一個(gè)通信管道。，寫(xiě)兩個(gè)線程，一個(gè)線程用于鍵盤(pán)輸入的數(shù)據(jù)管道輸出流，另一個(gè)線程用來(lái)管道讀取寫(xiě)入的數(shù)據(jù)。使用這兩個(gè)類來(lái)實(shí)現(xiàn)線程之間的通信。

四、總結(jié)

本文主要介紹了PipedInputStream類、PipedOutputStream類、使用PipedInputStream類與PipedOutputStream類學(xué)習(xí)管道流之間的通信。PipedInputStream類管道輸入流，它是可以連接管道輸出流，管道輸入流提供了要寫(xiě)入管道輸出流的所有數(shù)據(jù)的字節(jié)。PipedInputStream介紹了它的構(gòu)造方法和方法。PipedOutputStream類是管道輸出流，它是可以用于向管道中寫(xiě)入數(shù)據(jù)。PipedOutputStream介紹了它的構(gòu)造方法和方法。使用PipedInputStream類與PipedOutputStream類學(xué)習(xí)管道流之間的通信。希望大家通過(guò)本文的學(xué)習(xí)，對(duì)你有所幫助!

本文轉(zhuǎn)載自微信公眾號(hào)「Java進(jìn)階學(xué)習(xí)交流」，可以通過(guò)以下二維碼關(guān)注。轉(zhuǎn)載本文請(qǐng)聯(lián)系Java進(jìn)階學(xué)習(xí)交流公眾號(hào)。