HTTP/1.1 200 Ok

HTTP/1.1 206 Partial Content

If-Range: Etag | HTTP-Date

/**
 * String 在執(zhí)行AsyncTask時(shí)需要傳入的參數(shù)，可用于在后臺(tái)任務(wù)中使用。
 * Integer 后臺(tái)任務(wù)執(zhí)行時(shí)，如果需要在界面上顯示當(dāng)前的進(jìn)度，則使用這里指定的泛型作為進(jìn)度單位。
 * Integer 當(dāng)任務(wù)執(zhí)行完畢后，如果需要對(duì)結(jié)果進(jìn)行返回，則使用這里指定的泛型作為返回值類型。
 */
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;
  }

  /**
   * 這個(gè)方法中的所有代碼都會(huì)在子線程中運(yùn)行，我們應(yīng)該在這里處理所有的耗時(shí)任務(wù)。
   *
   * @param params
   * @return
   */
  @Override
  protected Integer doInBackground(String... params) {
    InputStream is = null;
    RandomAccessFile savedFile = null;
    File file = null;
    long downloadLength = 0;  //記錄已經(jīng)下載的文件長(zhǎng)度
    //文件下載地址
    String downloadUrl = params[0];
    //下載文件的名稱
    String fileName = downloadUrl.substring(downloadUrl.lastIndexOf("/"));
    //下載文件存放的目錄
    String directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS).getPath();
    //創(chuàng)建一個(gè)文件
    file = new File(directory + fileName);
    if (file.exists()) {
      //如果文件存在的話，得到文件的大小
      downloadLength = file.length();
    }
    //得到下載內(nèi)容的大小
    long contentLength = getContentLength(downloadUrl);
    if (contentLength == 0) {
      return TYPE_FAILED;
    } else if (contentLength == downloadLength) {
      //已下載字節(jié)和文件總字節(jié)相等，說明已經(jīng)下載完成了
      return TYPE_SUCCESS;
    }
    OkHttpClient client = new OkHttpClient();
    /**
     * HTTP請(qǐng)求是有一個(gè)Header的，里面有個(gè)Range屬性是定義下載區(qū)域的，它接收的值是一個(gè)區(qū)間范圍，
     * 比如：Range:bytes=0-10000。這樣我們就可以按照一定的規(guī)則，將一個(gè)大文件拆分為若干很小的部分，
     * 然后分批次的下載，每個(gè)小塊下載完成之后，再合并到文件中；這樣即使下載中斷了，重新下載時(shí)，
     * 也可以通過文件的字節(jié)長(zhǎng)度來判斷下載的起始點(diǎn)，然后重啟斷點(diǎn)續(xù)傳的過程，直到最后完成下載過程。
     */
    Request request = new Request.Builder()
        .addHeader("RANGE", "bytes=" + downloadLength + "-" + contentLength) //斷點(diǎn)續(xù)傳要用到的，指示下載的區(qū)間
        .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);//跳過已經(jīng)下載的字節(jié)
        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);
            //計(jì)算已經(jīng)下載的百分比
            int progress = (int) ((total + downloadLength) * 100 / contentLength);
            //注意：在doInBackground()中是不可以進(jìn)行UI操作的，如果需要更新UI,比如說反饋當(dāng)前任務(wù)的執(zhí)行進(jìn)度，
            //可以調(diào)用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;
  }

  /**
   * 當(dāng)在后臺(tái)任務(wù)中調(diào)用了publishProgress(Progress...)方法之后，onProgressUpdate()方法
   * 就會(huì)很快被調(diào)用，該方法中攜帶的參數(shù)就是在后臺(tái)任務(wù)中傳遞過來的。在這個(gè)方法中可以對(duì)UI進(jìn)行操作，利用參數(shù)中的數(shù)值就可以
   * 對(duì)界面進(jìn)行相應(yīng)的更新。
   *
   * @param values
   */
  @Override
  protected void onProgressUpdate(Integer... values) {
    int progress = values[0];
    if (progress > lastProgress) {
      listener.onProgress(progress);
      lastProgress = progress;
    }
  }

  /**
   * 當(dāng)后臺(tái)任務(wù)執(zhí)行完畢并通過Return語句進(jìn)行返回時(shí)，這個(gè)方法就很快被調(diào)用。返回的數(shù)據(jù)會(huì)作為參數(shù)
   * 傳遞到此方法中，可以利用返回的數(shù)據(jù)來進(jìn)行一些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;
  }

  /**
   * 得到下載內(nèi)容的完整大小
   *
   * @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 {


  /**
   * 通知當(dāng)前的下載進(jìn)度
   * @param progress
   */
  void onProgress(int progress);

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

  /**
   * 通知下載失敗
   */
  void onFailed();

  /**
   * 通知下載暫停
   */
  void onPaused();

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

}