Java中的stream流的概念解析及實際運用總結(jié)
流是字節(jié)序列的抽象概念。
文件是數(shù)據(jù)的靜態(tài)存儲形式,而流是指數(shù)據(jù)傳輸時的形態(tài)。
流類分為兩個大類:節(jié)點流類和過濾流類(也叫處理流類)。
程序用于直接操作目標設備所對應的類叫節(jié)點流類,程序也可以通過一個間接流類去調(diào)用節(jié)點流類,以達到更加靈活方便地讀取各種類型的數(shù)據(jù),這個間接流類就是過濾流類(也叫處理流類),或者稱為包裝類。
包裝類的調(diào)用過程如下圖:

流分類的關系
不管流的分類是多么的豐富和復雜,其根源來自于四個基本的類。這個四個類的關系如下:
| 字節(jié)流 | 字符流 | |
| 輸入流 | InputStream | Reader |
| 輸出流 | OutputStream | Writer |
Java內(nèi)用 Unicode 編碼存儲字符,字符流處理類負責將外部的其他編碼的字符流和java內(nèi) Unicode 字符流之間的轉(zhuǎn)換。而類InputStreamReader 和OutputStreamWriter處理字符流和字節(jié)流的轉(zhuǎn)換。字符流(一次可以處理一個緩沖區(qū))一次操作比字節(jié)流(一次一個字節(jié))效率高。
InputStream

由于InputStream和OutputStream是abstact類,所以它們還不能表明具體對應哪種IO設備。它們下面有許多子類,包括網(wǎng)絡、管道、內(nèi)存、文件等具體的IO設備,實際程序中使用的它們的各種子類對象。
注:我們將節(jié)點流類所對應的IO源和目標稱為流節(jié)點(Node)。
注意:將A文件的內(nèi)容寫入B文件,程序?qū)文件的操作所用的是輸出類還是輸入類這個問題。輸入輸出類是相對程序而言的,而不是代表文件的,所以我們應該創(chuàng)建一個輸入類來完成對A文件的操作,創(chuàng)建一個輸出類來完成對B文件的操作。
OutputStream

以字符為導向的 stream Reader/Writer
以 Unicode 字符為導向的 stream ,表示以 Unicode 字符為單位從 stream 中讀取或往 stream 中寫入信息。同樣,Reader/Writer也為abstact類。
Reader

Writer

