多线程下载

smanzheng

多个线程同时下载网络文件，基于http协议
[Java]代码

1. package com.test.download;
   
2. 
   
3. import java.io.File;
   
4. import java.io.InputStream;
   
5. import java.io.RandomAccessFile;
   
6. import java.net.HttpURLConnection;
   
7. import java.net.URL;
   
8. 
   
9. /*
   
10. * 多线程下载
    
11. */
    
12. public class MulThreadDownload {
    
13. 
    
14.     public static void main(String[] args) throws Exception {
    
15.         String path = "http://pic.4j4j.cn/upload/pic/20130909/681ebf9d64.jpg";
    
16.         new MulThreadDownload().download(path,3);
    
17.     }
    
18.      
    
19.     public void download (String path,int threadsize) throws Exception{
    
20.         URL url = new URL(path);
    
21.         HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    
22.         conn.setConnectTimeout(5000);
    
23.         conn.setRequestMethod("GET");
    
24.         if(conn.getResponseCode() == 200){
    
25.             //获取网络文件长度
    
26.             int length = conn.getContentLength();   
    
27.             //新建本地文件保存下载数据
    
28.             File file = new File(getFilename(path));
    
29.             //计算每条线程负责下载的数据量
    
30.             int block = length%threadsize==0 ? length/threadsize : length/threadsize+1;
    
31.             //开启指定数目的线程同时下载
    
32.             for(int threadid = 0; threadid < threadsize; threadid++){
    
33.                 new DownloadThread(threadid,block,url,file).start();
    
34.             }
    
35.         }else{
    
36.             System.out.println("下载失败！");
    
37.         }
    
38.     }
    
39.      
    
40.     private class DownloadThread extends Thread{
    
41.         private int threadid;   //线程编号
    
42.         private int block;      //下载块大小
    
43.         private URL url;        //下载链接
    
44.         private File file;      //下载数据保存文件
    
45.         public DownloadThread(int threadid, int block, URL url, File file) {
    
46.             this.threadid = threadid;
    
47.             this.block = block;
    
48.             this.url = url;
    
49.             this.file = file;
    
50.         }
    
51. 
    
52.         public void run() {
    
53.             int start = threadid * block;       //本线程下载数据写入文件开始位置
    
54.             int end = (threadid+1) * block - 1; //本线程下载数据写入文件结束位置
    
55.             try {
    
56.                 //创建一个随机访问文件流对象
    
57.                 RandomAccessFile accessFile = new RandomAccessFile(file, "rwd");
    
58.                 //文件指针偏移至正确写入位置
    
59.                 accessFile.seek(start);
    
60.                 HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    
61.                 conn.setConnectTimeout(5000);
    
62.                 conn.setRequestMethod("GET");
    
63.                 //设置请求数据的范围
    
64.                 conn.setRequestProperty("Range", "bytes="+start+"-"+end);
    
65.                 if(conn.getResponseCode() == 206){//状态码206:（部分内容） 服务器成功处理了部分 GET 请求
    
66.                     InputStream inStream = conn.getInputStream();
    
67.                     byte[] buffer = new byte[1024];
    
68.                     int len = 0;
    
69.                     while((len = inStream.read(buffer)) != -1){
    
70.                         accessFile.write(buffer, 0, len);
    
71.                     }
    
72.                     accessFile.close();
    
73.                     inStream.close();
    
74.                 }
    
75.                 System.out.println("第"+(threadid+1)+"部分下载完成");
    
76.             } catch (Exception e) {
    
77.                 e.printStackTrace();
    
78.             }
    
79.         }
    
80.     }
    
81. 
    
82.     private String getFilename(String path) {
    
83.         return path.substring(path.lastIndexOf("/")+1);
    
84.     }
    
85. }

复制代码