MappedByteBuffer以及ByteBufer的底层原理

Love The Way You Lie 2022-12-26 09:19 125阅读 0赞

最近在用java中的ByteBuffer，一直不明所以，尤其是对MappedByteBuffer使用的内存映射这个概念云里雾里。

于是首先补了物理内存、虚拟内存、页面内存、交换区的知识:[小科普——物理内存、页面文件、交换区和虚拟内存][Link 1]

然后阅读了ByteBuffer的文章：[ByteBuffer使用和实现以及文件内存映射][ByteBuffer]。

ByteBuffer分为两种:间接地和直接的，所谓直接就是指MappedByteBuffer,直接使用内存映射（java的话就意味着在JVM之外分配虚拟地址空间）;而间接的ByteBuffer是在JVM的堆上面的，说白了就是管理一群byte数组的包装。

这里面最核心最关键的也就是内存映射了，下面的内容来自这篇文件:内存映射文件原理探索

# 原理 #

首先，“映射”这个词，就和数学课上说的“一一映射”是一个意思，就是建立一种一一对应关系，在这里主要是指硬盘上文件的位置与进程逻辑地址空间中一块大小相同的区域之间的一一对应，如图1中过程1所示。这种对应关系纯属是逻辑上的概念，物理上是不存在的，原因是进程的逻辑地址空间本身就是不存在的。在内存映射的过程中，并没有实际的数据拷贝，文件没有被载入内存，只是逻辑上被放入了内存，具体到代码，就是建立并初始化了相关的数据结构(struct address\_space),这个过程有系统调用mmap()实现，所以建立内存映射的效率很高。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nZ2UzNjYz_size_16_color_FFFFFF_t_70][]

图1.内存映射原理

既然建立内存映射没有进行实际的数据拷贝，那么进程又怎么能最终直接通过内存操作访问到硬盘上的文件呢?那就要看内存映射之后的几个相关的过程了。

mmap()会返回一个指针ptr,它指向进程逻辑地址空间中的一个地址，这样以后进程无需再调用read或write对文件进行读写，而只需要通过ptr就能够操作文件。但是ptr所指向的是一个逻辑地址，要操作其中的数据，必须通过MMU将逻辑地址转换成物理地址，如图1中过程2所示。这个过程与内存映射无关。

前面讲过，建立内存映射并没有实际拷贝数据，这时，MMU在地址映射表中是无法找到与ptr相对应的物理地址的，也就是MMU失败，将产生一个缺页中断，缺页中断的中断响应函数会在swap中寻找相对应的页面，如果找不到(也就是该文件从来没有被读入内存的情况),则会通过mmap()建立的映射关系，从硬盘上将文件读取到物理内存中，如图1中过程3所示。这个过程与内存映射无关。

如果在拷贝数据时，发现物理内存不够用，则会通过虚拟内存机制(swap)将暂时不用的物理页面交换到硬盘上，如图1中过程4所示。这个过程也与内存映射无关。

# 效率 #

从代码层面上看，从硬盘上将文件读入内存，都要经过文件系统进行数据拷贝，并且数据拷贝操作是由文件系统和硬件驱动实现的，理论上来说，拷贝数据的效率是一样的。但是通过内存映射的访问访问硬盘上的文件，效率要比read和write系统调用高，这是为什么呢?原因是read()是系统调用，其中进行了数据拷贝到用户空间，如图2中过程2,在这个过程中，实际上完成了两次数据拷贝;而mmap()也是系统调用，如前所述，mmap()中没有进行数据拷贝，真正的数据拷贝是在缺页中断处理时进行的，由于mmap()将文件直接映射到用户空间，所以中断处理函数根据这个映射关系，直接将文件从硬盘拷贝到用户空间，只进行了一次数据拷贝。因此，内存映射的效率要比read/write效率高。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nZ2UzNjYz_size_16_color_FFFFFF_t_70 1][]

图2.read系统调用原理

下面这个程序，通过read和mmap两种方法分别对硬盘上一个名为"mmap\_test"的文件进行操作，文件中存有10000个证书，程序两次使用不同的方法将它们读出，加1，再写回硬盘。通过对比可以看出，read消耗的时间将近是mmap的两到三倍。

#include <unistd.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <string.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <sys/time.h>
    #include <fcntl.h>
    #include <sys/mman.h>
    
    #define MAX 10000
    
    int main() {
        int i=0;
        int count=0, fd=0;
        struct timeval tv1, tv2;
        int *array = (int *)malloc(sizeof(int)*MAX);
    
        /*read*/
        gettimeofday(&tv1, NULL);
        fd = open("mman_test", O_RDWR);
        if (sizeof(int)*MAX != read(fd, (void *)array, sizeof(int)*MAX)) {
            printf("Reading data filed.../n");
            return -1;
        }
        for (i=0; i<MAX; ++i) {
            ++array[i];
        }
        if (sizeof(int)*MAX != write(fd, (void *)array, sizeof(int)*MAX)) {
            printf("Writing data failed.../n");
            return -1;
        }
        free(array);
        close(fd);
        gettimeofday(&tv2, NULL);
        printf("Time of read/write: %dms\n", tv2.tv_usec-tv1.tv_usec);
    
        /*mmap*/
        gettimeofday(&tv1, NULL);
        fd = open("mmap_test", O_RDWR);
        array = mmap(NULL, sizeof(int)*MAX, PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0);
        for (i=0; i<MAX; ++i) {
            ++array[i];
        }
        munmap(array, sizeof(int)*MAX);
        msync(array, sizeof(int)*MAX, MS_SYNC);
        free(array);
        close(fd);
        gettimeofday(&tv2, NULL);
        printf("Time of mmap: %dms\n", tv2.tv_usec - tv1.tv_usec);
        return 0;
    }

输出结果:

Time of read/write: 154ms

Time of mmap: 68ms

[Link 1]: http://www.guokr.com/blog/62218/
[ByteBuffer]: http://www.molotang.com/articles/997.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nZ2UzNjYz_size_16_color_FFFFFF_t_70]: /images/20221120/867452446a0e44069f9efd8ae1c4f9db.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nZ2UzNjYz_size_16_color_FFFFFF_t_70 1]: /images/20221120/f5633e29e31f42ec8378da312d3a8cb4.png