一、InputStream

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

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

2） String對象

3） 文件

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

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

等等

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

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

?

二、細解InputStream源碼的核心

源碼如下：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92

/** ?* 所有字節輸入流實現類的基類 ?*/ public abstract class SInputStream { ????// 緩存區字節數組最大值 ????private static final int MAX_SKIP_BUFFER_SIZE =?2048; ????// 從輸入流中讀取數據的下一個字節，以int返回 ????public abstract int read()?throws IOException; ????// 從輸入流中讀取數據的一定數量字節，并存儲在緩存數組b ????public int read(byte b[])?throws IOException { ????????return read(b,?0, b.length); ????} ????// 從輸入流中讀取數據最多len個字節，并存儲在緩存數組b ????public 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方法才是核心方法：

1	public abstract int read()

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

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

?

?

1	public int read(byte b[])

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

1	read(b,?0, b.length)

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

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

?

?

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

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

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

1 2 3 4 5 6 7 8 9 10 11

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

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

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

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