JAVA NIO 之 Buffer

原文:https://segmentfault.com/a/1190000006824155

Java NIO Buffer


當(dāng)我們需要與 NIO Channel 進(jìn)行交互時,我們就需要使用到 NIO Buffer她奥,即數(shù)據(jù)從 Buffer寫入到 Channel 中瓮增,并且從 Channel 中讀取到 Buffer 中。

實際上哩俭,NIO Buffer 其實是一塊內(nèi)存區(qū)域的封裝绷跑,并提供了一些操作方法讓我們能夠方便地進(jìn)行數(shù)據(jù)的讀寫。

Buffer 類型有:

  • ByteBuffer
  • CharBuffer
  • DoubleBuffer
  • FloatBuffer
  • IntBuffer
  • LongBuffer
  • ShortBuffer

這些 Buffer 已經(jīng)覆蓋了能從 IO 中傳輸?shù)乃械?Java 基本數(shù)據(jù)類型凡资。

NIO Buffer 的基本使用

使用 NIO Buffer 的步驟如下:

  • 將 Channel 中的數(shù)據(jù)讀取到 Buffer 中砸捏,對于 Buffer 本身處于寫模式
  • 調(diào)用 Buffer.flip() 方法纫普,將 NIO Buffer 轉(zhuǎn)換為讀模式.
  • 從 Buffer 中讀取數(shù)據(jù)
  • 調(diào)用 Buffer.clear() 或 Buffer.compact() 方法玩焰,將 Buffer 轉(zhuǎn)換為寫模式

當(dāng)我們將數(shù)據(jù)寫入到 Buffer 中時卓起,Buffer 會記錄我們已經(jīng)寫了多少的數(shù)據(jù)驯击。當(dāng)我們需要從 Buffer 中讀取數(shù)據(jù)時,必須調(diào)用 Buffer.flip() 將 Buffer 切換為讀模式恩静。

一旦讀取了所有的 Buffer 數(shù)據(jù)理朋,那么我們必須清理 Buffer眯娱,讓其變?yōu)橹匦驴蓪懙暮裰溃謇?Buffer 可以調(diào)用 Buffer.clear() 或 Buffer.compact()弟灼。

示例:

public class Test {
    public static void main(String[] args) {
        IntBuffer intBuffer = IntBuffer.allocate(2);
        intBuffer.put(12345678);
        intBuffer.put(2);
        intBuffer.flip();
        System.err.println(intBuffer.get());
        System.err.println(intBuffer.get());
    }
}

上面代碼中,我們分配兩個單位大小的 IntBuffer蝗肪,因此它可以寫入兩個 int 值袜爪。
我們使用 put 方法將 int 值寫入蠕趁,然后使用 flip 方法將 buffer 轉(zhuǎn)換為讀模式薛闪,然后連續(xù)使用 get 方法從 buffer 中獲取這兩個 int 值。

每當(dāng)調(diào)用一次 get 方法讀取數(shù)據(jù)時俺陋,buffer 的讀指針都會向前移動一個單位長度(在這里是一個 int 長度)

Buffer 屬性

一個 Buffer 有三個屬性:

  • capacity
  • position
  • limit

其中 position 和 limit 的含義與 Buffer 處于讀模式或?qū)懩J接嘘P(guān)豁延,而 capacity 的含義與 Buffer 所處的模式無關(guān)昙篙。

Capacity

一個內(nèi)存塊會有一個固定的大小,即容量(capacity)诱咏,我們最多寫入 capacity 個單位的數(shù)據(jù)到 Buffer 中苔可,例如一個 DoubleBuffer,其 Capacity 是 100袋狞,那么我們最多可以寫入 100 個 double 數(shù)據(jù)焚辅。

Position

當(dāng)從一個 Buffer 中寫入數(shù)據(jù)時,我們是從 Buffer 的一個確定的位置(position)開始寫入的苟鸯。在最初的狀態(tài)時同蜻,position 的值是 0。每當(dāng)我們寫入了一個單位的數(shù)據(jù)后早处,position 就會遞增 1湾蔓。

