通过/dev/shm执行Java IPC的正确方式是什么(具有尽可能低的延迟)

我正在尝试通过/dev/shm编写IPC解决方案。

@SK-logic在这里的评论中给了我一些指示:Chronicle: How to optimize memory-mapped files for low-latency?

我的疑问是:我应该使用MappedByteBuffer还是只使用普通的FileChannel

通过MappedByteBuffer,我可以使用sun.misc.Unsafe并可以直接访问内存。这很棒,因为Unsafe提供了像getLongVolatile(除了getLong)和putLongVolatile(除了putLong)这样的方法。如果我使用普通的FileChannel,这可能吗?如何避免从FileChannel读取FileChannel从CPU缓存中读取缓存数据?对于/dev/shm中的易失性读写,我是否必须在操作系统中配置某些内容?什么?哪里?如何?:)

通过/dev/shm执行Java IPC的正确方式是什么?普通文件频道?MappdByteBuffer?

下面我如何通过sun.misc.Unsafe获取指向内存的指针:

    try {
        this.raf = new RandomAccessFile(file, "rw");
        this.fileChannel = raf.getChannel();
        this.mappedBuffer = this.fileChannel.map(MapMode.READ_WRITE, 0, size);
    } catch (Exception e) {
        throw new RuntimeException("Could not mmap file to memory: " + filename + " " + size, e);
    }
    
    try {
        addressField = Buffer.class.getDeclaredField("address");
        addressField.setAccessible(true);
        this.pointer = (long) addressField.get(this.mappedBuffer);
    } catch(Exception e) {
        throw new RuntimeException("Could not get off-heap pointer!", e);
    }

解决方案

历史记录队列使用Unsafe对堆和直接内存进行线程安全内存访问。

虽然这是可行的,但JVM并不保证系统将如何运行。我们在Intel X64、AMD和ARM处理器上进行测试。

与其自己编写所有这些内容,为什么不尝试使用编年史地图或队列来为您完成这些工作呢?

相关文章