Java中使用RandomAccessFile类实现多线程下载

baopbird2005

多线程下载文件的注意点主要有：

1、确定每个线程下载的文件大小，用这种方法计算：
先获取整个文件的大小length，然后除以线程个数count得到每个线程下载的块大小为blockSize = length / count,每个线程的起始下载点为：startPos = blockSize * i，结束下载点为：endPos = blockSize * (i + 1) - 1,其中最后一个线程下载的结束点应该为文件末尾

2、随机访问文件RandomAccessFile类的使用方法，该类的实例化需要两个参数，第一个可以使一个文件File类，也可以是文件的path，String类，第二个参数代表文件写入的模式，可以为"r","rw","rws","rwd"之一

3、在每个线程中写文件的时候都需要实例化一个RandomAccessFile的实例，而不能重复使用同一个RandomAccessFile

4、在设置请求参数时，获取服务器的响应码会有所不同，如果请求的是一整个资源，则请求成功的响应码是200，若请求的是某个资源的部分时，请求成功返回的响应码是206，这一点需要注意，另外，在每个线程中下载一个文件的不同部分时，需要设置请求的头字段：conn.setRequestProperty("Range", "bytes=12345-13456");设置该头字段代表请求服务器资源的12345到13456这部分的内容

另外，在每个线程下载之前，需要将RandomAccessFile的实例的指针指向下载的开始点，使用如下方法：
raf.seek(startPos); 其中raf为RandomAccessFile类的对象，startPos为下载的开始点

1. import java.io.File;
   
2. import java.io.InputStream;
   
3. import java.io.RandomAccessFile;
   
4. import java.net.HttpURLConnection;
   
5. import java.net.URL;
   
6. 
   
7. public class Test {
   
8.         /**
   
9.          * 文件下载的路径
   
10.          */
    
11.         private static final String PATH = "http://localhost:8080/test.exe";
    
12.         /**
    
13.          * 下载的线程个数
    
14.          */
    
15.         private static final int COUNT = 3;
    
16.         /**
    
17.          * 创建一个文件，将远程文件写入该文件
    
18.          */
    
19.         private File f = new File("C:\\Users\\Administrator\\Desktop\\test.exe");
    
20.        
    
21.         public void download() throws Exception{
    
22.                 URL url = new URL(PATH);
    
23.                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    
24.                 //使用get请求
    
25.                 conn.setRequestMethod("GET");
    
26.                 //设置连接超时时间为5秒
    
27.                 conn.setConnectTimeout(5000);
    
28.                 //得到服务器返回的响应码
    
29.                 int code = conn.getResponseCode();
    
30.                 //响应码为200，代表请求资源成功（前提是请求整个资源，而不是资源的某一部分）
    
31.                 if(code == 200){
    
32.                         //得到文件的总大小
    
33.                         int length = conn.getContentLength();
    
34.                         //新建一个随机访问的文件
    
35.                         RandomAccessFile raf = new RandomAccessFile(f, "rw");
    
36.                         //第一个参数为文件类型，第二个参数为模式，可以为"r","rw","rws","rwd"
    
37.                         raf = new RandomAccessFile(f, "rw");
    
38.                         //设置随机文件的大小为服务器端文件的大小
    
39.                         raf.setLength(length);
    
40.                         System.out.println("文件总大小为：" + length);
    
41.                         //计算每个线程下载的块的大小
    
42.                         int blockSize = length / COUNT;
    
43.                         for(int i = 0; i < COUNT; i++){
    
44.                                 //每个线程的起始下载点
    
45.                                 int startPos = blockSize * i;
    
46.                                 //每个线程的结束下载点
    
47.                                 int endPos = blockSize * (i + 1) - 1;
    
48.                                 //如果是最后一条线程，将其下载的终止点设为文件的终点
    
49.                                 if(i == COUNT){
    
50.                                         endPos = length;
    
51.                                 }
    
52.                                 System.out.println("线程" + i + "下载的部分为：" + startPos +"---" + endPos);
    
53.                                 //开启线程分别下载不同的部分
    
54.                                 new DownThread(i, startPos, endPos).start();
    
55.                         }
    
56.                 }
    
57.         }
    
58.        
    
59.         /**
    
60.          * 下载文件的线程
    
61.          * @author Administrator
    
62.          *
    
63.          */
    
64.         class DownThread extends Thread{
    
65.                 //线程ID
    
66.                 private int threadId;
    
67.                 //线程下载的起始点
    
68.                 private int startPos;
    
69.                 //线程下载的结束点
    
70.                 private int endPos;
    
71.                
    
72.                 public DownThread(int threadId, int startPos, int endPos) {
    
73.                         this.threadId = threadId;
    
74.                         this.startPos = startPos;
    
75.                         this.endPos = endPos;
    
76.                 }
    
77. 
    
78.                 @Override
    
79.                 public void run(){
    
80.                         try {
    
81.                                 URL url = new URL(PATH);
    
82.                                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    
83.                                 conn.setConnectTimeout(5000);
    
84.                                 conn.setRequestMethod("GET");
    
85.                                 //设置头部的参数，表示请求服务器资源的某一部分
    
86.                                 conn.setRequestProperty("Range", "bytes=" + startPos + "-" + endPos);
    
87.                                 //设置了上面的头信息后，响应码为206代表请求资源成功，而不再是200
    
88.                                 int code = conn.getResponseCode();
    
89.                                 if(code == 206){
    
90.                                         InputStream is = conn.getInputStream();
    
91.                                         int hasRead = 0;
    
92.                                         byte[] buf = new byte[1024];
    
93.                                         //这里要注意新创建一个RandomAccessFile对象，而不能重复使用download方法中创建的
    
94.                                         RandomAccessFile raf = new RandomAccessFile(f, "rw");
    
95.                                         //将写文件的指针指向下载的起始点
    
96.                                         raf.seek(startPos);
    
97.                                         while((hasRead = is.read(buf)) > 0) {
    
98.                                                 raf.write(buf, 0, hasRead);
    
99.                                         }
    
100.                                         is.close();
     
101.                                         System.out.println("线程" + threadId + "下载完毕...");
     
102.                                 }
     
103.                         } catch (Exception e) {
     
104.                                 e.printStackTrace();
     
105.                         }
     
106.                 }
     
107.         }
     
108.        
     
109.         public static void main(String[] args) {
     
110.                 try {
     
111.                         new Test().download();
     
112.                 } catch (Exception e) {
     
113.                         e.printStackTrace();
     
114.                 }
     
115.         }
     
116. }

复制代码