摘要：不建議對(duì)這兩個(gè)對(duì)象嘗試使用單個(gè)線程，因?yàn)檫@樣可能會(huì)造成該線程死鎖。構(gòu)造函數(shù)創(chuàng)建尚未連接到管道輸入流的管道輸出流。通常，數(shù)據(jù)由某個(gè)線程從對(duì)象讀取，并由其他線程將其寫入到相應(yīng)的。

管道流的主要作用是可以進(jìn)行兩個(gè)線程間的通訊，分為管道輸出流(PipedOutputStream)、管道輸入流（PipedInputStream），如果想要進(jìn)行管道輸出，則必須要把輸出流連在輸入流之上，在PipedOutputStream類上有如下的一個(gè)方法用于連接管道：
public void connect(PipedInputStream snk)throws IOException

通常是創(chuàng)建兩個(gè)多帶帶的線程來(lái)實(shí)現(xiàn)通信，如果是單個(gè)線程的話容易出現(xiàn)線程堵塞，因?yàn)檩敵隽髯疃嘀荒芟蚓彌_區(qū)寫入1024個(gè)字節(jié)的數(shù)據(jù)，如果超出就會(huì)出現(xiàn)線程堵塞，因此必須創(chuàng)建多個(gè)線程實(shí)現(xiàn)緩沖區(qū)的釋放和存儲(chǔ)

管道輸出流是管道的發(fā)送端，可以將管道輸出流連接到管道輸入流來(lái)創(chuàng)建一個(gè)通信管道，通常，數(shù)據(jù)由某個(gè)線程寫入 PipedOutputStream 對(duì)象，并由其他線程從連接的 PipedInputStream 讀取。不建議對(duì)這兩個(gè)對(duì)象嘗試使用單個(gè)線程，因?yàn)檫@樣可能會(huì)造成該線程死鎖。如果某個(gè)線程正從連接的管道輸入流中讀取數(shù)據(jù)字節(jié)，但該線程不再處于活動(dòng)狀態(tài)，則該管道被視為處于 毀壞 狀態(tài)。

PipedOutputStream()  創(chuàng)建尚未連接到管道輸入流的管道輸出流。

PipedOutputStream(PipedInputStream snk)   創(chuàng)建連接到指定管道輸入流的管道輸出流。

close()  關(guān)閉

void    connect(PipedInputStream snk)  將此管道輸出流連接到接收者。

void    flush()    刷新此輸出流并強(qiáng)制寫出所有緩沖的輸出字節(jié)。

void    write(byte[] b, int off, int len)      將 len 字節(jié)從初始偏移量為 off 的指定 byte 數(shù)組寫入該管道輸出流。

void    write(int b)    將指定 byte 寫入傳送的輸出流。

管道輸入流應(yīng)該連接到管道輸出流；管道輸入流提供要寫入管道輸出流的所有數(shù)據(jù)字節(jié)。通常，數(shù)據(jù)由某個(gè)線程從 PipedInputStream 對(duì)象讀取，并由其他線程將其寫入到相應(yīng)的 PipedOutputStream。不建議對(duì)這兩個(gè)對(duì)象嘗試使用單個(gè)線程，因?yàn)檫@樣可能死鎖線程。管道輸入流包含一個(gè)緩沖區(qū)，可在緩沖區(qū)限定的范圍內(nèi)將讀操作和寫操作分離開。 如果向連接管道輸出流提供數(shù)據(jù)字節(jié)的線程不再存在，則認(rèn)為該管道已損壞。

PipedInputStream()    創(chuàng)建尚未連接的 PipedInputStream。

PipedInputStream(PipedOutputStream src)    創(chuàng)建 PipedInputStream，使其連接到管道輸出流 src。

int    available()   返回可以不受阻塞地從此輸入流中讀取的字節(jié)數(shù)。

void    close()   關(guān)閉此管道輸入流并釋放與該流相關(guān)的所有系統(tǒng)資源。

void    connect(PipedOutputStream src)    使此管道輸入流連接到管道輸出流 src。

int    read()  讀取此管道輸入流中的下一個(gè)數(shù)據(jù)字節(jié)。

int read(byte[] b, int off, int len)    將最多 len 個(gè)數(shù)據(jù)字節(jié)從此管道輸入流讀入 byte 數(shù)組。

protected  void    receive(int b)   接收數(shù)據(jù)字節(jié)。

package IO;

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;

/**
 * Created by chenjiabing on 17-5-25.
 */

