Okhttp多线程断点续传

2019年5月8日 464次阅读来源: 小红军storm

1、断点续传相关定义

1.1、断点续传：

记录上次下载的位置，下次接着该位置继续下载。

1.2、多线程下载：

根据目标下载文件长度，分给多个线程同时下载。

1.3、多线程断点续传：

根据目标下载文件长度，分给多个线程同时下载；每个线程在中断下载时都记录当前的下载位置，下次下载时接着该位置继续下载（所有的线程下载完成，最终文件也下载完成）。

2、断点续传相关技术方案

2.1、断点续传实现方案：

下载方面：

在http的header中添加rang字段下载对应部分的内容。

 /**
     * @param url        下载链接
     * @param startIndex 下载起始位置
     * @param endIndex   结束为止
     * @param callback   回调
     * @throws IOException
     */
    public void downloadFileByRange(String url, long startIndex, long endIndex, Callback callback) throws IOException {
        // 创建一个Request
        // 设置分段下载的头信息。 Range:做分段数据请求,断点续传指示下载的区间。格式: Range bytes=0-1024或者bytes:0-1024
        Request request = new Request.Builder().header("RANGE", "bytes=" + startIndex + "-" + endIndex)
                .url(url)
                .build();
        doAsync(request, callback);
    }

文件写入方面：

使用RandomAccessFile类跳过已下载部分，然后开始写入。

InputStream is = inputStream;// 获取流
RandomAccessFile tmpAccessFile = new RandomAccessFile(mTmpFile, "rw");// 获取前面已创建的文件.
tmpAccessFile.seek(finalStartIndex);// 文件写入的开始位置.
/*  将网络流中的文件写入本地*/
byte[] buffer = new byte[1024 << 2];
int length = -1;
while ((length = is.read(buffer)) > 0) {
         tmpAccessFile.write(buffer, 0, length);
}

2.2、多线程下载实现方案：

（1）计算每个线程下载的大小。
long blockSize = mFileLength / THREAD_COUNT

（2）开启THREAD_COUNT个线程去下载文件的对应部分。

for (int threadId = 0; threadId < THREAD_COUNT; threadId++) {
      long startIndex = threadId * blockSize; // 线程开始下载的位置
      long endIndex = (threadId + 1) * blockSize - 1; // 线程结束下载的位置
      if (threadId == (THREAD_COUNT - 1)) { // 如果是最后一个线程,将剩下的文件全部交给这个线程完成
           endIndex = mFileLength - 1;
         }
    download(startIndex, endIndex, threadId);// 开启线程下载
 }

    原文作者：小红军storm
    原文地址: https://www.jianshu.com/p/9e2b272af163
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。

算法网