當(dāng)我們從 Buffer 中讀取數(shù)據(jù)時,我們也是從某個特定的位置開始讀取的砌梆。當(dāng)我們調(diào)用了 filp() 方法將 Buffer 從寫模式轉(zhuǎn)換到讀模式時默责,position 的值會自動被設(shè)置為0。每當(dāng)我們讀取一個單位的數(shù)據(jù)咸包,position 的值遞增 1桃序。

position 表示了讀寫操作的位置指針。

limit

limit - position 表示此時還可以寫入/讀取多少單位的數(shù)據(jù)诉儒。
例如在寫模式葡缰,如果此時 limit 是 10,position 是 2忱反,則表示已經(jīng)寫入了 2 個單位的數(shù)據(jù)泛释,還可以寫入 10 - 2 = 8 個單位的數(shù)據(jù)。

示例:

public class Test {
    public static void main(String args[]) {
        IntBuffer intBuffer = IntBuffer.allocate(10);
        intBuffer.put(10);
        intBuffer.put(101);
        System.err.println("Write mode: ");
        System.err.println("\tCapacity: " + intBuffer.capacity());
        System.err.println("\tPosition: " + intBuffer.position());
        System.err.println("\tLimit: " + intBuffer.limit());

        intBuffer.flip();
        System.err.println("Read mode: ");
        System.err.println("\tCapacity: " + intBuffer.capacity());
        System.err.println("\tPosition: " + intBuffer.position());
        System.err.println("\tLimit: " + intBuffer.limit());
    }
}

這里我們首先寫入兩個 int 值温算,此時 capacity = 10怜校,position = 2,limit = 10注竿;
然后我們調(diào)用 flip 轉(zhuǎn)換為讀模式, 此時 capacity = 10茄茁,position = 0,limit = 2巩割。

分配 Buffer

為了獲取一個 Buffer 對象裙顽,我們首先需要分配內(nèi)存空間。每個類型的 Buffer 都有一個 allocate() 方法宣谈,我們可以通過這個方法分配 Buffer:

ByteBuffer buf = ByteBuffer.allocate(48);

這里我們分配了 48 * sizeof(Byte) 字節(jié)的內(nèi)存空間愈犹。

CharBuffer buf = CharBuffer.allocate(1024);

這里我們分配了大小為 1024 個字符的 Buffer,即這個 Buffer 可以存儲 1024 個 Char,其大小為 1024 * 2 個字節(jié)漩怎。

Direct Buffer 和 Non-Direct Buffer 的區(qū)別

Direct Buffer:

  • 所分配的內(nèi)存不在 JVM 堆上勋颖,不受 GC 的管理。(但是 Direct Buffer 的 Java 對象是由 GC 管理的勋锤,因此當(dāng)發(fā)生 GC饭玲,對象被回收時,Direct Buffer 也會被釋放)叁执;
  • 因為 Direct Buffer 不在 JVM 堆上分配茄厘,因此 Direct Buffer 對應(yīng)用程序的內(nèi)存占用的影響就不那么明顯(實際上還是占用了這么多內(nèi)存,但是 JVM 不好統(tǒng)計到非 JVM 管理的內(nèi)存)
  • 申請和釋放 Direct Buffer 的開銷比較大谈宛。因此正確的使用 Direct Buffer 的方式是在初始化時申請一個 Buffer蚕断,然后不斷復(fù)用此 buffer,在程序結(jié)束后才釋放此 buffer入挣。
  • 使用 Direct Buffer 時亿乳,當(dāng)進(jìn)行一些底層的系統(tǒng) IO 操作時,效率會比較高径筏,因為此時 JVM 不需要拷貝 buffer 中的內(nèi)存到中間臨時緩沖區(qū)中葛假。

Non-Direct Buffer:

  • 直接在 JVM 堆上進(jìn)行內(nèi)存的分配,本質(zhì)上是 byte[] 數(shù)組的封裝滋恬。
  • 因為 Non-Direct Buffer 在 JVM 堆中聊训,因此當(dāng)進(jìn)行操作系統(tǒng)底層 IO 操作中時,會將此 buffer 的內(nèi)存復(fù)制到中間臨時緩沖區(qū)中恢氯,因此 Non-Direct Buffer 的效率較低带斑。

Buffer 的讀寫

寫入數(shù)據(jù)到 Buffer

// read into buffer.
int bytesRead = inChannel.read(buf); 
buf.put(127);

從 Buffer 中讀取數(shù)據(jù)

