Thinking in java(内存映射文件)

在处理大文件时,若是利用普通的FileInputStream 或者FileOutputStream 抑或RandomAccessFile 来进行频繁的读写操做,都将致使进程因频繁读写外存而下降速度.以下为一个对比实验。java

package test;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class Test {

	
	public static void main(String[] args) {
		try {
			FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			try {
				while((n=fis.read())>=0){
					sum+=n;
				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		try {
			FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");
			BufferedInputStream bis=new BufferedInputStream(fis);
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			try {
				while((n=bis.read())>=0){
					sum+=n;
				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		MappedByteBuffer buffer=null;
		try {
			buffer=new RandomAccessFile("/home/tobacco/test/res.txt","rw").getChannel().map(FileChannel.MapMode.READ_WRITE, 0, 1253244);
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			for(int i=0;i<1253244;i++){
				n=0x000000ff&buffer.get(i);
				sum+=n;
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}

    测试文件为一个大小为1253244字节的文件。测试结果:数组

sum:220152087  time:1464
sum:220152087  time:72
sum:220152087  time:25
app

    说明读数据无误。删去其中的数据处理部分。dom

package test;

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class Test {

	
	public static void main(String[] args) {
		try {
			FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			try {
				while((n=fis.read())>=0){
					//sum+=n;
				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		try {
			FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");
			BufferedInputStream bis=new BufferedInputStream(fis);
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			try {
				while((n=bis.read())>=0){
					//sum+=n;
				}
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		MappedByteBuffer buffer=null;
		try {
			buffer=new RandomAccessFile("/home/tobacco/test/res.txt","rw").getChannel().map(FileChannel.MapMode.READ_WRITE, 0, 1253244);
			int sum=0;
			int n;
			long t1=System.currentTimeMillis();
			for(int i=0;i<1253244;i++){
				//n=0x000000ff&buffer.get(i);
				//sum+=n;
			}
			long t=System.currentTimeMillis()-t1;
			System.out.println("sum:"+sum+"  time:"+t);
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

}


    测试结果:学习

sum:0  time:1458
sum:0  time:67
sum:0  time:8
测试

    因而可知,将文件部分或者所有映射到内存后进行读写,速度将提升不少。spa

    这是由于内存映射文件首先将外存上的文件映射到内存中的一块连续区域,被当成一个字节数组进行处理,读写操做直接对内存进行操做,然后再将内存区域从新映射到外存文件,这就节省了中间频繁的对外存进行读写的时间,大大下降了读写时间。code

Ps :该文章只是在本人学习中检索到的相对而言比较专业的文章,可是没有通过实践的验证。orm

相关文章
相关标签/搜索