概述

今天給大家分享一個比較有意思的 IO 流。SequenceInputStream ，聽名字顧名思義。

SequenceInputStream 流可以把多個 InputStream 合并為一個 InputStream . 按照指定的順序，把幾個輸入流連續地合并起來，使用起來像一個流一樣。并且使它們像單個輸入流一樣出現。每個輸入流依次被讀取，直到到達該流的末尾。然后“序列輸入流”類關閉這個流并自動地切換到下一個輸入流。

合并流的作用是將多個源合并合一個源。

使用場景

比如現在有三個文件【1.txt】、【2.txt】、【3.txt】；現在要把這三個文件按照1、2、3的順序合并成一個文件輸出到 【all.txt】文件中。

如果不知道有這個流，大家可能都是自己一個一個文件的去讀，自己合并到一個文件中。
有了這個流，我們操作起來，代碼更加優雅。

示例

public class SequenceInputStreamDemo {public static void sequenceStream() {// 創建字節輸入流對象s1,s2,s3try (InputStream s1 = new FileInputStream(new File("d:\\1.txt"));InputStream s2 = new FileInputStream(new File("d:\\2.txt"));InputStream s3 = new FileInputStream(new File("d:\\3.txt"));) {/*** SequenceInputStream(Enumeration<? extends InputStream> e)* 通過記住參數來初始化新創建的 SequenceInputStream， 該參數必須是生成運行時類型為 InputStream* 對象的 Enumeration 型參數。*/// 創建一個Vector類對象vVector<InputStream> v = new Vector<>();/*** void addElement(E obj) 將指定的組件添加到此向量的末尾，將其大小增加 1。*/// 將3個字節流對象添加到Vector容器中v.addElement(s1);v.addElement(s2);v.addElement(s3);// 獲取Vector對象中的元素Enumeration<InputStream> e = v.elements();// 將Enumeration對象中的流合并（創建一個序列流，用于合并多個字節流文件s1,s2,s3）try (SequenceInputStream se = new SequenceInputStream(e);OutputStream os = new FileOutputStream("d:\\all.txt")) {byte[] b = new byte[1024];int len = 0;while ((len = se.read(b)) != -1) {os.write(b, 0, len);os.write("\r\n".getBytes());}System.out.println("合并成功");} catch (IOException ex) {ex.printStackTrace();}} catch (IOException e) {e.printStackTrace();}}public static void main(String[] args) {sequenceStream();} }

該示例是，把D盤目錄下的三個文件【1.txt】、【2.txt】、【3.txt】使用SequenceInputStream 流，按照 指定的文件的順序合并輸出到 【all.txt】 文件中。

SequenceInputStream 源碼解析

public class SequenceInputStream extends InputStream {Enumeration<? extends InputStream> e;InputStream in;...... }

SequenceInputStream 繼承 InputStream。
定義了一個 Enumeration 的一個變量。該變量存儲的是所有需要合并的InputStream。
定義了一個 InputStream的一個變量。該變量是記錄 Enumeration 中正在讀去的 InputStream。

Enumeration
Enumeration 接口是Iterator迭代器的“古老版本”，從JDK 1.0開始，Enumeration接口就已經存在了（Iterator從JDK 1.2才出現）。Enumeration接口只有兩個方法。

構造方法

提供兩個構造方法。
* 1、提供 Enumeration 類型的參數。
把傳過來的參數賦值給 e 變量。
并調用 nextStream() 方法。

現在的迭代器都在使用Iterator，而這里為啥還在使用Enumeration 呢？
因為 Iterator 是在JDK1.2以后才有的，而SequenceInputStream 這個流在JDK1.0就已經存在了，故使用 Enumeration 當參數。

• 2、提供兩個 InputStream 類型的參數。
  構造中把這兩個流添加到 Vector 數組中，然后調用 elements 方法放回一個 Enumeration 類型，并賦值給 e 變量。
  并調用 nextStream() 方法。

nextStream 方法

1、判斷該流是否不為null，不為null 則把當前 InputStream 關閉。
2、該方法是先判斷 Enumeration 中是否有可用的元素，如果獲取 Enumeration 迭代器中下一個的元素，并賦值給 in 變量。

read 方法

讀取 InputStream 中的數據。如果當前 InputStream 讀取完了，再調用 nextStream 方法，獲取下一個流，然后繼續讀取。直到所有的流都已經讀取完畢。

close 方法

close 方法會關閉剩下沒有讀取完的所有的 InputStream。
讀取過的InputStream 會在 調用 nextStream 方法中關閉。所以在這只需要關閉沒有讀取完的流就可以了。

看完源碼是不是感覺 SequenceInputStream 超級簡單，自己也可以實現一個。

---

想了解更多精彩內容請關注我的公眾號

本人簡書blog地址：http://www.jianshu.com/u/1f0067e24ff8????
點擊這里快速進入簡書
GIT地址：http://git.oschina.net/brucekankan/
點擊這里快速進入GIT

總結

以上是生活随笔為你收集整理的Java IO 之 SequenceInputStream 原理解析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。