Android Okhttp断点续传面试深入解析

前言

我们在刷一下面试题的时候，有时候会看到一些大厂会问关于断点续传的原理，那么今天在这里从 http 断点续传知识和 android 中如何实现断点续传的思路来做一个关于 android 断点续传原理的总结。

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 是有客户端发送给服务端的
验证过程

• step 1：客户端缓存从服务端获取的页面
• step 1：客户端访问相同页面时，客户端将服务器发送过来的  last-modified 通过 if-modified-since 发送给服务器
• step 2：服务器通过客户端发送过来的 if-modified-since 进行判断客户端当前的缓存的页面是否为最新的
  • 如果不是最新的，那么就发送最新的页面给客户端
  • 如果是最新的，那么就发送 304 告诉客户端它本地缓存的页面是最新的

etag & if-range（文件唯一标志）

etag：作为文件的唯一标志，这个标志可以是文件的 hash 值或者是一个版本

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

if-range: etag | http-date

if-range 可以使用 etag 或者 last-modified 返回的值。当没有 etage 却有 last-modified 时，可以把 last-modified 作为 if-range 字段的值

验证过程

• step 1：客户端发起续传请求，头部包含 range 和 if-range 参数
• step 2：服务器中收到客户端的请求之后，将客户端和服务器的 etag 进行比对
  • 相等：请求文件资源没有发生变化，应答报文为 206
  • 不相等：请求文件资源发生变化，应答报文为 200

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

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

• http/1.1 206 partial content
• content-range: bytes 10-222/7877
• etag: "1ec5-502264e2ae4c0"
• last-modified: wed, 03 sep 2014 10:00:27 gmt

okhttp 断点下载

断点下载思路

• step 1：判断检查本地是否有下载文件，若存在，则获取已下载的文件大小 downloadlength，若不存在，那么本地已下载文件的长度为 0
• step 2：获取将要下载的文件总大小（http 响应头部的 content-length)
• step 3：比对已下载文件大小和将要下载的文件总大小（contentlength），判断要下载的长度
• step 4：再即将发起下载请求的 http 头部中添加即将下载的文件大小范围（range: bytes = downloadlength - contentlength)

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();

}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。