JAVA NIO文件映射、通道、流读写文件示例

本例使用FileChannel和 BufferedInputStream等测试对比。

TestHandler.java 用于实现动态代理，测试运行效率

package com.test;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

public class TestHandler implements InvocationHandler{

private Object obj=null;

public TestHandler(Object obj){
this.obj=obj;
}

public static Object newInstance(Object obj){
Object result=Proxy.newProxyInstance(obj.getClass().getClassLoader(),
obj.getClass().getInterfaces(), new TestHandler(obj));
return result;
}

@Override
public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
Object result=null;
System.out.println("执行中...");

long start=System.currentTimeMillis();
result=method.invoke(obj, args);

long end=System.currentTimeMillis();
System.out.println("执行完成，耗时："+(end-start));

return result;
}

}

INIOTest.java

package com.test;

import java.io.IOException;

public interface INIOTest{
public void copyFileMapped(String oldPath,String newPath)  throws IOException;
public void copyFileNIO(String oldPath,String newPath)  throws IOException;
public void copyFile(String oldPath,String newPath)  throws IOException;
}

Test.java

package com.test;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.ByteBuffer;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;

public class Test implements INIOTest{
public void copyFileMapped(String oldPath,String newPath)  throws IOException{
long length=0;
RandomAccessFile raf=new RandomAccessFile(oldPath , "r");
FileChannel fcr=raf.getChannel();
length=fcr.size();
//返回要读取文件的映射内存区块
MappedByteBuffer mbb=fcr.map(FileChannel.MapMode.READ_ONLY, 0, length);
ByteBuffer buffer=mbb.get(new byte[(int)length]);

//要写入的文件
RandomAccessFile raw=new RandomAccessFile(newPath, "rw");
FileChannel fcw=raw.getChannel();
MappedByteBuffer mbbw=fcw.map(FileChannel.MapMode.READ_WRITE, 0, length);
for(int i=0;i<length;i++){
mbbw.put(i,buffer.get(i));
}
fcw.close();
fcr.close();
raf.close();
raw.close();
/**
* MappedByteBuffer是java平台共享内存的实现，把硬盘虚拟为内存，
* 主要用于进程间共享数据，所以在进程没有退出前文件是不允许删除的。
* 一个映射的字节缓冲区和文件映射，它代表仍然有效，直到缓冲本身是垃圾收集。
*/
raf=null;
raw=null;
System.gc();
try {
//等待垃圾回收
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}

}
public void copyFileNIO(String oldPath,String newPath) throws IOException{
FileInputStream fis=new FileInputStream(oldPath);
FileOutputStream fos=new FileOutputStream(newPath);
//获取输入输出通道
FileChannel fcin=fis.getChannel();
FileChannel fout=fos.getChannel();
//创建缓冲区
ByteBuffer buffer=ByteBuffer.allocate(1024);
while(true){
//clear方法重设缓冲区，使它可以接受读入的数据
buffer.clear();
int len=fcin.read(buffer);
if(len==-1){

break;
}
//写模式转换成读模式。该限制设置为当前的位置然后位置设置为零。如果标记定义然后丢弃。
//flip方法让缓冲区可以将新读入的数据写入另一个通道
buffer.flip();
fout.write(buffer);
}
fcin.close();
fout.close();
}

public void copyFile(String oldPath,String newPath) throws IOException{
FileInputStream fis=new FileInputStream(oldPath);
FileOutputStream fos=new FileOutputStream(newPath);

BufferedInputStream bis=new BufferedInputStream(fis);
BufferedOutputStream bos=new BufferedOutputStream(fos);
byte[] buffer=new byte[1024];

int len=0;
while((len=bis.read(buffer))!=-1){
bos.write(buffer,0,buffer.length);
}
bis.close();
bos.close();
}
public static void main(String agrs[]){

INIOTest test1=(INIOTest)TestHandler.newInstance(new Test());
try {
test1.copyFileMapped("D:\\upan\\VC++6.0简体中文版.rar","D:\\VC++6.0简体中文版.rar");
test1.copyFileNIO("D:\\upan\\VC++6.0简体中文版.rar","D:\\VC++6.0简体中文版.rar");
test1.copyFile("D:\\upan\\VC++6.0简体中文版.rar","D:\\VC++6.0简体中文版.rar");
} catch (IOException e) {
// TODO 自动生成的 catch 块
e.printStackTrace();
}

}

}

第一个为使用文件映射读写耗时

第二个为文件通道（Channel）读写文件耗时

第三个位BufferedInputStream等耗时

测试多次均是Channel，文件映射读写耗时较稳定，时间也比较短，BufferedInputStream时间也不错，和映射差不多（个人测试的是180M的文件，大文件建议还是使用文件映射可能好点）

特别需要注意的是文件映射无法关闭，MappedByteBuffer是java平台共享内存的实现，把硬盘虚拟为内存，主要用于进程间共享数据，所以在进程没有退出前文件是不允许删除的。也无法访问它。所以这里将它置为null，并等待垃圾回收它。

参考：http://yipsilon.iteye.com/blog/298153