Java怎么實(shí)現(xiàn)斷點(diǎn)下載服務(wù)端與客戶端

這篇“Java怎么實(shí)現(xiàn)斷點(diǎn)下載服務(wù)端與客戶端”文章的知識點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“Java怎么實(shí)現(xiàn)斷點(diǎn)下載服務(wù)端與客戶端”文章吧。

原理

首先，我們先說明了斷點(diǎn)續(xù)傳的功能,實(shí)際上的原理比較簡單

客戶端和服務(wù)端規(guī)定好一個(gè)規(guī)則,客戶端傳遞一個(gè)參數(shù),告知服務(wù)端需要數(shù)據(jù)從何處開始傳輸,服務(wù)端接收到參數(shù)進(jìn)行處理,之后文件讀寫流從指定位置開始傳輸給客戶端

實(shí)際上,上述的參數(shù),在http協(xié)議中已經(jīng)有規(guī)范,參數(shù)名為Range

而對于服務(wù)端來說，只要處理好Range請求頭參數(shù)，即可實(shí)現(xiàn)下載續(xù)傳的功能

我們來看下Range請求頭數(shù)據(jù)格式如下：

格式如下：

Range:bytes=300-800
//客戶端需要文件300-800字節(jié)范圍的數(shù)據(jù)（即500B數(shù)據(jù)）

Range:bytes=300-
//客戶端需要文件300字節(jié)之后的數(shù)據(jù)

我們根據(jù)上面的格式，服務(wù)端對Range字段進(jìn)行處理(String字符串?dāng)?shù)據(jù)處理),在流中返回指定的數(shù)據(jù)大小即可

那么，如何讓流返回指定的數(shù)據(jù)大小或從指定位置開始傳輸數(shù)據(jù)呢?

這里,Java提供了RandomAccessFile類,通過seekTo()方法,可以讓我們將流設(shè)置從指定位置開始讀取或?qū)懭霐?shù)據(jù)

這里讀取和寫入數(shù)據(jù),我是采用的Java7之后新增的NIO的Channel進(jìn)行流的寫入（當(dāng)然，用傳統(tǒng)的文件IO流(BIO)也可以）

這里,我所說的客戶端是指的Android客戶端,由于App開發(fā)也是基于Java,所以也是可以使用RandomAccessFile這個(gè)類

對于客戶端來說，有以下邏輯：

先讀取本地已下載文件的大小，然后請求下載數(shù)據(jù)將文件大小的數(shù)據(jù)作為請求頭的數(shù)值傳到服務(wù)端，之后也是利用RandomAccessFile移動(dòng)到文件的指定位置開始寫入數(shù)據(jù)即可

擴(kuò)展-大文件快速下載思路

利用上面的思路，我們還可以可以得到一個(gè)大文件快速下載的思路：

如，一份文件，大小為2000B（這個(gè)大小可以通過網(wǎng)絡(luò)請求，從返回?cái)?shù)據(jù)的請求頭content-length獲取獲取）

客戶端拿回到文件的總大小,根據(jù)調(diào)優(yōu)算法,將平分成合適的N份，通過線程池，來下載這個(gè)N個(gè)單文件

在下載完畢之后，將N個(gè)文件按照順序合并成單個(gè)文件即可

代碼

上面說明了具體的思路,那么下面就是貼出服務(wù)端和客戶端的代碼示例

服務(wù)端

服務(wù)端是采用的spring boot進(jìn)行編寫

/**
 * 斷點(diǎn)下載文件
 *
 * @return
 */