// read from buffer into channel.
int bytesWritten = inChannel.write(buf);
byte aByte = buf.get();

重置 position

Buffer.rewind() 方法可以重置 position 的值為0,因此我們可以重新讀取/寫入 Buffer 了勋拟。
如果是讀模式勋磕,則重置的是讀模式的 position,如果是寫模式敢靡,則重置的是寫模式的 position挂滓。

示例:

public class Test {
    public static void main(String[] args) {
        IntBuffer intBuffer = IntBuffer.allocate(2);
        intBuffer.put(1);
        intBuffer.put(2);
        System.err.println("position: " + intBuffer.position());

        intBuffer.rewind();
        System.err.println("position: " + intBuffer.position());
        intBuffer.put(1);
        intBuffer.put(2);
        System.err.println("position: " + intBuffer.position());

        intBuffer.flip();
        System.err.println("position: " + intBuffer.position());
        intBuffer.get();
        intBuffer.get();
        System.err.println("position: " + intBuffer.position());

        intBuffer.rewind();
        System.err.println("position: " + intBuffer.position());
    }
}

rewind() 主要針對于讀模式,在讀模式時啸胧,讀取到 limit 后赶站,可以調(diào)用 rewind() 方法,將讀 position 置為 0纺念。

關(guān)于 mark() 和 reset()

我們可以通過調(diào)用 Buffer.mark() 將當(dāng)前的 position 的值保存起來贝椿,隨后可以通過調(diào)用 Buffer.reset() 方法將 position 的值恢復(fù)回來。

示例:

public class Test {
    public static void main(String[] args) {
        IntBuffer intBuffer = IntBuffer.allocate(2);
        intBuffer.put(1);
        intBuffer.put(2);
        intBuffer.flip();
        System.err.println(intBuffer.get());
        System.err.println("position: " + intBuffer.position());
        intBuffer.mark();
        System.err.println(intBuffer.get());

        System.err.println("position: " + intBuffer.position());
        intBuffer.reset();
        System.err.println("position: " + intBuffer.position());
        System.err.println(intBuffer.get());
    }
}

這里我們寫入兩個 int 值陷谱,然后首先讀取了一個值烙博。此時讀 position 的值為 1。
接著我們調(diào)用 mark() 方法將當(dāng)前的 position 保存起來(在讀模式,因此保存的是讀的 position)习勤,然后再次讀取,此時 position 就是 2 了焙格。
接著使用 reset() 恢復(fù)原來的讀 position图毕,因此讀 position 又為 1 了,可以再次讀取數(shù)據(jù)眷唉。

flip, rewind 和 clear 的區(qū)別

flip

flip 方法源碼

public final Buffer flip() {
    limit = position;
    position = 0;
    mark = -1;
    return this;
}

Buffer 的讀/寫模式共用一個 position 和 limit 變量予颤,當(dāng)從寫模式變?yōu)樽x模式時,原先的 寫 position 就變成了讀模式的 limit冬阳。

rewind

rewind 方法源碼

public final Buffer rewind() {
    position = 0;
    mark = -1;
    return this;
}

rewind蛤虐,即倒帶,這個方法僅僅是將 position 置為 0肝陪。

clear

clear 方法源碼

public final Buffer clear() {
    position = 0;
    limit = capacity;
    mark = -1;
    return this;
}

根據(jù)源碼我們可以知道驳庭,clear 將 positin 設(shè)置為 0,將 limit 設(shè)置為 capacity氯窍。

clear 方法使用場景:

  • 在一個已經(jīng)寫滿數(shù)據(jù)的 buffer 中饲常,調(diào)用 clear,可以從頭讀取 buffer 的數(shù)據(jù)狼讨;
  • 為了將一個 buffer 填充滿數(shù)據(jù)贝淤,可以調(diào)用 clear,然后一直寫入政供,直到達(dá)到 limit播聪。

示例:

IntBuffer intBuffer = IntBuffer.allocate(2);
intBuffer.flip();
System.err.println("position: " + intBuffer.position());
System.err.println("limit: " + intBuffer.limit());
System.err.println("capacity: " + intBuffer.capacity());

// 這里不能讀, 因為 limit == position == 0, 沒有數(shù)據(jù).
//System.err.println(intBuffer.get());

