如何測(cè)試FileChannel結(jié)合MappedByteBuffer往文件中寫入數(shù)據(jù)

本篇內(nèi)容主要講解“如何測(cè)試FileChannel結(jié)合MappedByteBuffer往文件中寫入數(shù)據(jù)”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“如何測(cè)試FileChannel結(jié)合MappedByteBuffer往文件中寫入數(shù)據(jù)”吧!

FileChannel結(jié)合ByteBuffer測(cè)試

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結(jié)合ByteBuffer測(cè)試

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;
    }

}

到此，相信大家對(duì)“如何測(cè)試FileChannel結(jié)合MappedByteBuffer往文件中寫入數(shù)據(jù)”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！