文件斷點續(xù)傳代碼

import java.io.File;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.Date;


public class DT extends Thread {

    String urlt;//下載地址
    int startl;//子線程讀取/寫入起始字節(jié)
    int end;//子線程寫入結(jié)束字節(jié)長度
    String fileName;
    RandomAccessFile osf;

    public DT(int i, String url, String fileName, int start, int end) {
        this.setName("t" + i); //子線程名稱
        this.urlt = url; //下載地址
        this.fileName = fileName;
        this.startl = start; //子線程讀取/寫入起始字節(jié)
        this.end = end;//子線程寫入結(jié)束字節(jié)長度
    }

    public void run() {
        try {
            osf = new RandomAccessFile(fileName, "rw");
            URL url = new URL(urlt);
            HttpURLConnection http2 = (HttpURLConnection) url.openConnection();
            http2.setRequestProperty("User-Agent", "NetFox");

            /*
             * 斷點續(xù)傳和多線程下載的關(guān)鍵代碼關(guān)鍵位置：即設(shè)置斷點
             * http2.setRequestProperty("RANGE", "bytes="+startl+"-");//設(shè)置斷點位置，向服務(wù)器請求從文件的哪個字節(jié)開始讀取。
             * osf.seek(startl);//設(shè)置本地文件從哪個字節(jié)開始寫入
             * 如果是單線程，則首先要判斷下載文件是否已經(jīng)存在 及DownloadFile.java 里的 fileName = "C:\eclipse.zip";
             * 如果存在則開始斷點續(xù)傳，方法同多線程：
             * 因為斷點續(xù)傳是從上次傳輸中斷的字節(jié)開始，則首先要得到上次中斷的位置，既是文件長度（針對單線程）f.length()
             * 然后設(shè)置HTTP請求頭屬性RANGE，該屬性告知服務(wù)器從哪個自己開始讀取文件。
             * 設(shè)置本地文件寫入起始字節(jié)，及接從上次傳輸斷點繼續(xù)寫入（斷點續(xù)傳）
             * osf.seek(offset) 該方法設(shè)定從offset后一個字節(jié)開始寫入文件
             * 注意：多線程不能用文件長度做為寫文件起始字節(jié)，需有配置文件記錄上次讀寫的位置，迅雷下載既是使用該種方法。
             *
             */
            http2.setRequestProperty("RANGE", "bytes=" + startl + "-");//設(shè)置斷點位置，向服務(wù)器請求從文件的哪個字節(jié)開始讀取。
            osf.seek(startl);//設(shè)置本地文件從哪個字節(jié)開始寫入

            InputStream input = http2.getInputStream();
            byte b[] = new byte[1024];//設(shè)置緩沖池，每次只讀1024字節(jié)
            Date d = new Date();//子線程開始下載時間
            int l;//計算子線程讀取和寫入的文件長度，當(dāng)長度大于每個子線程平均下載長度則終止線程
            int i;
            l = 0;
            System.out.println(this.getName() + " 開始下載。。。");
            while ((i = input.read(b, 0, 1024)) != -1 && l < end) {    //線程下載字節(jié)長度控制誤差小于緩沖池大小，本示例為緩沖池1024字節(jié)
                osf.write(b, 0, i);
                b = new byte[1024];//重新賦值，避免重新讀入舊內(nèi)容
                l += i;
            }
            Date d2 = new Date();//子線程結(jié)束下載時間
            System.out.println(this.getName() + " 線程耗時： " + (d2.getTime() - d.getTime()) / 1000 + " 秒,實際共下載：" + l + "字節(jié)");//子線程下載耗時（秒）
        } catch (FileNotFoundException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        } catch (MalformedURLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

測試代碼文章來源地址http://www.zghlxwxcb.cn/news/detail-837905.html

import java.io.*;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;


public class DownloadFile {


    /**
     * @param args
     */
    static int len;//線程平均下載文件長度
    static int bn ;//每個線程寫入文件的字節(jié)數(shù)
    static int tn; //線程數(shù)
    static String urlt;//下載地址
    static String fileName;
    static RandomAccessFile osf; //文件操作
    public static void main(String[] args) {
        // TODO Auto-generated method stub

        try {
            urlt = "http://192.168.16.77:8080/Stargreat/html/baidu player";
            fileName = "C:\" + urlt.split("http://")[1].split("/")[urlt.split("http://")[1].split("/").length-1];
            System.out.println(fileName);
            URL url = new URL(urlt);
            HttpURLConnection http = (HttpURLConnection) url.openConnection();

            /**
             * 此處設(shè)定5個線程下載一個文件tn = 5;
             * 判斷平均每個線程需下載文件長度：
             */
            System.out.println("file size:" + http.getContentLength());
            tn = 3;
            len = http.getContentLength() / tn ;//舍去余數(shù)（余數(shù)自動舍去）計算每個線程應(yīng)下載平均長度，最后一個線程再加上余數(shù)，則是整個文件的長度,
            File f = new File(fileName);
            if (f.exists()){
                f.delete();
                osf = new RandomAccessFile(f, "rw");
                osf.seek(http.getContentLength()-1);
                osf.write(0);
            }else{
                osf = new RandomAccessFile(f, "rw");
                osf.seek(http.getContentLength()-1);
                osf.write(0);
            }
            System.out.println("temp 文件長度：" + f.length());
            Thread t;//下載子線程，
            for (int j = 0; j < tn; j++) {
                if(j == tn - 1){//如果最后一個線程則加上余數(shù)長度字節(jié)
                    bn = len + (http.getContentLength() % tn);
                }else{
                    bn = len;
                }
                System.out.println("t"+ j + "線程下載長度：" + bn + "起始字節(jié)：" + len*j);
                t = new DT(
                        j,
                        urlt,
                        fileName,
                        len*j,
                        bn

                );
                t.start();
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

到了這里，關(guān)于Java實現(xiàn)文件斷點續(xù)傳的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！