Java MemoryMapped文件的功能

在JDK 1.4中，將內存映射文件的有趣功能添加到Java中，該功能允許將任何文件映射到OS內存以進行有效讀取。 內存映射文件可用于開發(fā)IPC類型的解決方案。 本文是使用內存映射文件創(chuàng)建IPC的實驗。

有關內存映射文件的一些詳細信息，來自WIKI的定義

內存映射文件是虛擬內存的一部分，已為其分配了與文件或類文件資源的某些部分直接的逐字節(jié)關聯(lián)。 此資源通常是物理上存在于磁盤上的文件，但也可以是設備，共享內存對象或操作系統(tǒng)可以通過文件描述符引用的其他資源。 一旦存在，文件和內存空間之間的這種關聯(lián)關系允許應用程序將映射的部分當作主內存一樣對待。

樣例程序

下面我們有兩個Java程序，一個是作者，另一個是讀者。 寫入者是生產者，嘗試寫入“內存映射”文件，讀取者是使用者，它從內存映射文件中讀取消息。 這只是一個示例程序，向您展示了這個想法，它不能處理許多極端情況，但足以在內存映射文件的頂部構建內容。

MemoryMapWriter

import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.RandomAccessFile; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel;public class MemoryMapWriter {public static void main(String[] args) throws FileNotFoundException, IOException, InterruptedException {File f = new File("c:/tmp/mapped.txt");f.delete();FileChannel fc = new RandomAccessFile(f, "rw").getChannel();long bufferSize=8*1000;MappedByteBuffer mem =fc.map(FileChannel.MapMode.READ_WRITE, 0, bufferSize);int start = 0;long counter=1;long HUNDREDK=100000;long startT = System.currentTimeMillis();long noOfMessage = HUNDREDK * 10 * 10; for(;;){ if(!mem.hasRemaining()){start+=mem.position();mem =fc.map(FileChannel.MapMode.READ_WRITE, start, bufferSize);}mem.putLong(counter); counter++;if(counter > noOfMessage )break; }long endT = System.currentTimeMillis();long tot = endT - startT;System.out.println(String.format("No Of Message %s , Time(ms) %s ",noOfMessage, tot)) ; }}

MemoryMapReader

import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.RandomAccessFile; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel;public class MemoryMapReader {/*** @param args* @throws IOException * @throws FileNotFoundException * @throws InterruptedException */public static void main(String[] args) throws FileNotFoundException, IOException, InterruptedException {FileChannel fc = new RandomAccessFile(new File("c:/tmp/mapped.txt"), "rw").getChannel();long bufferSize=8*1000;MappedByteBuffer mem = fc.map(FileChannel.MapMode.READ_ONLY, 0, bufferSize);long oldSize=fc.size();long currentPos = 0;long xx=currentPos;long startTime = System.currentTimeMillis();long lastValue=-1;for(;;){while(mem.hasRemaining()){lastValue=mem.getLong();currentPos +=8;}if(currentPos < oldSize){xx = xx + mem.position();mem = fc.map(FileChannel.MapMode.READ_ONLY,xx, bufferSize);continue; }else{long end = System.currentTimeMillis();long tot = end-startTime;System.out.println(String.format("Last Value Read %s , Time(ms) %s ",lastValue, tot));System.out.println("Waiting for message");while(true){long newSize=fc.size();if(newSize>oldSize){oldSize = newSize;xx = xx + mem.position();mem = fc.map(FileChannel.MapMode.READ_ONLY,xx , oldSize-xx);System.out.println("Got some data");break;}} }}}}

觀察

使用內存映射文件對于開發(fā)進程間通信可能是一個很好的選擇，對于生產者和消費者而言，吞吐量也相當不錯。 由生產者和消費者共同運行的性能統(tǒng)計信息：

每條消息是一個長號

產生– 1000萬條消息– 16個

消費者– 1000萬條消息0.6（s）

一條非常簡單的消息用于說明您的想法，但是它可以是任何類型的復雜消息，但是當存在復雜的數(shù)據結構時，序列化會增加開銷。 有許多技術可以克服這些開銷。 下一個博客中的更多內容。

參考：來自Java的JCG合作伙伴 Ashkrit Sharma 的Java MemoryMapped File的功能，在Are you ready博客上。

翻譯自: https://www.javacodegeeks.com/2013/05/power-of-java-memorymapped-file.html

總結

以上是生活随笔為你收集整理的Java MemoryMapped文件的功能的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。