OKHTTP断点续传

OKHTTP断点续传

文章目录

  • OKHTTP断点续传
    • HTTP断点续传知识点
      • Range
      • Content Range
      • Etag&If-Range(文件唯一标志)
    • OKHTTP断点下载
    • OKHTTP 简单短断点下载代码示例

Android 断点续传一直是面试的高频问点,这里从HTTP断点续传知识和Android续传思路结合一起,总结出关于Android断点续传做法。

HTTP断点续传知识点

HTTP1.1 协议中默认支持获取文件的部分内容,主要是通过头部两个参数:Range和Content Range 来实现的,客户端发送请求是对应是Range ,服务器响应时是对应Content-Range。

Range

是客户端想要获取文件的部分内容的关键字段,Range 参数中指定获取内容的起始字节的位置和终止字节的位置。他的一般格式为:

<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">Range:(unit=first byte </font>**<font style="color:rgb(51, 51, 51);">pos</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">)-[</font>**<font style="color:rgb(51, 51, 51);">last</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);"> byte </font>**<font style="color:rgb(51, 51, 51);">pos</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">]</font>

例如:

Range: bytes=0-499      表示第 0-499 字节范围的内容 、
Range: bytes=-500       表示最后 500 字节的内容 
Range: bytes=500-       表示从第 500 字节开始到文件结束部分的内容 
Range: bytes=0-0,-1     表示第一个和最后一个字节 
Range: bytes=500-600,601-999 同时指定几个范围

Content Range

在接受到客户端的Range请求后,服务器会在响应的头部添加Content 参数,返回可以接受的文件字节范围和文件的总大小,他们格式如下:

<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">Content-Range: bytes (unit first byte </font>**<font style="color:rgb(51, 51, 51);">pos</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">) - [</font>**<font style="color:rgb(51, 51, 51);">last</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);"> byte </font>**<font style="color:rgb(51, 51, 51);">pos</font>**<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">]/[entity legth]</font>

例如:

<font style="color:navy;">Content-Range</font><font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">: bytes </font><font style="color:teal;">0</font><font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">-</font><font style="color:teal;">499</font><font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">/</font><font style="color:teal;">22400</font>_<font style="color:rgb(153, 153, 136);">// 0-499 是指当前发送的数据的范围,而 22400 则是文件的总大小。</font>_

不使用文件断点续传响应体内容:<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">HTTP/</font><font style="color:teal;">1.1200Ok</font>

使用文件断点续传响应体的内容:<font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);">HTTP/</font><font style="color:teal;">1.1206</font><font style="color:rgb(51, 51, 51);background-color:rgb(248, 248, 248);"> Partial </font><font style="color:navy;">Content</font>

服务器文件发生变化,会导致续传的请求是肯定是失败的,为了处理这种服务器文件资源发生改变的问题,在RFC2616中定义了Last-Modified和Etag来判断文件资源是否发生改变。

Etag&If-Range(文件唯一标志)

  • Etag:作为文件唯一的标志,这个标志可以是文件的hash值或者是一个版本
  • If-Range:用于判断实体是否发生改变,如果未改变,服务器发送客户端丢失的部分,否则发送整个实体,一般格式为:If-Range: Etag | HTTP-Date If-Range可以使用Etag或者Last-Modified返回的值,当没有ETag却有Last-Modified时,可以把Last-Modified作为If-Range的值
  • 验证过程:
    • step1:客户端发起续传请求,头部包含Range和If-Range参数
    • step2:服务器中收到客户端的请求之后,将客户端与服务器的Etag进行对比
      • 相等:请求文件资源没有发生变化,应答报文是206
      • 不相等:请求文件资源发生变化,应答报文为200

OKHTTP断点下载

  • step 1:判断检查本地是否有下载文件,若存在,则获取已下载的文件大小 downloadLength,若不存在,那么本地已下载文件的长度为 0
  • step 2:获取将要下载的文件总大小(HTTP 响应头部的 content-Length)
  • step 3:比对已下载文件大小和将要下载的文件总大小(contentLength),判断要下载的长度
  • step 4:再即将发起下载请求的 HTTP 头部中添加即将下载的文件大小范围(Range: bytes = downloadLength - contentLength)

OKHTTP 简单短断点下载代码示例


