Writer：李強強

一、InputStream

InputStream是一個抽象類，即表示所有字節輸入流實現類的基類。它的作用就是抽象地表示所有從不同數據源產生輸入的類，例如常見的FileInputStream、FilterInputStream等。那些數據源呢？比如：

1） 字節數組（不代表String類，但可以轉換）

2） String對象

3） 文件

4） 一個其他種類的流組成的序列化 （在分布式系統中常見）

5） 管道（多線程環境中的數據源）

等等

二者，注意它是屬于字節流部分，而不是字符流（java.io中Reader\Writer，下面會講到）。

FilterInputStream是為各種InputStream實現類提供的“裝飾器模式”的基類。因此，可以分為原始的字節流和“裝飾”過的功能封裝字節流。

二、細解InputStream源碼的核心

源碼如下：

/*** 所有字節輸入流實現類的基類*/ public abstract class SInputStream {// 緩存區字節數組最大值private static final int MAX_SKIP_BUFFER_SIZE = 2048;// 從輸入流中讀取數據的下一個字節，以int返回public abstract int read() throws IOException;// 從輸入流中讀取數據的一定數量字節，并存儲在緩存數組bpublic int read(byte b[]) throws IOException {return read(b, 0, b.length);}// 從輸入流中讀取數據最多len個字節，并存儲在緩存數組bpublic int read(byte b[], int off, int len) throws IOException {if (b == null) {throw new NullPointerException();} else if (off < 0 || len < 0 || len > b.length - off) {throw new IndexOutOfBoundsException();} else if (len == 0) {return 0;}int c = read();if (c == -1) {return -1;}b[off] = (byte)c;int i = 1;try {for (; i < len ; i++) {c = read();if (c == -1) {break;}b[off + i] = (byte)c;}} catch (IOException ee) {}return i;}// 跳過輸入流中數據的n個字節public long skip(long n) throws IOException {long remaining = n;int nr;if (n <= 0) {return 0;}int size = (int)Math.min(MAX_SKIP_BUFFER_SIZE, remaining);byte[] skipBuffer = new byte[size];while (remaining > 0) {nr = read(skipBuffer, 0, (int)Math.min(size, remaining));if (nr < 0) {break;}remaining -= nr;}return n - remaining;}// 返回下一個方法調用能不受阻塞地從此讀取（或者跳過）的估計字節數public int available() throws IOException {return 0;}// 關閉此輸入流，并釋放與其關聯的所有資源public void close() throws IOException {}// 在此輸出流中標記當前位置public synchronized void mark(int readlimit) {}// 將此流重新定位到最后一次對此輸入流調用 mark 方法時的位置。public synchronized void reset() throws IOException {throw new IOException("mark/reset not supported");}// 測試此輸入流是否支持 mark 和 reset 方法public boolean markSupported() {return false;}}

其中，InputStream下面三個read方法才是核心方法：

public abstract int read()

抽象方法，沒有具體實現。因為子類必須實現此方法的一個實現。這就是輸入流的關鍵方法。

二者，可見下面兩個read()方法都調用了這個方法子類的實現來完成功能的。

?

public int read(byte b[])

該方法是表示從輸入流中讀取數據的一定數量字節，并存儲在緩存字節數組b。其效果等同于調用了下面方法的實現：

read(b, 0, b.length)

如果b的長度為 0，則不讀取任何字節并返回 0；否則，嘗試讀取至少 1 字節。如果因為流位于文件末尾而沒有可用的字節，則返回值 -1；否則，至少讀取一個字節并將其存儲在 b 中。

思考：這時候，怪不得很多時候， b != –1 或者 b != EOF

?

public int read(byte b[], int off, int len)

在輸入數據可用、檢測到流末尾或者拋出異常前，此方法一直阻塞。

該方法先進行校驗，然后校驗下個字節是否為空。如果校驗通過后，
如下代碼：

int i = 1; try {for (; i < len ; i++) {c = read();if (c == -1) {break;}b[off + i] = (byte)c;} } catch (IOException ee) { }

將讀取的第一個字節存儲在元素 b[off] 中，下一個存儲在 b[off+1] 中，依次類推。讀取的字節數最多等于 len。設 k 為實際讀取的字節數；這些字節將存儲在 b[off] 到 b[off+k-1] 的元素中，不影響 b[off+k] 到 b[off+len-1] 的元素。

?

?

?

因為有上面兩個read的實現，所以這里InputStream設計為抽象類。

三、小結

1. InputSream 對應著 OutputStream

2. 看源碼是享受人家寫代碼中流露的How

3. 泥瓦匠學習的代碼都在github上（同步osc git），歡迎大家點star，提意見，一起進步。地址：https://github.com/JeffLi1993

總結

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

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