/**
 * 注意的問(wèn)題：
 * 1.寫線程正在往緩沖區(qū)寫數(shù)據(jù)的時(shí)候，但是此時(shí)的讀線程的管道結(jié)束，那么此時(shí)的寫線程的管道就會(huì)發(fā)生IOException異常
 * 2.讀線程正在從緩沖區(qū)讀數(shù)據(jù)的時(shí)候，但是此時(shí)的寫線程的管道已經(jīng)結(jié)束了，此時(shí)就會(huì)引起讀線程的管道發(fā)生IOException異常
 * 3.必須是啟用多線程才能實(shí)現(xiàn)管道之間的讀寫，否則會(huì)出現(xiàn)堵塞現(xiàn)象，因?yàn)檫@里的PipeOutputStream每次向緩沖區(qū)寫入的字節(jié)數(shù)最大是1024，如果不及時(shí)的減少緩沖區(qū)的數(shù)據(jù)量就會(huì)出現(xiàn)堵塞
 */

public class demo7 {
    public static PipedOutputStream outputStream = new PipedOutputStream();
    public static PipedInputStream inputStream = new PipedInputStream();

    /**
     * 創(chuàng)建一個(gè)寫入數(shù)據(jù)進(jìn)程，使用的是PipeOutStream，將數(shù)據(jù)寫入管道中
     */
    public static void send() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                byte[] bytes = new byte[2000];     //創(chuàng)建一個(gè)2000字節(jié)的數(shù)組
                while (true) {
                    try {
                        outputStream.write(bytes, 0, 2000);  //寫入管道，但是這里的緩沖區(qū)最多寫入1024個(gè)字節(jié)的數(shù)據(jù)，因此這個(gè)是一次沒有寫完
                        System.out.println("寫入成功");
                    } catch (IOException e) {
                        System.out.println("寫入失敗");
                        System.exit(1);
                    }
                }
            }
        }).start();
    }

    /**
     * 使用PipeInputStream創(chuàng)建一個(gè)讀取的線程
     */

    public static void receive() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                byte[] bytes = new byte[100];  //一次性只讀取100個(gè)字節(jié)
                int len = 0;
                try {
                    len = inputStream.read(bytes, 0, 100);  //讀取
                    while (len != -1) {
                        System.out.println("已經(jīng)讀取了" + len + "個(gè)字節(jié)");
                        len = inputStream.read(bytes, 0, 100);
                    }


                } catch (IOException e) {
                    System.out.println("讀取失敗");
                    System.exit(1);
                }

            }
        }).start();

    }

    public static void main(String args[]) {
        try {
            inputStream.connect(outputStream);  //連接
        } catch (IOException e) {
            System.out.println("連接失敗");
            System.exit(1);
        }
        send();
        receive();


    }

}

注意:從上面的運(yùn)行結(jié)果可以看出，緩沖區(qū)最多可以寫入1024個(gè)字節(jié)的數(shù)據(jù)，所以在緩沖區(qū)滿了之后上面的send進(jìn)程就會(huì)堵塞等待緩沖區(qū)空閑，如果recieve進(jìn)程不繼續(xù)讀取數(shù)據(jù)了，那么就會(huì)一直出現(xiàn)堵塞

寫線程正在往緩沖區(qū)寫數(shù)據(jù)的時(shí)候，但是此時(shí)的讀線程的結(jié)束讀取，那么此時(shí)的寫線程的管道就會(huì)發(fā)生IOException異常，可以將上面receive進(jìn)程中的while(true)去掉就可以清楚的看出

讀線程正在從緩沖區(qū)讀數(shù)據(jù)的時(shí)候，但是此時(shí)的寫線程的管道已經(jīng)結(jié)束了，此時(shí)就會(huì)引起讀線程的管道發(fā)生IOException異常,將上面的send進(jìn)程中的while(true)去掉就可以實(shí)現(xiàn)這個(gè)問(wèn)題

必須是啟用多線程才能實(shí)現(xiàn)管道之間的讀寫，否則會(huì)出現(xiàn)堵塞現(xiàn)象，因?yàn)檫@里的PipeOutputStream每次向緩沖區(qū)寫入的字節(jié)數(shù)最大是1024，如果不及時(shí)的減少緩沖區(qū)的數(shù)據(jù)量就會(huì)出現(xiàn)堵塞

后續(xù)更新中..........

http://www.cnblogs.com/lich/archive/2011/12/11/2283928.html

http://ifeve.com/java-io-%E7%AE%A1%E9%81%93/

http://www.cnblogs.com/chinareny2k/archive/2010/03/24/1693878.html