Java学习者论坛

 找回密码
 立即注册

QQ登录

只需一步,快速开始

手机号码,快捷登录

恭喜Java学习者论坛(https://www.javaxxz.com)已经为数万Java学习者服务超过8年了!积累会员资料超过10000G+
成为本站VIP会员,下载本站10000G+会员资源,购买链接:点击进入购买VIP会员
JAVA高级面试进阶视频教程Java架构师系统进阶VIP课程

分布式高可用全栈开发微服务教程

Go语言视频零基础入门到精通

Java架构师3期(课件+源码)

Java开发全终端实战租房项目视频教程

SpringBoot2.X入门到高级使用教程

大数据培训第六期全套视频教程

深度学习(CNN RNN GAN)算法原理

Java亿级流量电商系统视频教程

互联网架构师视频教程

年薪50万Spark2.0从入门到精通

年薪50万!人工智能学习路线教程

年薪50万!大数据从入门到精通学习路线年薪50万!机器学习入门到精通视频教程
仿小米商城类app和小程序视频教程深度学习数据分析基础到实战最新黑马javaEE2.1就业课程从 0到JVM实战高手教程 MySQL入门到精通教程
查看: 345|回复: 0

[JavaIO学习]Java nio中用内存映射处理大文件

[复制链接]
  • TA的每日心情
    开心
    2021-3-12 23:18
  • 签到天数: 2 天

    [LV.1]初来乍到

    发表于 2014-11-3 23:58:27 | 显示全部楼层 |阅读模式
    在处理大文件时,如果利用普通的FileInputStream 或者FileOutputStream 抑或RandomAccessFile 来进行频繁的读写操作,都将导致进程因频繁读写外存而降低速度.如下为一个对比实验。

    1. import java.io.BufferedInputStream;  
    2. import java.io.FileInputStream;  
    3. import java.io.FileNotFoundException;  
    4. import java.io.IOException;  
    5. import java.io.RandomAccessFile;  
    6. import java.nio.MappedByteBuffer;  
    7. import java.nio.channels.FileChannel;  
    8.   
    9. public class Test {  
    10.   
    11.       
    12.     public static void main(String[] args) {  
    13.         try {  
    14.             FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");  
    15.             int sum=0;  
    16.             int n;  
    17.             long t1=System.currentTimeMillis();  
    18.             try {  
    19.                 while((n=fis.read())>=0){  
    20.                     sum+=n;  
    21.                 }  
    22.             } catch (IOException e) {  
    23.                 // TODO Auto-generated catch block   
    24.                 e.printStackTrace();  
    25.             }  
    26.             long t=System.currentTimeMillis()-t1;  
    27.             System.out.println("sum:"+sum+"  time:"+t);  
    28.         } catch (FileNotFoundException e) {  
    29.             // TODO Auto-generated catch block   
    30.             e.printStackTrace();  
    31.         }  
    32.          
    33.         try {  
    34.             FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");  
    35.             BufferedInputStream bis=new BufferedInputStream(fis);  
    36.             int sum=0;  
    37.             int n;  
    38.             long t1=System.currentTimeMillis();  
    39.             try {  
    40.                 while((n=bis.read())>=0){  
    41.                     sum+=n;  
    42.                 }  
    43.             } catch (IOException e) {  
    44.                 // TODO Auto-generated catch block   
    45.                 e.printStackTrace();  
    46.             }  
    47.             long t=System.currentTimeMillis()-t1;  
    48.             System.out.println("sum:"+sum+"  time:"+t);  
    49.         } catch (FileNotFoundException e) {  
    50.             // TODO Auto-generated catch block   
    51.             e.printStackTrace();  
    52.         }  
    53.          
    54.         MappedByteBuffer buffer=null;  
    55.         try {  
    56.             buffer=new RandomAccessFile("/home/tobacco/test/res.txt","rw").getChannel().
    57.                           map(FileChannel.MapMode.READ_WRITE, 0, 1253244);  
    58.             int sum=0;  
    59.             int n;  
    60.             long t1=System.currentTimeMillis();  
    61.             for(int i=0;i< 1253244;i++){  
    62.                 n=0x000000ff&buffer.get(i);  
    63.                 sum+=n;  
    64.             }  
    65.             long t=System.currentTimeMillis()-t1;  
    66.             System.out.println("sum:"+sum+"  time:"+t);  
    67.         } catch (FileNotFoundException e) {  
    68.             // TODO Auto-generated catch block   
    69.             e.printStackTrace();  
    70.         } catch (IOException e) {  
    71.             // TODO Auto-generated catch block   
    72.             e.printStackTrace();  
    73.         }  
    74.   
    75.     }  
    76.   
    77. }  
    复制代码
    测试文件为一个大小为1253244字节的文件。测试结果: sum:220152087 time:1464
    sum:220152087 time:72
    sum:220152087 time:25
       说明读数据无误。删去其中的数据处理部分。
    1. import java.io.BufferedInputStream;  
    2. import java.io.FileInputStream;  
    3. import java.io.FileNotFoundException;  
    4. import java.io.IOException;  
    5. import java.io.RandomAccessFile;  
    6. import java.nio.MappedByteBuffer;  
    7. import java.nio.channels.FileChannel;  
    8.   
    9. public class Test1 {  
    10.   
    11.       
    12.     public static void main(String[] args) {  
    13.         try {  
    14.             FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");  
    15.             int sum=0;  
    16.             int n;  
    17.             long t1=System.currentTimeMillis();  
    18.             try {  
    19.                 while((n=fis.read())>=0){  
    20.                     //sum+=n;   
    21.                 }  
    22.             } catch (IOException e) {  
    23.                 // TODO Auto-generated catch block   
    24.                 e.printStackTrace();  
    25.             }  
    26.             long t=System.currentTimeMillis()-t1;  
    27.             System.out.println("sum:"+sum+"  time:"+t);  
    28.         } catch (FileNotFoundException e) {  
    29.             // TODO Auto-generated catch block   
    30.             e.printStackTrace();  
    31.         }  
    32.          
    33.         try {  
    34.             FileInputStream fis=new FileInputStream("/home/tobacco/test/res.txt");  
    35.             BufferedInputStream bis=new BufferedInputStream(fis);  
    36.             int sum=0;  
    37.             int n;  
    38.             long t1=System.currentTimeMillis();  
    39.             try {  
    40.                 while((n=bis.read())>=0){  
    41.                     //sum+=n;   
    42.                 }  
    43.             } catch (IOException e) {  
    44.                 // TODO Auto-generated catch block   
    45.                 e.printStackTrace();  
    46.             }  
    47.             long t=System.currentTimeMillis()-t1;  
    48.             System.out.println("sum:"+sum+"  time:"+t);  
    49.         } catch (FileNotFoundException e) {  
    50.             // TODO Auto-generated catch block   
    51.             e.printStackTrace();  
    52.         }  
    53.          
    54.         MappedByteBuffer buffer=null;  
    55.         try {  
    56.             buffer=new RandomAccessFile("/home/tobacco/test/res.txt","rw").getChannel().
    57.                           map(FileChannel.MapMode.READ_WRITE, 0, 1253244);  
    58.             int sum=0;  
    59.             int n;  
    60.             long t1=System.currentTimeMillis();  
    61.             for(int i=0;i< 1253244;i++){  
    62.                 //n=0x000000ff&buffer.get(i);   
    63.                 //sum+=n;   
    64.             }  
    65.             long t=System.currentTimeMillis()-t1;  
    66.             System.out.println("sum:"+sum+"  time:"+t);  
    67.         } catch (FileNotFoundException e) {  
    68.             // TODO Auto-generated catch block   
    69.             e.printStackTrace();  
    70.         } catch (IOException e) {  
    71.             // TODO Auto-generated catch block   
    72.             e.printStackTrace();  
    73.         }  
    74.   
    75.     }  
    76.   
    77. }  
    复制代码
    测试结果: sum:0 time:1458
    sum:0 time:67
    sum:0 time:8
       由此可见,将文件部分或者全部映射到内存后进行读写,速度将提高很多。  这是因为内存映射文件首先将外存上的文件映射到内存中的一块连续区域,被当成一个字节数组进行处理,读写操作直接对内存进行操作,而后再将内存区域重新映射到外存文件,这就节省了中间频繁的对外存进行读写的时间,大大降低了读写时间。
       
         
         
          
          

            
          

            
          
         
       

      


    源码下载:http://file.javaxxz.com/2014/11/3/235827546.zip
    回复

    使用道具 举报

    您需要登录后才可以回帖 登录 | 立即注册

    本版积分规则

    QQ|手机版|Java学习者论坛 ( 声明:本站资料整理自互联网,用于Java学习者交流学习使用,对资料版权不负任何法律责任,若有侵权请及时联系客服屏蔽删除 )

    GMT+8, 2025-2-25 13:54 , Processed in 0.340402 second(s), 34 queries .

    Powered by Discuz! X3.4

    © 2001-2017 Comsenz Inc.

    快速回复 返回顶部 返回列表