內(nèi)容: 在Java 語言中，提供了各種各樣的輸入輸出流（stream）,使我們能夠很方便的對數(shù)據(jù)進行操作，其中，管道（pipe）流是一種特殊的流，用于在不同線程（threads）間直接傳送數(shù)據(jù)。一個線程發(fā)送數(shù)據(jù)到輸出管道，另一個線程從輸入管道中讀數(shù)據(jù)。通過使用管道，實現(xiàn)不同線程間的通訊。無需求助于類似臨時文件之類的東西。本文在簡要介紹管道的基本概念后，將以一個具體的實例pipeapp加以詳細說明。 1．管道的創(chuàng)建與使用Java提供了兩個特殊的專門的類專門用于處理管道，它們就是pipedinputstream類和pipeoutputstream類。Pipedinputstream代表了數(shù)據(jù)在管道中的輸出端，也就是線程向管道讀數(shù)據(jù)的一端；pipeoutputstream代表了數(shù)據(jù)在管道中的輸入端，也就是線程向管道寫數(shù)據(jù)的一端，這兩個類一起使用可以提供數(shù)據(jù)的管道流。為了創(chuàng)建一個管道流，我們必須首先創(chuàng)建一個pipeoutstream對象，然后，創(chuàng)建pipeinputstream對象，實例如下：pipeout= new pipedyoutstream();pipein= new pipedputsteam(pipepout);一旦創(chuàng)建了一個管道后，就可以象操作文件一樣對管道進行數(shù)據(jù)的讀寫。2．演示程序： pipeapp應用程序由三個程序組成：主線程（pipeapp.Java）及由主線程啟動的兩個二級線程（ythread.Java和zthread.Java）,它們使用管道來處理數(shù)據(jù)。程序從一個內(nèi)容為一行一行'x'字母的'input.txt'文件中讀取數(shù)據(jù)，使用管道傳輸數(shù)據(jù)，第一次是利用線程ythread將數(shù)據(jù)'x'轉(zhuǎn)換為'y'，最后利用線程zthread將'y'轉(zhuǎn)換為'z',之后，程序在屏幕上顯示修改后的數(shù)據(jù)。主線程 （pipeapp.Java）在main()方法中，程序首先創(chuàng)建一個應用對象：pipeapp pipeapp=new pipeapp();由于程序中流操作都需要使用IOException異常處理，所以設(shè)置了一個try塊。在try中，為了從源文件中讀取數(shù)據(jù)，程序為'input.txt'文件創(chuàng)建了一個輸入流Xfileln,:fileinputstream xfileln= new fileinputstream('input.txt');新的輸入流傳遞給changetoy()方法，讓線程ythread能讀取該文件：inputstream ylnpipe =pipeapp.changetoy(xfileln);changetoy()方法創(chuàng)建將輸入數(shù)據(jù)'x'改變到'y'的線程ythread,并返回該線程的輸入管道：inputstream zlnpipe = pipeapp.changetoz(ylnpipe);changetoz()方法啟動將數(shù)據(jù)從'y'改變到'z'的線程zehread,主程序?qū)⑹褂脧腸hangetoz()返回的輸入管道。得到以修改的數(shù)據(jù)。然后，程序?qū)⒐艿垒斎肓鞫ㄎ坏絛atainputstream對象，使程序能夠使用readline()方法讀取數(shù)據(jù)：datainputstream inputstream = new datainputstream(zlnpiepe);創(chuàng)建了輸入流以后，程序就可以以行一行的讀取數(shù)據(jù)病顯示在屏幕上。 String str= inputstream.readline();While(str!=null){system.out.println(str);str=inputstream.readline();} 顯示完成之后，程序關(guān)閉輸入流：inputstream.close();changetoy()方法 changetoy()方法首先通過傳遞一個參數(shù)inputstream給datainputstream對象來定位資源的輸入流，使程序能使用readline()方法從流中讀取數(shù)據(jù)：datainputstream xfileln =new datainutstream(inputstream)；然后，changetoy()創(chuàng)建輸出管道和輸入管道： pipeoutstream pipeout = new pipeoutputstream();pipeinputstream pipeln = new pipedinputsteam(pipeout); 為了能夠使用println()方法輸出修改的后的文本行到管道，程序?qū)⑤敵龉艿蓝ㄎ坏絧rintstream對象：printstream printstream = new printstream(pipeout);現(xiàn)在，程序可以創(chuàng)建將數(shù)據(jù)從x改變到y(tǒng)的線程，該線程是ythread類的一個對象，他傳遞兩個參數(shù)：輸入文件（xfileln）和輸出管道（調(diào)用printstream）ythread ythread =new thread(xfileln,printstream);之后，程序啟動線程：changetoz（）方法changetoz()方法與changetoy()方法很相似，他從changetoy()返回的輸入流開始：datainputstream yfileln= new datainputstream(inputstream);程序創(chuàng)建一個新的管道：pipedoutstream pipeout2 = new pipedoutputstream();pipedinputstream pipeln2 = new pipedinputsream(pipeout2); 該線程通過這個新的管道發(fā)出修改后的數(shù)據(jù)（輸入流pipeln2）給主程序。 源程序如下： ////pipeapp.Java-pipeapp的主應用程序//import Java.io.*class pipeapp{public static void main(string[] args){pipeapp pipeapp=new pipeapp();try{fileinputstream xfile =new fileinputstream('input.txt');inputstream ylnpipe = pipeapp.changetoy(xfileln);inputstream zlnpipe=pipeapp.changetoz(ylnpipe);system.out.println();system.out.println('here are the results');system.out.pringln();datainputstream inputstream = nes datainputstream(zlnpipe);string str = inputstream.readline();while (str!=null){system.out.println(str);str=inputstream.readline();}inputstream.close();}catch(exception e){system.out.println(e.tostring());}}public inputstream changetoy(inputstream inputstream){try{datainputstream pipeout = new datainputsteam(inputstream);pipedoutstream pipeout = new pipedoutputstream();pipedlnsteam pipeln = new pipedlnputstream(pipeout);printstream printstream = new printstream(pipeout);ythread ythread = new ythread(xfileln,printstream);ythread.start();return pipeln;}catch(exeption e){system.out.println(x.tostring());}return null;}public inputstream changetoz(inputstream inputsteam){try{datainputstream yfileln = new datainputstream(inputstream);pipeoutputstream pipeln2 = new pipedinputstream(pipeout2);printrstream printstream2 = new printsteam(pipeout2);zthread zthread = new zthread(yfileln,printstream2);zthread.start();return pipeln2;}catch(exception e){system.out.println(e.tostring());}return null;}} Ythread類和Zthread類由于ythread類與zthread類基本一樣，在此僅以ythread為例加以說明。Ythread的構(gòu)造器接收兩個參數(shù)：輸入的文件和第一個管道的輸出端，構(gòu)造器存儲這兩個參數(shù)作為類的數(shù)據(jù)成員： Ythread(datainputstream xfileln,pringstream printstream){this.xfileln = xfileln;this.printstream = printstream;} 線程通過run()方法來處理數(shù)據(jù)。首先讀取一行數(shù)據(jù)，確保xstring不為空的情況下循環(huán)執(zhí)行：string xstring = xfileln.readline();每讀一行數(shù)據(jù)，完成一次轉(zhuǎn)換string ystring = xstring.replace('x','y');然后將修改后的數(shù)據(jù)輸出到管道的輸出端：prinstream.prinrln(ystring);為了確保所有緩沖區(qū)的數(shù)據(jù)完全進入管道的輸出端：pringstram.flush();循環(huán)完成后，線程關(guān)閉管道輸出流：pringstram.close();ythread類的源程序如下： ////ythread.Java//import Java.io.*;class ythread exteads thread{datainputstream xfileln;pringstream printstream;ythread(datainputstream xfileln,pringstream.printstream){this.xfileln = xfileln;this.printstream = printstream;}public void run(){try{string xstring = xfileln.readline();while(xstring!=null){string ystring= xstring.replace('x','y');printstream.pringln(ystring);printstream.flush();xstring= xfileln.readline();}printstream.close();}catch{ioexception e}{system.out.println(e.tostring());}}} 出處 jianada··emook Java, java, J2SE, j2se, J2EE, j2ee, J2ME, j2me, ejb, ejb3, JBOSS, jboss, spring, hibernate, jdo, struts, webwork, ajax, AJAX, mysql, MySQL, Oracle, Weblogic, Websphere, scjp, scjd