intBuffer.clear();
System.err.println("position: " + intBuffer.position());
System.err.println("limit: " + intBuffer.limit());
System.err.println("capacity: " + intBuffer.capacity());

// 這里可以讀取數(shù)據(jù)了, 因為 clear 后, limit == capacity == 2, position == 0,
// 即使我們沒有寫入任何的數(shù)據(jù)到 buffer 中.
System.err.println(intBuffer.get()); // 讀取到0
System.err.println(intBuffer.get()); // 讀取到0

Buffer 的比較

我們可以通過 equals() 或 compareTo() 方法比較兩個 Buffer,當(dāng)且僅當(dāng)如下條件滿足時布隔,兩個 Buffer 是相等的:

  • 兩個 Buffer 是相同類型的
  • 兩個 Buffer 的剩余的數(shù)據(jù)個數(shù)是相同的
  • 兩個 Buffer 的剩余的數(shù)據(jù)都是相同的.

通過上述條件我們可以發(fā)現(xiàn)离陶,比較兩個 Buffer 時,并不是 Buffer 中的每個元素都進(jìn)行比較衅檀,而是比較 Buffer 中剩余的元素枕磁。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市术吝,隨后出現(xiàn)的幾起案子计济,更是在濱河造成了極大的恐慌,老刑警劉巖排苍,帶你破解...
    沈念sama閱讀 218,546評論 6 507
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件沦寂,死亡現(xiàn)場離奇詭異,居然都是意外死亡淘衙,警方通過查閱死者的電腦和手機传藏,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,224評論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人毯侦,你說我怎么就攤上這事哭靖。” “怎么了侈离?”我有些...
    開封第一講書人閱讀 164,911評論 0 354
  • 文/不壞的土叔 我叫張陵试幽,是天一觀的道長。 經(jīng)常有香客問我卦碾,道長铺坞,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 58,737評論 1 294
  • 正文 為了忘掉前任洲胖,我火速辦了婚禮济榨,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘绿映。我一直安慰自己擒滑,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 67,753評論 6 392
  • 文/花漫 我一把揭開白布叉弦。 她就那樣靜靜地躺著橘忱,像睡著了一般。 火紅的嫁衣襯著肌膚如雪卸奉。 梳的紋絲不亂的頭發(fā)上钝诚,一...
    開封第一講書人閱讀 51,598評論 1 305
  • 那天,我揣著相機與錄音榄棵,去河邊找鬼凝颇。 笑死,一個胖子當(dāng)著我的面吹牛疹鳄,可吹牛的內(nèi)容都是我干的拧略。 我是一名探鬼主播,決...
    沈念sama閱讀 40,338評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼瘪弓,長吁一口氣:“原來是場噩夢啊……” “哼垫蛆!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起腺怯,我...
    開封第一講書人閱讀 39,249評論 0 276
  • 序言:老撾萬榮一對情侶失蹤袱饭,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后呛占,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體虑乖,經(jīng)...
    沈念sama閱讀 45,696評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,888評論 3 336
  • 正文 我和宋清朗相戀三年晾虑,在試婚紗的時候發(fā)現(xiàn)自己被綠了疹味。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片仅叫。...
    茶點故事閱讀 40,013評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖糙捺,靈堂內(nèi)的尸體忽然破棺而出诫咱,到底是詐尸還是另有隱情,我是刑警寧澤洪灯,帶...
    沈念sama閱讀 35,731評論 5 346
  • 正文 年R本政府宣布坎缭,位于F島的核電站,受9級特大地震影響婴渡,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜凯亮,卻給世界環(huán)境...
    茶點故事閱讀 41,348評論 3 330
  • 文/蒙蒙 一边臼、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧假消,春花似錦柠并、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,929評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至啃沪,卻和暖如春粘拾,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背创千。 一陣腳步聲響...
    開封第一講書人閱讀 33,048評論 1 270
  • 我被黑心中介騙來泰國打工缰雇, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人追驴。 一個月前我還...
    沈念sama閱讀 48,203評論 3 370
  • 正文 我出身青樓械哟,卻偏偏與公主長得像,于是被迫代替她去往敵國和親殿雪。 傳聞我的和親對象是個殘疾皇子暇咆,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 44,960評論 2 355

推薦閱讀更多精彩內(nèi)容