資訊專欄INFORMATION COLUMN
摘要：主要實(shí)現(xiàn)是通過改變屬性的值來實(shí)現(xiàn)的這兩個(gè)方法是對數(shù)據(jù)做標(biāo)記，然后通過方法重置，主要為了方便重復(fù)讀取流的數(shù)據(jù)以上就是的核心實(shí)現(xiàn)，其實(shí)可以看到關(guān)鍵的方法都是的，說明流都是阻塞的。
分析開始
ByteArrayInputStream一共有四個(gè)屬性
protected byte buf[];//存放數(shù)據(jù)
protected int pos;//讀取數(shù)據(jù)的偏移量
protected int mark = 0;//對讀取數(shù)據(jù)做一個(gè)標(biāo)記
protected int count;//count=buf.length 數(shù)據(jù)量的大小
read()方法主要是先判斷數(shù)據(jù)是否讀完，如果讀完則返回-1(所以數(shù)據(jù)讀完了我們會(huì)經(jīng)常用read()==-1來判斷)，如果沒有讀完則讀取pos的數(shù)據(jù)然后將pos加1，那么下次則讀取的數(shù)據(jù)是pos則是1，接著是一個(gè) & 0xff的操作，這個(gè)其實(shí)是將byte數(shù)據(jù)轉(zhuǎn)換成int數(shù)據(jù)，是通過位運(yùn)算高位補(bǔ)0，例如byte的值是5，那么byte的二進(jìn)制是0000 0101，那么& 0xff的操作是 0000 0101 & 1111 1111 1111 1111 1111 1111 1111 1111 = 0000 0000 0000 0000 0000 0000 0000 0101,結(jié)果沒變只不過是把byte類型轉(zhuǎn)換成int類型了。說明下java里，一個(gè)byte是占1個(gè)字節(jié)(8位)，一個(gè)int是4個(gè)字節(jié)(32位)
public synchronized int read() {
return (pos < count) ? (buf[pos++] & 0xff) : -1;
}
還有read()的方法，這個(gè)方法主要是將數(shù)據(jù)讀到第一個(gè)參數(shù)的byte[]里去，與上面read()的差別是這個(gè)是有點(diǎn)像是一下讀去一塊數(shù)據(jù)，所以效率會(huì)比上面一個(gè)塊，第二的參數(shù)off是從哪個(gè)位置開始讀，len是讀取的需要讀取的長度是多少，讀完后會(huì)將pos的位置加上len的數(shù)值算出數(shù)據(jù)的讀取的偏移的位置
public synchronized int read(byte b[], int off, int len) {
if (b == null) {
throw new NullPointerException();
} else if (off < 0 || len < 0 || len > b.length - off) {
//裝數(shù)據(jù)byte[]的長度一定要小于，讀取的長度-off的長度，否則就裝不下啦
throw new IndexOutOfBoundsException();
}
if (pos >= count) {
return -1;
}
int avail = count - pos;//計(jì)算剩余的有效數(shù)據(jù)
if (len > avail) {
len = avail;
}
if (len <= 0) {
return 0;
}
System.arraycopy(buf, pos, b, off, len);//拷貝數(shù)據(jù)到byte[]塊里
pos += len;//設(shè)置讀取的偏移量
return len;
}
skip()這個(gè)方法是跳過不需要讀取的數(shù)據(jù)，然后直接讀取想要的數(shù)據(jù)。主要實(shí)現(xiàn)是通過改變屬性pos的值來實(shí)現(xiàn)的
public synchronized long skip(long n) {
long k = count - pos;
if (n < k) {
k = n < 0 ? 0 : n;
}
pos += k;
return k;
}
mark(),rest()這兩個(gè)方法是mark()對數(shù)據(jù)做標(biāo)記，然后通過reset()方法重置，主要為了方便重復(fù)讀取流的數(shù)據(jù)
public void mark(int readAheadLimit) {
mark = pos;
}
public synchronized void reset() {
pos = mark;
}
以上就是ByteArrayInputStream的核心實(shí)現(xiàn)，其實(shí)可以看到關(guān)鍵的方法都是synchronized的，說明io流都是阻塞的。
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/68820.html
摘要：簡介字節(jié)數(shù)組輸入流上一篇簡單的介紹了一下字節(jié)輸入流的超類，只提及了一下超類中定義的一些方法字節(jié)數(shù)組輸入流是超類的一個(gè)具體的實(shí)現(xiàn)主要的操作實(shí)際上就是讀取操作一個(gè)字節(jié)數(shù)組，類中定義了一個(gè)緩沖的字節(jié)數(shù)組，具體的操作通過定義一下標(biāo)志位，操作次數(shù)等進(jìn) 簡介 ByteArrayInputStream 字節(jié)數(shù)組輸入流 上一篇簡單的介紹了一下字節(jié)輸入流的超類，只提及了一下超類中定義的一些方法；字節(jié)數(shù)組...
摘要：類圖結(jié)構(gòu)如上，主要流程如下類實(shí)現(xiàn)接口類中和接口。對于，通過定義對象并調(diào)用方法對進(jìn)行反序列化。底層還是通過調(diào)用的操作和類實(shí)現(xiàn)的序列化和反序列化。 showImg(https://segmentfault.com/img/bVJxmP?w=938&h=672); redis在緩存POJO的時(shí)候需要將POJO序列化為byte數(shù)組進(jìn)行存儲(chǔ)，spring-data-redis實(shí)現(xiàn)了類JdkSer...
摘要：類圖結(jié)構(gòu)如上，主要流程如下類實(shí)現(xiàn)接口類中和接口。對于，通過定義對象并調(diào)用方法對進(jìn)行反序列化。底層還是通過調(diào)用的操作和類實(shí)現(xiàn)的序列化和反序列化。 showImg(https://segmentfault.com/img/bVJxmP?w=938&h=672); redis在緩存POJO的時(shí)候需要將POJO序列化為byte數(shù)組進(jìn)行存儲(chǔ)，spring-data-redis實(shí)現(xiàn)了類JdkSer...
摘要：類圖結(jié)構(gòu)如上，主要流程如下類實(shí)現(xiàn)接口類中和接口。對于，通過定義對象并調(diào)用方法對進(jìn)行反序列化。底層還是通過調(diào)用的操作和類實(shí)現(xiàn)的序列化和反序列化。 showImg(https://segmentfault.com/img/bVJxmP?w=938&h=672); redis在緩存POJO的時(shí)候需要將POJO序列化為byte數(shù)組進(jìn)行存儲(chǔ)，spring-data-redis實(shí)現(xiàn)了類JdkSer...
閱讀 1014·2021-09-27 13:36
閱讀 1064·2021-09-08 09:35
閱讀 1147·2021-08-12 13:25
閱讀 1503·2019-08-29 16:52
閱讀 2992·2019-08-29 15:12
閱讀 2797·2019-08-29 14:17
閱讀 2698·2019-08-26 13:57
閱讀 1080·2019-08-26 13:51
