private static void getFileContent(){
    // 輸入輸出流
    try(FileChannel channel = new FileInputStream("C:\Users\My\Desktop\learn\demo\demo\test.txt").getChannel()){
        // 準(zhǔn)備緩沖區(qū)
        ByteBuffer buffer = ByteBuffer.allocate(10);
        // 循環(huán)遍歷
        while(true){
            // 從 channel 讀取數(shù)據(jù), 向 buffer 寫(xiě)入
            int len = channel.read(buffer);
            if (len == -1){
                System.out.println("沒(méi)有內(nèi)容了");
                break;
            }
            // 打印 buffer 內(nèi)容
            // 切換至 讀模式
            buffer.flip();
            // 遍歷查看是否還有剩余未讀數(shù)據(jù)
            while(buffer.hasRemaining()){
                byte b = buffer.get();
                System.out.println(b);
            }
            // 切換為寫(xiě)模式
            buffer.clear();
        }
    }catch (Exception e){
        System.out.println("文件未找到");
    }
}

打印結(jié)果

test.txt文件內(nèi)容如下所示

接下來(lái)執(zhí)行上述代碼, 結(jié)果如下

可以看到打印出來(lái)的結(jié)果是 ASCII 編碼表的值，所以我們把輸出轉(zhuǎn)為 char 類(lèi)型，結(jié)果如下

Buffer

Buffer繼承自O(shè)bject類(lèi)，是基本類(lèi)型元素的線(xiàn)性有限序列（容器）。除內(nèi)容外，Buffer的基本屬性有：Limit—限制，Capacity—容量，Position—位置。對(duì)著三個(gè)變量操作，可以完成幾乎所有對(duì)Buffer的代碼操作。

今天開(kāi)始學(xué)習(xí) Netty ,那就繞不過(guò) NIO, 在 NIO 包下的 Buffer 有以下七種實(shí)現(xiàn):

ByteBuffer
ShortBuffer
FloatBuffer
CharBuffer
DoubleBuffer
IntBuffer
LongBuffer

實(shí)際上就是八種數(shù)據(jù)類(lèi)型的相關(guān) Buffer, 但是我只聽(tīng)說(shuō)過(guò) ByteBuffer, 也是使用最廣泛的, 至于為什么我也不知道, 希望以后有機(jī)會(huì)能過(guò)來(lái)填坑, 有大佬知道的話(huà)也可以評(píng)論區(qū)說(shuō)一下

ByteBuffer常用方法

在 java 中 ByteBuffer 的常用方法有以下七種:

put: 寫(xiě)入
get: 讀數(shù)據(jù)
flip: 切換讀模式
rewind: 重新重頭開(kāi)始讀
mark: 記錄當(dāng)前下標(biāo)
reset: 回到 mark 位置
clear: 切換寫(xiě)模式
compact: 切換寫(xiě)模式, 同時(shí)將未讀數(shù)據(jù)移動(dòng)到首部

工具方法 selectAll()

為了方便觀察當(dāng)前 ByteBuffer 所處的位置, 容量等信息, 寫(xiě)了下面這個(gè)方法

private static void selectAll(ByteBuffer buffer){
    System.out.println();
    int limit = buffer.limit();
    System.out.print("pos = " + buffer.position() + "     " + "lim = " + buffer.limit() + "     " + "cap = " + buffer.capacity());
    System.out.println();
    for (int i = 0; i < limit; i++) {
        if (i < 10){
            System.out.print(" |  ");
        }else{
            System.out.print(" | ");
        }
        System.out.print(i);
    }
    System.out.println();
    System.out.println("--------------------------------------------------------------------------");
    for (int i = 0; i < limit; i++) {
        byte b = buffer.get(i);
        System.out.print(" |  ");
        System.out.print((char) b);
        if (b == 0){
            System.out.print(0);
        }
    }
    System.out.println();
}

打印結(jié)果如下:

根據(jù)打印結(jié)果我們可以很直觀的看到當(dāng)前 ByteBuffer 每個(gè)下標(biāo)上的元素是什么, 同時(shí)也能看到當(dāng)前指針?biāo)幍奈恢?Position)