IO程序代碼的復用:
平時寫代碼用-1來作為鍵盤輸入的結(jié)束,在寫的函數(shù)中不直接使用System.in,只是在調(diào)用該函數(shù)時,將System.in作為參數(shù)傳遞進去,這樣,我們以后要從某個文件中讀取數(shù)據(jù),來代替手工鍵盤輸入時,我們可以直接使用這個函數(shù),程序就不用做太多的修改了,達到以不變應萬變的效果。
字節(jié)流和字符流的相互轉(zhuǎn)換
InputStreamReader和OutputStreamReader:把一個以字節(jié)為導向的stream轉(zhuǎn)換成一個以字符為導向的stream。
InputStreamReader類是從字節(jié)流到字符流的橋梁:它讀入字節(jié),并根據(jù)指定的編碼方式,將之轉(zhuǎn)換為字符流。
使用的編碼方式可能由名稱指定,或平臺可接受的缺省編碼方式。
InputStreamReader的read()方法之一的每次調(diào)用,可能促使從基本字節(jié)輸入流中讀取一個或多個字節(jié)。
為了達到更高效率,考慮用BufferedReader封裝InputStreamReader,
BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
Java流使用的一點總結(jié)
最經(jīng)工作中碰到不少Java流的使用,總結(jié)如下:
1. 生成Zip格式,遇到的是要在一個Servlet中生成Zip文件,輸出到web 客戶端,直接下載。
response.setContentType("application/zip");
response.addHeader("Content-Disposition", "attachment;filename=/"xxx.zip/"");
ZipOutputStream out = new ZipOutputStream(response.getOutputStream())
for()
{
ZipEntry entry = new ZipEntry("aa" + i ".dat");
out.putNewEntry(entry);
bytes[] bt = s.getBytes();
out.writeBytes(bt, 0, bt.length());
out.closeEntry();
}
out.flush();
out.close();
ZipOutputStream 繼承自 java.io.FilterOutputStream. 因此真正的寫操作是通過參數(shù)OutputStream out去寫的。
其 void write(byte[] b, int off, int len) 最終調(diào)用了 out.write(b, off, len);
如果要生成一個zip文件,構(gòu)造時就這樣寫 new ZipOutputStream(new FileOutputStream(path));
2. 類似的寫XML.
XMLWriter writer = new XMLWriter(new FileOutputStream(path), formater)
writer.write(doc).道理和上面類似
3. 寫文本文件,追加。
PrintStream ps = new PrintStream(new FileOutputStream(path, true), "utf-8") ps.println(s); // 能寫boolean、int等各種類型。
其內(nèi)部使用一個OutputStreamWriter的對象textOut來寫。例如write(String s)最終調(diào)用到textOut.write(s);
這里涉及到編碼的問題。其參數(shù)里的"utf-8"最終傳遞到OutputStream。
OutputStream是一個字符流和字節(jié)流之間的橋梁。
因此其提供了write(char[] cbuf, int off, int len) 和 write(String str, int off, int len) 用來寫字符和字符串。
OutputStream內(nèi)部又通過一個StreamEncoder對象來序列化字符和字符串。
4. 寫出到socket。
DataOutputStream out = new DataOutputStream(socket.getOutputStream()); out.writeBytes(bt); out.writeBoolean(boolean v) ;
DataOutputStream同樣是一個自FilterOutputStream.
5. 從文本中讀取
BufferedReader reader = new BufferedReader(new FileReader(path)); reader.readLine();
BufferedReader的模式和上面的Filter模式一樣,其內(nèi)部存儲一個Reader對象為參數(shù)傳進來并用來實際讀取的對象。
BufferedReader對應java 1.0的類就是BufferedInputStream,是一個FilterInputStream。
6. 從Socket中讀取
BufferedInputStream is = new BufferedInputStream(socket.getInputStream()); is.read(bt, 0, bt.length());
總結(jié):
基類Stream系列是InputStream和OutputStream,他們是抽象類,要求的方法只有(以Output為例)
void write(int b) throws IOException; void write(byte b[]) throws IOException void write(byte b[], int off, int len)
其最基本的只是字節(jié)操作。第1個方法看似寫一個整數(shù),其實只寫一個字節(jié)(最低八個bit)。其子類分兩個系列,一個是直接操作輸出設備的,我們上面碰到的有文件(FileOutputStream)和Servlet輸出(ServletOutputStream)。其他常用的還有一個 ByteArrayOutputStream,是直接在內(nèi)存里操作的。
再就是FilterOutputStream系列了,都是接收一個OutputStream對象座位參數(shù),真正的寫操作通過該對象去完成。例如ZipOutputStream,其本身只負責生成壓縮格式的數(shù)據(jù),至于這些數(shù)據(jù)是寫到文件、內(nèi)存、還是servletResponse,由輸入的參數(shù)確定。這就是裝飾器模式。
Filter系列常用的有PrintStream(提供了print,println,write(boolean[int, char, string])各種操作,最終利用out.write方法以寫字節(jié)的方式寫進去。
還有DataOutputStream,其提供了writeByte/writeBoolean/writeDouble/writeLong/wiretUTF等方法。
還有就是socket/zip等不常用的。
Java的流很方便也很復雜。復雜就復雜在實現(xiàn)一個功能往往需要多個類,而且有多種組合的辦法。尚需繼續(xù)在實踐中總結(jié)。
相關文章
RabbitMQ中的Connection和Channel信道詳解
這篇文章主要介紹了RabbitMQ中的Connection和Channel信道詳解,信道是建立在 Connection 之上的虛擬連接,RabbitMQ 處理的每條 AMQP 指令都是通過信道完成的,需要的朋友可以參考下2023-08-08
SpringBoot數(shù)據(jù)層測試事務回滾的實現(xiàn)流程
這篇文章主要介紹了SpringBoot數(shù)據(jù)層測試事務回滾的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習吧2022-10-10
在?Spring?Boot?中使用?Quartz?調(diào)度作業(yè)的示例詳解
這篇文章主要介紹了在?Spring?Boot?中使用?Quartz?調(diào)度作業(yè)的示例詳解,在本文中,我們將看看如何使用Quartz框架來調(diào)度任務,Quartz支持在特定時間運行作業(yè)、重復作業(yè)執(zhí)行、將作業(yè)存儲在數(shù)據(jù)庫中以及Spring集成,需要的朋友可以參考下2022-07-07
Java利用數(shù)組隨機抽取幸運觀眾如何實現(xiàn)
這篇文章主要介紹了Java利用數(shù)組隨機抽取幸運觀眾如何實現(xiàn),需要的朋友可以參考下2014-02-02
springboot整合redis過期key監(jiān)聽實現(xiàn)訂單過期的項目實踐
現(xiàn)在各種電商平臺都有自己的訂單過期時間設置,那么如何設置訂單時間過期呢,本文主要介紹了springboot整合redis過期key監(jiān)聽實現(xiàn)訂單過期的項目實踐,感興趣的可以了解一下2023-12-12
Spring?Security權(quán)限管理實現(xiàn)接口動態(tài)權(quán)限控制
這篇文章主要為大家介紹了Spring?Security權(quán)限管理實現(xiàn)接口動態(tài)權(quán)限控制,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-06-06