@GetMapping("download")
public void download( HttpServletRequest request, HttpServletResponse response) throws IOException {
    //todo 這里文件按照你的需求調(diào)整
    File file = new File("D:\\temp\\測試文件.zip");
    if (!file.exists()) {
        response.setStatus(HttpStatus.NOT_FOUND.value());
        return;
    }
    long fromPos = 0;
    long downloadSize = file.length();

    if (request.getHeader("Range") != null) {
        response.setStatus(HttpServletResponse.SC_PARTIAL_CONTENT);
        String[] ary = request.getHeader("Range").replaceAll("bytes=", "").split("-");
        fromPos = Long.parseLong(ary[0]);
        downloadSize = (ary.length < 2 ? downloadSize : Long.parseLong(ary[1])) - fromPos;
    }
    //注意下面設(shè)置的相關(guān)請求頭
    response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
    //相當(dāng)于設(shè)置請求頭content-length
    response.setContentLengthLong(downloadSize);

    //使用URLEncoder處理中文名(否則會(huì)出現(xiàn)亂碼)
    response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(file.getName(), "UTF-8"));
    response.setHeader("Accept-Ranges", "bytes");
    response.setHeader("Content-Range", String.format("bytes %s-%s/%s", fromPos, (fromPos + downloadSize), downloadSize));

    RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw");
    randomAccessFile.seek(fromPos);

    FileChannel inChannel = randomAccessFile.getChannel();
    WritableByteChannel outChannel = Channels.newChannel(response.getOutputStream());

    try {
        while (downloadSize > 0) {
            long count = inChannel.transferTo(fromPos, downloadSize, outChannel);
            if (count > 0) {
                fromPos += count;
                downloadSize -= count;
            }
        }
        inChannel.close();
        outChannel.close();
        randomAccessFile.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

客戶端

Android客戶端,是基于Okhttp的網(wǎng)絡(luò)框架寫的，需要先引用依賴

implementation 'com.squareup.okhttp3:okhttp:3.9.0'

下面給出的是封裝好的方法（含進(jìn)度，下載失敗和成功回調(diào)）：

package com.tyky.update.utils;

import com.blankj.utilcode.util.ThreadUtils;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.math.BigDecimal;
import java.nio.ByteBuffer;
import java.nio.channels.Channels;
import java.nio.channels.FileChannel;
import java.nio.channels.ReadableByteChannel;

import okhttp3.Call;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

public class FileDownloadUtil {

    public static void download(String url, File file, OnDownloadListener listener) {

        //http://10.232.107.44:9060/swan-business/file/download
        // 利用通道完成文件的復(fù)制(非直接緩沖區(qū))
        ThreadUtils.getIoPool().submit(new Runnable() {
            @Override
            public void run() {
                try {

                    //續(xù)傳開始的進(jìn)度
                    long startSize = 0;
                    if (file.exists()) {
                        startSize = file.length();
                    }
                    OkHttpClient okHttpClient = new OkHttpClient.Builder().build();
                    Request request = new Request.Builder().url(url)
                            .addHeader("Range", "bytes=" + startSize)
                            .get().build();
                    Call call = okHttpClient.newCall(request);
                    Response resp = call.execute();

                    double length = Long.parseLong(resp.header("Content-Length")) * 1.0;
                    InputStream fis = resp.body().byteStream();
                    ReadableByteChannel fisChannel = Channels.newChannel(fis);

                    RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw");
                    //從上次未完成的位置開始下載
                    randomAccessFile.seek(startSize);
                    FileChannel foschannel = randomAccessFile.getChannel();

                    // 通道沒有辦法傳輸數(shù)據(jù)，必須依賴緩沖區(qū)
                    // 分配指定大小的緩沖區(qū)
                    ByteBuffer byteBuffer = ByteBuffer.allocate(1024);

                    // 將通道中的數(shù)據(jù)存入緩沖區(qū)中
                    while (fisChannel.read(byteBuffer) != -1) {  // fisChannel 中的數(shù)據(jù)讀到 byteBuffer 緩沖區(qū)中
                        byteBuffer.flip();  // 切換成讀數(shù)據(jù)模式
                        // 將緩沖區(qū)中的數(shù)據(jù)寫入通道
                        foschannel.write(byteBuffer);

                        final double progress = (foschannel.size() / length);
                        BigDecimal two = new BigDecimal(progress);
                        double result = two.setScale(2,BigDecimal.ROUND_HALF_UP).doubleValue();
                        //計(jì)算進(jìn)度，回調(diào)
                        if (listener != null) {
                            listener.onProgress(result);
                        }
                        byteBuffer.clear();  // 清空緩沖區(qū)
                    }
                    foschannel.close();
                    fisChannel.close();
                    randomAccessFile.close();

                    if (listener != null) {
                        listener.onSuccess(file);
                    }
                } catch (IOException e) {
                    if (listener != null) {
                        listener.onError(e);
                    }

                }
            }
        });


    }

    public interface OnDownloadListener {
        void onProgress(double progress);

        void onError(Exception e);

        void onSuccess(File outputFile);
    }
}

使用：

FileDownloadUtil.download(downloadUrl, file, new FileDownloadUtil.OnDownloadListener() {
    @Override
    public void onProgress(double progress) {
        KLog.d("下載進(jìn)度: " + progress);
    }

    @Override
    public void onError(Exception e) {
        KLog.e("下載錯(cuò)誤: " + e.getMessage());
    }

    @Override
    public void onSuccess(File outputFile) {
        KLog.d("下載成功");
    }
});

以上就是關(guān)于“Java怎么實(shí)現(xiàn)斷點(diǎn)下載服務(wù)端與客戶端”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對大家有幫助，若想了解更多相關(guān)的知識內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道。