初始化

以下測(cè)試用例的 ByteBuffer 采用同一個(gè) ByteBuffer

ByteBuffer buffer = ByteBuffer.allocate(16);

buffer.put()

put 方法就是往 ByteBuffer 中寫(xiě)入數(shù)據(jù), 具體操作如下述代碼所示

private static void bufferPut(ByteBuffer buffer){
    buffer.put(new byte[]{'a', 'b', 'c', 'd'});
    selectAll(buffer);
    buffer.put(new byte[]{'1'});
    selectAll(buffer);
}

執(zhí)行結(jié)果如下:

圖中和代碼一樣, 是分兩次打印當(dāng)前 ByteBuffer 的內(nèi)容, pos 就是下一次寫(xiě)入的下標(biāo)

buffer.get()

get 方法是獲取元素的, 但是我們?nèi)绻趧倢?xiě)入之后就去讀取的話(huà), 是什么都讀取不到的, 具體如下所示

可以看到, 我們讀取出來(lái)當(dāng)前的元素為 0, 我們進(jìn)入源碼看一下 get 方法

如圖所示, 我們通過(guò) get 方法獲取到的元素都是當(dāng)前 pos 的下一個(gè)坐標(biāo)元素, 在之前的 put 方法中, 我們看到最后 pos 是指向了 5 是下一個(gè) 寫(xiě)入下標(biāo)

我們有兩種方法可以獲取到元素:

通過(guò)下標(biāo)獲取
將寫(xiě)入模式更改為讀模式

通過(guò)下標(biāo)獲取: 直接輸入下標(biāo)就可以獲取到了

buffer.flip()

flip 方法: 將讀模式轉(zhuǎn)換為寫(xiě)模式

還是剛才的例子, 使用方法 buffer.flip() 之后, 可以看到 pos 變成了 1, lim 變成了 5 , cap 不變

這里 pos 代表的是下一個(gè) get 的下標(biāo), lim 代表的是當(dāng)前的長(zhǎng)度

注意: 在調(diào)用 flip 進(jìn)入讀模式之后，后續(xù)如果調(diào)用 get() 導(dǎo)致 position 大于等于了 limit 的值，程序會(huì)拋出 BufferUnderflowException 異常。這點(diǎn)從之前 get 的源碼也可以看出來(lái)。

buffer.rewind()

rewind 方法可以理解為下標(biāo)歸零, 也可以理解為重新開(kāi)始, 重頭開(kāi)始. 代碼展示如下所示

我們點(diǎn)進(jìn)源代碼也可以看到, 它實(shí)際上就是將 pos 賦值了 0, 將 mark 賦值為 -1

buffer.mark() & buffer.reset()

這里將 mark 方法和 reset 方法一起講, 他倆是相輔相成的一個(gè)關(guān)系, 二者缺一不可
mark 方法標(biāo)記當(dāng)前下標(biāo), reset 回到 mark 標(biāo)記的下標(biāo)

可以看到, 當(dāng)我們執(zhí)行 mark 方法的時(shí)候記錄了當(dāng)前的下標(biāo), 執(zhí)行 reset 方法的時(shí)候 pos 又更改為了 1

buffer.clear() & buffer.compact()

clear 方法和 compact 方法都是對(duì)當(dāng)前 ByteBuffer 寫(xiě)入 , clear 方法是從頭開(kāi)始寫(xiě)入, compact 方法是將未讀內(nèi)容移至頭部然后再寫(xiě)入

可以看到, 在執(zhí)行完 clear 方法之后, 新增的元素是從下標(biāo) 0 開(kāi)始寫(xiě)入的

可以看到, 在執(zhí)行完 compact 方法之后, 它先是將沒(méi)有讀取到的數(shù)據(jù)放置頭部, 在接下來(lái) put 的時(shí)候?qū)竺娴膬?nèi)容進(jìn)行了一個(gè)覆蓋

全部代碼

import java.io.FileInputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
/**
 * @Author ningxuan
 * @Date 2022/10/31 21:28
 */
