今天刚学到RandomAccessFile类，听毕老师讲这个类可以实现下载软件的多线程下载，于是动手写了下面这段代码。
求指点~~{:soso_e106:}

1. /**
   
2. 需求：用RandomAccessFile模拟多线程下载数据。
   
3. 分析：1，将要下载文件和保存路径用File封装为对象file1和file2。
   
4.           2，线程中用RandomAccessFile seek方法确定开始的位置，读取file1中的数据，对应的file2写入数据。
   
5. */
   
6. import java.io.*;
   
7. class RandomAccessFileTest{
   
8.         public static void main(String[] args){
   
9.                 File file1 = new File("testfiles\\2.mp3");
   
10.                 File file2 = new File("testfiles\\1.mp3");
    
11.                 if(!file1.exists()){
    
12.                         throw new RuntimeException("文件不存在！");
    
13.                 }
    
14.                 long part =  file1.length()/1024/1024; //将文件按1MB分段。
    
15.                 DownLoading[] downLoadThread =new DownLoading[(int)part+1]; //创建一个线程数组，有几段就分配几个线程。
    
16.                 for(int x=0 ; x<=(int)part ; x++){
    
17.                         downLoadThread[x] = new DownLoading();
    
18.                         downLoadThread[x].setFile(file1,file2,x);
    
19.                         
    
20.                 }
    
21.                 for(DownLoading dlt:downLoadThread){
    
22.                         dlt.start();
    
23.                 }
    
24. 
    
25.         }
    
26. 
    
27. }
    
28. class DownLoading extends Thread{        
    
29.         /**
    
30.         @param file1 下载文件
    
31.         @param file2 保存路径
    
32.         @param pos 线程读写指针
    
33.         @author @yrom
    
34.         @version 1.0
    
35.         @date 2012-11-16
    
36.         */
    
37.         private File file1;
    
38.         private File file2;
    
39.         private long pos;
    
40. 
    
41.         //设置文件下载和保存路径已经每个线程读写的位置。
    
42.         public void setFile(File file1, File file2,int pos){
    
43.                 this.file1 = file1;
    
44.                 this.file2 = file2;
    
45.                 this.pos = (long)pos;
    
46.         }
    
47.         public void run(){
    
48.                 pos = 1024*1024*pos; //定义起始的字节数。
    
49.                 downloading(pos,file1,file2);
    
50.                 System.out.println(Thread.currentThread().getName()+"run.");
    
51.         }
    
52.         //下载方法
    
53.         private void downloading(long pos,File file1,File file2){
    
54.                 byte[] buf = new byte[1024*1024];  //以1MB为分段长度
    
55.                 try{
    
56.                 RandomAccessFile raf1 = new RandomAccessFile(file1,"rw");
    
57.                 RandomAccessFile raf2 = new RandomAccessFile(file2,"rw");
    
58.                 //设置分段开始位置。
    
59.                 raf1.seek(pos);
    
60.                 raf2.seek(pos);
    
61.                 //每个线程只读写1MB的数据。
    
62.                 int len = raf1.read(buf);
    
63.                 raf2.write(buf,0,len);
    
64.                 raf1.close();
    
65.                 raf2.close();
    
66.                 }
    
67.                 catch(IOException e){
    
68.                         throw new RuntimeException("Something is wrong!");
    
69.                 }
    
70.         }
    
71. }

复制代码

今天刚学到RandomAccessFile类，听毕老师讲这个类可以实现下载软件的多线程下载，于是动手写了下面这段代码。
求指点~~{:soso_e106:}

1. /**
   
2. 需求：用RandomAccessFile模拟多线程下载数据。
   
3. 分析：1，将要下载文件和保存路径用File封装为对象file1和file2。
   
4.           2，线程中用RandomAccessFile seek方法确定开始的位置，读取file1中的数据，对应的file2写入数据。
   
5. */
   
6. import java.io.*;
   
7. class RandomAccessFileTest{
   
8.         public static void main(String[] args){
   
9.                 File file1 = new File("testfiles\\2.mp3");
   
10.                 File file2 = new File("testfiles\\1.mp3");
    
11.                 if(!file1.exists()){
    
12.                         throw new RuntimeException("文件不存在！");
    
13.                 }
    
14.                 long part =  file1.length()/1024/1024; //将文件按1MB分段。
    
15.                 DownLoading[] downLoadThread =new DownLoading[(int)part+1]; //创建一个线程数组，有几段就分配几个线程。
    
16.                 for(int x=0 ; x<=(int)part ; x++){
    
17.                         downLoadThread[x] = new DownLoading();
    
18.                         downLoadThread[x].setFile(file1,file2,x);
    
19.                         
    
20.                 }
    
21.                 for(DownLoading dlt:downLoadThread){
    
22.                         dlt.start();
    
23.                 }
    
24. 
    
25.         }
    
26. 
    
27. }
    
28. class DownLoading extends Thread{        
    
29.         /**
    
30.         @param file1 下载文件
    
31.         @param file2 保存路径
    
32.         @param pos 线程读写指针
    
33.         @author @yrom
    
34.         @version 1.0
    
35.         @date 2012-11-16
    
36.         */
    
37.         private File file1;
    
38.         private File file2;
    
39.         private long pos;
    
40. 
    
41.         //设置文件下载和保存路径已经每个线程读写的位置。
    
42.         public void setFile(File file1, File file2,int pos){
    
43.                 this.file1 = file1;
    
44.                 this.file2 = file2;
    
45.                 this.pos = (long)pos;
    
46.         }
    
47.         public void run(){
    
48.                 pos = 1024*1024*pos; //定义起始的字节数。
    
49.                 downloading(pos,file1,file2);
    
50.                 System.out.println(Thread.currentThread().getName()+"run.");
    
51.         }
    
52.         //下载方法
    
53.         private void downloading(long pos,File file1,File file2){
    
54.                 byte[] buf = new byte[1024*1024];  //以1MB为分段长度
    
55.                 try{
    
56.                 RandomAccessFile raf1 = new RandomAccessFile(file1,"rw");
    
57.                 RandomAccessFile raf2 = new RandomAccessFile(file2,"rw");
    
58.                 //设置分段开始位置。
    
59.                 raf1.seek(pos);
    
60.                 raf2.seek(pos);
    
61.                 //每个线程只读写1MB的数据。
    
62.                 int len = raf1.read(buf);
    
63.                 raf2.write(buf,0,len);
    
64.                 raf1.close();
    
65.                 raf2.close();
    
66.                 }
    
67.                 catch(IOException e){
    
68.                         throw new RuntimeException("Something is wrong!");
    
69.                 }
    
70.         }
    
71. }

复制代码