/*** String 在执行AsyncTask时需要传入的参数,可用于在后台任务中使用。* Integer 后台任务执行时,如果需要在界面上显示当前的进度,则使用这里指定的泛型作为进度单位。* Integer 当任务执行完毕后,如果需要对结果进行返回,则使用这里指定的泛型作为返回值类型。*/
public class DownloadTask extends AsyncTask<String, Integer, Integer> {public static final int TYPE_SUCCESS = 0;public static final int TYPE_FAILED = 1;public static final int TYPE_PAUSED = 2;public static final int TYPE_CANCELED = 3;private DownloadListener listener;private boolean isCanceled = false;private boolean isPaused = false;private int lastProgress;public DownloadTask(DownloadListener listener) {this.listener = listener;}/*** 这个方法中的所有代码都会在子线程中运行,我们应该在这里处理所有的耗时任务。** @param params* @return*/@Overrideprotected Integer doInBackground(String... params) {InputStream is = null;RandomAccessFile savedFile = null;File file = null;long downloadLength = 0;   //记录已经下载的文件长度//文件下载地址String downloadUrl = params[0];//下载文件的名称String fileName = downloadUrl.substring(downloadUrl.lastIndexOf("/"));//下载文件存放的目录String directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();//创建一个文件file = new File(directory + fileName);if (file.exists()) {//如果文件存在的话,得到文件的大小downloadLength = file.length();}//得到下载内容的大小long contentLength = getContentLength(downloadUrl);if (contentLength == 0) {return TYPE_FAILED;} else if (contentLength == downloadLength) {//已下载字节和文件总字节相等,说明已经下载完成了return TYPE_SUCCESS;}OkHttpClient client = new OkHttpClient();/*** HTTP请求是有一个Header的,里面有个Range属性是定义下载区域的,它接收的值是一个区间范围,* 比如:Range:bytes=0-10000。这样我们就可以按照一定的规则,将一个大文件拆分为若干很小的部分,* 然后分批次的下载,每个小块下载完成之后,再合并到文件中;这样即使下载中断了,重新下载时,* 也可以通过文件的字节长度来判断下载的起始点,然后重启断点续传的过程,直到最后完成下载过程。*/Request request = new Request.Builder().addHeader("RANGE", "bytes=" + downloadLength + "-" + contentLength)  //断点续传要用到的,指示下载的区间.url(downloadUrl).build();try {Response response = client.newCall(request).execute();if (response != null) {is = response.body().byteStream();savedFile = new RandomAccessFile(file, "rw");savedFile.seek(downloadLength);//跳过已经下载的字节byte[] b = new byte[1024];int total = 0;int len;while ((len = is.read(b)) != -1) {if (isCanceled) {return TYPE_CANCELED;} else if (isPaused) {return TYPE_PAUSED;} else {total += len;savedFile.write(b, 0, len);//计算已经下载的百分比int progress = (int) ((total + downloadLength) * 100 / contentLength);//注意:在doInBackground()中是不可以进行UI操作的,如果需要更新UI,比如说反馈当前任务的执行进度,//可以调用publishProgress()方法完成。publishProgress(progress);}}response.body().close();return TYPE_SUCCESS;}} catch (IOException e) {e.printStackTrace();} finally {try {if (is != null) {is.close();}if (savedFile != null) {savedFile.close();}if (isCanceled && file != null) {file.delete();}} catch (Exception e) {e.printStackTrace();}}return TYPE_FAILED;}/*** 当在后台任务中调用了publishProgress(Progress...)方法之后,onProgressUpdate()方法* 就会很快被调用,该方法中携带的参数就是在后台任务中传递过来的。在这个方法中可以对UI进行操作,利用参数中的数值就可以* 对界面进行相应的更新。** @param values*/@Overrideprotected void onProgressUpdate(Integer... values) {int progress = values[0];if (progress > lastProgress) {listener.onProgress(progress);lastProgress = progress;}}/*** 当后台任务执行完毕并通过Return语句进行返回时,这个方法就很快被调用。返回的数据会作为参数* 传递到此方法中,可以利用返回的数据来进行一些UI操作。** @param status*/@Overrideprotected void onPostExecute(Integer status) {switch (status) {case TYPE_SUCCESS:listener.onSuccess();break;case TYPE_FAILED:listener.onFailed();break;case TYPE_PAUSED:listener.onPaused();break;case TYPE_CANCELED:listener.onCanceled();break;default:break;}}public void pauseDownload() {isPaused = true;}public void cancelDownload() {isCanceled = true;}/*** 得到下载内容的完整大小** @param downloadUrl* @return*/private long getContentLength(String downloadUrl) {OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url(downloadUrl).build();try {Response response = client.newCall(request).execute();if (response != null && response.isSuccessful()) {long contentLength = response.body().contentLength();response.body().close();return contentLength;}} catch (IOException e) {e.printStackTrace();}return 0;}}

public class DownloadListener {/*** 通知当前的下载进度* @param progress*/void onProgress(int progress);/*** 通知下载成功*/void onSuccess();/*** 通知下载失败*/void onFailed();/*** 通知下载暂停*/void onPaused();/*** 通知下载取消事件*/void onCanceled();}

推荐阅读:Android OkHttp 文件上传与下载的进度监听扩展 - 掘金

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/58793.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Android 音量调节流程分析

音量调节流程分析 按下音量键 音量键被按下后&#xff0c;按键事件会一路派发给Acitivity&#xff0c;如果无人拦截并处理&#xff0c;承载当前Activity的显示PhoneWindow类的onKeyDown()以及onKeyUp()函数将会被处理&#xff0c;从而开始通过音量键调整音量的处理流程&#x…

【设计模式】《Java 设计模式魔法:解锁高效编程的秘密武器》

标题&#xff1a;《Java 设计模式奇幻之旅&#xff1a;解锁高效编程的魔法钥匙》 摘要&#xff1a; 本文将深入探讨 Java 中的十种设计模式&#xff0c;包括单例模式、工厂方法模式、抽象工厂模式…迭代器模式、组合模式、模板方法模式等。通过详细的解释、生动有趣的例子以及…

如何防止U盘盗取电脑数据?

数据安全无论是对企业还是个人都至关重要。这些用户群体随时面临着数据被窃取的风险&#xff0c;而 U 盘则成为了潜在的安全隐患。如果你想要禁止电脑上使用 这类USB 存储设备&#xff0c;看完这篇文章&#xff0c;防止 U 盘盗取数据并非难事。 禁止使用usb存储设备 打开电脑上…

虚拟机 Ubuntu 扩容

文章目录 一、Vmware 重新分配 Ubuntu 空间二、Ubuntu 扩容分区 一、Vmware 重新分配 Ubuntu 空间 先打开 Vmware &#xff0c;选择要重新分配空间的虚拟机 点击 编辑虚拟机设置 &#xff0c;再点击 硬盘 &#xff0c;再点击 扩展 选择预计扩展的空间&#xff0c;然后点击 扩展…

计算机毕业设计——ssm基于SSM的英语学习网站的设计与实现演示录像2021

作者&#xff1a;程序媛9688开发技术&#xff1a;SpringBoot、SSM、Vue、MySQL、JSP、ElementUI、Python、小程序等。 &#x1f31f;文末获取源码数据库&#x1f31f;感兴趣的可以先收藏起来&#xff0c;还有大家在毕设选题&#xff08;免费咨询指导选题&#xff09;&#xff0…

用 AI 革新医学:从早期检测到精准护理

AI 通过实现早期疾病检测、改进诊断和个性化护理来改变医学。 c AI 与放射科医生合作以提高诊断准确性 一段时间以来,AI 一直是医疗诊断的重要辅助工具。一项日本研究表明,ChatGPT 比该领域的专家进行了更准确的评估。 在执行了 150 次诊断后,神经放射学家记录了 AI 的 80…

vite5 打包项目兼容ie和低版本chrome

背景&#xff1a; vite打包后的项目 在低版本chrome无法使用 直接打包项目在69版本的chrome上无法加载 报错 解决方法&#xff1a; 使用vite官方推荐的插件 vitejs/plugin-legacy 1、下载 npm i vitejs/plugin-legacy -D 2、vite.config.js import legacy from "vit…

最逼真的AI换脸软件,Pluse下载介绍(可直播)

Pluse是基于人工智能的实时AI换脸工具&#xff0c;可以在无需任何前期数据训练的情况下&#xff0c;通过一张照片快速替换视频中的人脸&#xff0c;它支持高分辨率细节重建、色彩矫正&#xff0c;并能实时替换多目标人脸&#xff0c;非常适合娱乐社交、影视制作和虚拟现实等多种…

LeetCode题练习与总结:扁平化嵌套列表迭代器--341

一、题目描述 给你一个嵌套的整数列表 nestedList 。每个元素要么是一个整数&#xff0c;要么是一个列表&#xff1b;该列表的元素也可能是整数或者是其他列表。请你实现一个迭代器将其扁平化&#xff0c;使之能够遍历这个列表中的所有整数。 实现扁平迭代器类 NestedIterato…

vue系列=计算属性

1、计算属性 1、计算属性。当模板显示的某个数据需要通过已有数据进行一定的逻辑计算才能确定时&#xff0c;就可以选择用计算属性语法来实现。先来看利用计算属性语法重构后的代码&#xff0c;具体如下。 2、代码中多出一个配置对象computed。实际上这就是Vue中计算属性定义的…

在米尔电子MPSOC实现12G SDI视频采集H.265压缩SGMII万兆以太网推流

1. 引言 随着网络视频平台的发展&#xff0c;用户对于4K高清画质的需求日益增长。然而&#xff0c;许多用户发现&#xff0c;即使购买了视频平台的会员&#xff0c;观看4K内容时画质却不如预期&#xff0c;有时甚至还会出现模糊、卡顿的情况。这种现象背后涉及到视频编码、网络…

数据结构与算法实验练习(三)(排序及线性表的应用)

数据结构与算法分析课下实验练习&#xff0c;现记录一下解答过程&#xff0c;欢迎大家批评指正。 声明&#xff1a;本题目来源于西安交通大学电信学院原盛老师&#xff0c;任何单位或个人在使用、转载或引用本题目时&#xff0c;请务必标明出处为“西安交通大学电信学院原盛老…

使用java从提前pdf中的文字

引入依赖 <dependency><groupId>org.apache.pdfbox</groupId><artifactId>pdfbox</artifactId><version>2.0.28</version></dependency>样例代码 public static String pdf2text(InputStream inputStream) {String text &quo…

日志代码编写

&#x1f30e;日志代码编写 文章目录&#xff1a; 日志代码编写 了解日志 日志编写       日志等级       获取时间信息       获取文件名行号及处理可变参数列表       以宏的形式传参       日志加锁       日志消息输出方式 完整代码 …

HCIA笔记整合

第一部分&#xff1a; OSI七层模型 应用层&#xff1a;人机交互 抽象语言--------编码 表示层&#xff1a;编码------二进制 会话层&#xff1a;提供会话号 传输层&#xff1a;TCP/UDP 分段&#xff08;收到MTU值的限制&#xff09; MTU&#xff1a;最大传输单元&#xff…

Kafka集群数据迁移方案

概述 MirrorMaker2&#xff08;后文简称 MM2&#xff09;在 2019 年 12 月随 Kafka 2.4.0 一起推出。顾名思义&#xff0c;是为了解决 Kafka 集群之间数据复制和数据同步的问题而诞生的 Kafka 官方的数据复制工具。在实际生产中&#xff0c;经常被用来实现 Kafka 数据的备份&a…

Prometheus监控平台部署与应用

Prometheus特点 多维数据模型 PromSQL&#xff1a;一种灵活的查询语言&#xff0c;可以利用多维数据完成复杂的查询 不依赖分布式存储&#xff0c;单个服务器节点可直接工作 基于HTTP的pull方式采集时间序列数据 推送时间序列数据通过PushGateway组件支持 通过服务发现或静态配…

vue3 栅栏式拖拽布局组件

先看效果&#xff1a; 使用方法&#xff1a; 1、npm install fencelayout 2、引入使用 <template><Fencelayout><!-- 需要写的模块直接嵌套在这个下面就可以 --><div class"aaaa"><a-button>模块1</a-button></div><…

探索设计模式:命令模式

探索设计模式&#xff1a;命令模式 &#x1f9d0;1. 概念&#x1f3af;2. 作用&#x1f4e6;3. 实现3.1 定义命令接口3.2 实现具体命令3.3 实现接收者3.4 实现调用者3.5 使用 &#x1f4bb;4. 应用场景 命令模式&#xff08;Command Pattern&#xff09;就是一种行为型设计模式…

茅台最新任务脚本

茅台最新任务脚本 –小白教程— 这个脚本的作用是实现i茅台应用的自动预约功能&#xff0c;主要功能包括生成请求头、预约商品、计算距离和库存情况、发送微信推送消息等。 代码如下#!/usr/bin/python3cron: 0 0 9/21 * * * new Env(i茅台) import logging import sysimpor…