Android Okhttp断点续传的示例分析

发布时间:2021-06-26 11:38:37 作者:小新
来源:亿速云 阅读:200

这篇文章主要为大家展示了“Android Okhttp断点续传的示例分析”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“Android Okhttp断点续传的示例分析”这篇文章吧。

Http 断点续传知识点

什么是断点续传

指的是在上传/下载时,将任务(一个文件或压缩包)人为的划分为几个部分,每一个部分采用一个线程进行上传/下载,如果碰到网络故障,可以从已经上传/下载的部分开始继续上传/下载未完成的部分,而没有必要从头开始上传/下载。可以节省时间,提高速度。

Http 怎么支持断点续传的?

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

Range

客户端想要获取文件的部分内容,那么它就需要请求头部中的 Range 参数中指定获取内容的起始字节的位置和终止字节的位置,它的格式一般为:

Range:(unit=first byte pos)-[last byte pos]

例如:

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

Content Range

在收到客户端中携带 Range 的请求后,服务器会在响应的头部中添加 Content Range 参数,返回可接受的文件字节范围及其文件的总大小。它的格式如下:

Content-Range: bytes (unit first byte pos) - [last byte pos]/[entity legth]

例如:

Content-Range: bytes 0-499/22400    // 0-499 是指当前发送的数据的范围,而 22400 则是文件的总大小。

使用断点续传和不使用断点续传的响应内容区别

不使用断点续传

HTTP/1.1 200 Ok

使用断点续传

HTTP/1.1 206 Partial Content

处理请求资源发生改变的问题

在现实的场景中,服务器中的文件是会有发生变化的情况的,那么我们发起续传的请求肯定是失败的,那么为了处理这种服务器文件资源发生改变的问题,在 RFC2616 中定义了 Last-Modified 和  Etag 来判断续传文件资源是否发生改变。

Last-Modified & If-Modified-Since(文件最后修改时间)

Last-Modified:记录 Http 页面最后修改时间的 Http 头部参数,Last-Modified 是由服务端发送给客户端的
If-Modified-Since:记录 Http 页面最后修改时间的 Http 头部参数,If-Modified-Since 是有客户端发送给服务端的
验证过程

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

Etag:作为文件的唯一标志,这个标志可以是文件的 hash 值或者是一个版本

if-Range:用于判断实体是否发生改变,如果实体未改变,服务器发送客户端丢失的部分,否则发送整个实体。一般格式:

If-Range: Etag | HTTP-Date

If-Range 可以使用 Etag 或者 Last-Modified 返回的值。当没有 ETage 却有 Last-modified 时,可以把 Last-modified 作为 If-Range 字段的值

验证过程

检查服务器是否支持断点续传

Android Okhttp断点续传的示例分析

我们使用 curl 进行检测,可以看出以下的几个关键信息

OkHttp 断点下载

断点下载思路

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

DownloadTask.java

/**
 * 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
   */
  @Override
  protected 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
   */
  @Override
  protected void onProgressUpdate(Integer... values) {
    int progress = values[0];
    if (progress > lastProgress) {
      listener.onProgress(progress);
      lastProgress = progress;
    }
  }

  /**
   * 当后台任务执行完毕并通过Return语句进行返回时,这个方法就很快被调用。返回的数据会作为参数
   * 传递到此方法中,可以利用返回的数据来进行一些UI操作。
   *
   * @param status
   */
  @Override
  protected 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;
  }

}

DownloadListener.java

public class DownloadListener {


  /**
   * 通知当前的下载进度
   * @param progress
   */
  void onProgress(int progress);

  /**
   * 通知下载成功
   */
  void onSuccess();

  /**
   * 通知下载失败
   */
  void onFailed();

  /**
   * 通知下载暂停
   */
  void onPaused();

  /**
   * 通知下载取消事件
   */
  void onCanceled();

}

以上是“Android Okhttp断点续传的示例分析”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

推荐阅读:
  1. Android OkHttp, 一行代码 OkHttp提升请求稳定性
  2. Android架构师之路 网络层架构设计与实战

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

android okhttp

上一篇:Android WorkManager的示例分析

下一篇:android studio3.4如何安装

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》