Java实现文件断点续传

文件断点续传代码

1. import java.io.File;
2. import java.io.FileNotFoundException;
3. import java.io.IOException;
4. import java.io.InputStream;
5. import java.io.RandomAccessFile;
6. import java.net.HttpURLConnection;
7. import java.net.MalformedURLException;
8. import java.net.URL;
9. import java.util.Date;
12. public class DT extends Thread {
14.     String urlt;//下载地址
15.     int startl;//子线程读取/写入起始字节
16.     int end;//子线程写入结束字节长度
17.     String fileName;
18.     RandomAccessFile osf;
20.     public DT(int i, String url, String fileName, int start, int end) {
21.         this.setName("t" + i); //子线程名称
22.         this.urlt = url; //下载地址
23.         this.fileName = fileName;
24.         this.startl = start; //子线程读取/写入起始字节
25.         this.end = end;//子线程写入结束字节长度
26.     }
28.     public void run() {
29.         try {
30.             osf = new RandomAccessFile(fileName, "rw");
31.             URL url = new URL(urlt);
32.             HttpURLConnection http2 = (HttpURLConnection) url.openConnection();
33.             http2.setRequestProperty("User-Agent", "NetFox");
35.             /*
36.              * 断点续传和多线程下载的关键代码关键位置：即设置断点
37.              * http2.setRequestProperty("RANGE", "bytes="+startl+"-");//设置断点位置，向服务器请求从文件的哪个字节开始读取。
38.              * osf.seek(startl);//设置本地文件从哪个字节开始写入
39.              * 如果是单线程，则首先要判断下载文件是否已经存在 及DownloadFile.java 里的 fileName = "C:\eclipse.zip";
40.              * 如果存在则开始断点续传，方法同多线程：
41.              * 因为断点续传是从上次传输中断的字节开始，则首先要得到上次中断的位置，既是文件长度（针对单线程）f.length()
42.              * 然后设置HTTP请求头属性RANGE，该属性告知服务器从哪个自己开始读取文件。
43.              * 设置本地文件写入起始字节，及接从上次传输断点继续写入（断点续传）
44.              * osf.seek(offset) 该方法设定从offset后一个字节开始写入文件
45.              * 注意：多线程不能用文件长度做为写文件起始字节，需有配置文件记录上次读写的位置，迅雷下载既是使用该种方法。
46.              *
47.              */
48.             http2.setRequestProperty("RANGE", "bytes=" + startl + "-");//设置断点位置，向服务器请求从文件的哪个字节开始读取。
49.             osf.seek(startl);//设置本地文件从哪个字节开始写入
51.             InputStream input = http2.getInputStream();
52.             byte b[] = new byte[1024];//设置缓冲池，每次只读1024字节
53.             Date d = new Date();//子线程开始下载时间
54.             int l;//计算子线程读取和写入的文件长度，当长度大于每个子线程平均下载长度则终止线程
55.             int i;
56.             l = 0;
57.             System.out.println(this.getName() + " 开始下载。。。");
58.             while ((i = input.read(b, 0, 1024)) != -1 && l < end) {    //线程下载字节长度控制误差小于缓冲池大小，本示例为缓冲池1024字节
59.                 osf.write(b, 0, i);
60.                 b = new byte[1024];//重新赋值，避免重新读入旧内容
61.                 l += i;
62.             }
63.             Date d2 = new Date();//子线程结束下载时间
64.             System.out.println(this.getName() + " 线程耗时： " + (d2.getTime() - d.getTime()) / 1000 + " 秒,实际共下载：" + l + "字节");//子线程下载耗时（秒）
65.         } catch (FileNotFoundException e1) {
66.             // TODO Auto-generated catch block
67.             e1.printStackTrace();
68.         } catch (MalformedURLException e) {
69.             // TODO Auto-generated catch block
70.             e.printStackTrace();
71.         } catch (IOException e) {
72.             // TODO Auto-generated catch block
73.             e.printStackTrace();
74.         }
75.     }
76. }

复制代码

测试代码

1. import java.io.*;
2. import java.net.HttpURLConnection;
3. import java.net.MalformedURLException;
4. import java.net.URL;
7. public class DownloadFile {
10.     /**
11.      * @param args
12.      */
13.     static int len;//线程平均下载文件长度
14.     static int bn ;//每个线程写入文件的字节数
15.     static int tn; //线程数
16.     static String urlt;//下载地址
17.     static String fileName;
18.     static RandomAccessFile osf; //文件操作
19.     public static void main(String[] args) {
20.         // TODO Auto-generated method stub
22.         try {
23.             urlt = "http://192.168.16.77:8080/Stargreat/html/baidu player";
24.             fileName = "C:" + urlt.split("//")[1].split("/")[urlt.split("//")[1].split("/").length-1];
25.             System.out.println(fileName);
26.             URL url = new URL(urlt);
27.             HttpURLConnection http = (HttpURLConnection) url.openConnection();
29.             /**
30.              * 此处设定5个线程下载一个文件tn = 5;
31.              * 判断平均每个线程需下载文件长度：
32.              */
33.             System.out.println("file size:" + http.getContentLength());
34.             tn = 3;
35.             len = http.getContentLength() / tn ;//舍去余数（余数自动舍去）计算每个线程应下载平均长度，最后一个线程再加上余数，则是整个文件的长度,
36.             File f = new File(fileName);
37.             if (f.exists()){
38.                 f.delete();
39.                 osf = new RandomAccessFile(f, "rw");
40.                 osf.seek(http.getContentLength()-1);
41.                 osf.write(0);
42.             }else{
43.                 osf = new RandomAccessFile(f, "rw");
44.                 osf.seek(http.getContentLength()-1);
45.                 osf.write(0);
46.             }
47.             System.out.println("temp 文件长度：" + f.length());
48.             Thread t;//下载子线程，
49.             for (int j = 0; j < tn; j++) {
50.                 if(j == tn - 1){//如果最后一个线程则加上余数长度字节
51.                     bn = len + (http.getContentLength() % tn);
52.                 }else{
53.                     bn = len;
54.                 }
55.                 System.out.println("t"+ j + "线程下载长度：" + bn + "起始字节：" + len*j);
56.                 t = new DT(
57.                         j,
58.                         urlt,
59.                         fileName,
60.                         len*j,
61.                         bn
63.                 );
64.                 t.start();
65.             }
67.         } catch (IOException e) {
68.             // TODO Auto-generated catch block
69.             e.printStackTrace();
70.         }
71.     }
72. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。