如何測試FileChannel結合MappedByteBuffer往文件中寫入數據

本篇內容主要講解“如何測試FileChannel結合MappedByteBuffer往文件中寫入數據”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“如何測試FileChannel結合MappedByteBuffer往文件中寫入數據”吧!

FileChannel結合ByteBuffer測試

package com;

import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

/**
 * FileChannel Test
 *
 * @author Dale
 * @date 2019/10/23
 */
public class FileChannelTest{

    static ByteBuffer writeBuffer = ByteBuffer.allocate(9);
    static Integer wrotePosition = 0;
    static Integer committedPosition = 0;
    static FileChannel fileChannel = null;

    static {
        try {
            RandomAccessFile randomAccessFile = new RandomAccessFile("d://test.log", "rw");
            fileChannel = randomAccessFile.getChannel();
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    public static void main(String[] args) throws Exception{

        appendData("1234");
        commit();

        appendData("567");
        commit();

        appendData("89");
        commit();

        //fileChannel.force(false);
    }

    public static void appendData(String msg) throws Exception{
        int msgLen = msg.length();

        ByteBuffer byteBuffer = writeBuffer.slice();
        byteBuffer.position(wrotePosition);

        ByteBuffer msgStoreItemMemory = ByteBuffer.allocate(msgLen);
        msgStoreItemMemory.put(msg.getBytes("UTF-8"));
        byteBuffer.put(msgStoreItemMemory.array(), 0, msgLen);
        wrotePosition = wrotePosition + msgLen;
    }

    public static void commit() throws Exception{
        ByteBuffer byteBuffer = writeBuffer.slice();
        byteBuffer.position(committedPosition);
        byteBuffer.limit(wrotePosition);
        fileChannel.position(committedPosition);
        fileChannel.write(byteBuffer);
        committedPosition = wrotePosition;
    }

}

MappedByteBuffer結合ByteBuffer測試

package com;

import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

/**
 * MappedByteBuffer Test
 *
 * @author Dale
 * @date 2019/10/23
 */
public class MappedByteBufferTest {

    static ByteBuffer writeBuffer = ByteBuffer.allocate(9);
    static Integer wrotePosition = 0;
    static Integer committedPosition = 0;
    static FileChannel fileChannel = null;
    static MappedByteBuffer mappedByteBuffer;

    static {
        try {
            RandomAccessFile randomAccessFile = new RandomAccessFile("d://test.log", "rw");
            fileChannel = randomAccessFile.getChannel();
            mappedByteBuffer = fileChannel.map(FileChannel.MapMode.READ_WRITE, 0, 9);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    public static void main(String[] args) throws Exception{

        appendData("1234");

        appendData("567");

        appendData("89");

        //mappedByteBuffer.force();
    }

    public static void appendData(String msg) throws Exception{
        int msgLen = msg.length();

        ByteBuffer byteBuffer = mappedByteBuffer.slice();
        byteBuffer.position(wrotePosition);

        ByteBuffer msgStoreItemMemory = ByteBuffer.allocate(msgLen);
        msgStoreItemMemory.put(msg.getBytes("UTF-8"));
        byteBuffer.put(msgStoreItemMemory.array(), 0, msgLen);
        wrotePosition = wrotePosition + msgLen;
    }

}

到此，相信大家對“如何測試FileChannel結合MappedByteBuffer往文件中寫入數據”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！