public class ByteBufferTest {
    public static void main(String[] args) {
        // 讀文件案例
//        getFileContent();
        // 初始化 ByteBuffer
        ByteBuffer buffer = ByteBuffer.allocate(16);
        // 寫(xiě)測(cè)試
        bufferPut(buffer);  // a , b , c , d, 1
        bufferGet(buffer);
        buffer.flip();
//        System.out.println((char) buffer.get());    // a    pos == 0
//        System.out.println((char)buffer.get());     // b    pos == 1
//        buffer.rewind();
//        System.out.println((char)buffer.get());     // c    pos == 0
//        System.out.println((char)buffer.get());     // d    pos == 1
//        bufferMarkTest(buffer);
        bufferCompact(buffer);
    }
    private static void bufferCompact(ByteBuffer buffer){
        selectAll(buffer);
        buffer.get();
        buffer.get();
        selectAll(buffer);
        buffer.compact();
        selectAll(buffer);
        buffer.put(new byte[]{'e', 'h'});
        selectAll(buffer);
    }
    private static void bufferClear(ByteBuffer buffer){
        selectAll(buffer);
        System.out.println();
        buffer.clear();
        buffer.put(new byte[]{'e', 'h'});
        selectAll(buffer);
    }
    private static void bufferMarkTest(ByteBuffer buffer){
        byte b;
        b = buffer.get();   // a
        System.out.println((char) b);
        buffer.mark();
        System.out.println("position = " + buffer.position());
        b = buffer.get();   // b
        System.out.println((char) b);
        b = buffer.get();   // c
        System.out.println((char) b);
        buffer.reset();
        System.out.println("position = " + buffer.position());
        b = buffer.get();   // b
        System.out.println((char) b);
        b = buffer.get();   // c
        System.out.println((char) b);
    }
    private static void bufferGet(ByteBuffer buffer){
        byte b = buffer.get(0);
//        System.out.println((char)b);
        b = buffer.get(1);
//        System.out.println((char)b);
    }
    private static void bufferPut(ByteBuffer buffer){
        buffer.put(new byte[]{'a', 'b', 'c', 'd'});
//        selectAll(buffer);
        buffer.put(new byte[]{'1'});
//        selectAll(buffer);
    }
    private static void selectAll(ByteBuffer buffer){
        System.out.println();
        int limit = buffer.limit();
        System.out.print("pos = " + buffer.position() + "     " + "lim = " + buffer.limit() + "     " + "cap = " + buffer.capacity());
        System.out.println();
        for (int i = 0; i < limit; i++) {
            if (i < 10){
                System.out.print(" |  ");
            }else{
                System.out.print(" | ");
            }
            System.out.print(i);
        }
        System.out.println();
        System.out.println("--------------------------------------------------------------------------");
        for (int i = 0; i < limit; i++) {
            byte b = buffer.get(i);
            System.out.print(" |  ");
            System.out.print((char) b);
            if (b == 0){
                System.out.print(0);
            }
        }
        System.out.println();
    }
    private static void getFileContent(){
        // 輸入輸出流
        try(FileChannel channel = new FileInputStream("C:\Users\My\Desktop\learn\demo\demo\test.txt").getChannel()){
            // 準(zhǔn)備緩沖區(qū)
            ByteBuffer buffer = ByteBuffer.allocate(10);
            // 循環(huán)遍歷
            while(true){
                // 從 channel 讀取數(shù)據(jù), 向 buffer 寫(xiě)入
                int len = channel.read(buffer);
                if (len == -1){
                    System.out.println("沒(méi)有內(nèi)容了");
                    break;
                }
                // 打印 buffer 內(nèi)容
                // 切換至 讀模式
                buffer.flip();
                // 遍歷查看是否還有剩余未讀數(shù)據(jù)
                while(buffer.hasRemaining()){
                    byte b = buffer.get();
                    System.out.println((char) b);
                }
                // 切換為寫(xiě)模式
                buffer.clear();
            }
        }catch (Exception e){
            System.out.println("文件未找到");
        }
    }
}

以上就是Java NIO下ByteBuffer的常用方法學(xué)習(xí)的詳細(xì)內(nèi)容，更多關(guān)于Java ByteBuffer的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: