使用Retrofit下載文件并實(shí)現(xiàn)進(jìn)度監(jiān)聽的示例

public interface DownloadListener {
  void onStart();//下載開始

  void onProgress(int progress);//下載進(jìn)度

  void onFinish(String path);//下載完成

  void onFail(String errorInfo);//下載失敗
}

public interface DownloadService {

  @Streaming
  @GET
  Call<ResponseBody> download(@Url String url);
}

public class DownloadUtil {

  public static void download(String url, final String path, final DownloadListener downloadListener) {

    Retrofit retrofit = new Retrofit.Builder()
        .baseUrl("http://www.xxx.com")
        //通過線程池獲取一個(gè)線程，指定callback在子線程中運(yùn)行。
        .callbackExecutor(Executors.newSingleThreadExecutor())
        .build();

    DownloadService service = retrofit.create(DownloadService.class);

    Call<ResponseBody> call = service.download(url);
    call.enqueue(new Callback<ResponseBody>() {
      @Override
      public void onResponse(@NonNull Call<ResponseBody> call, @NonNull final Response<ResponseBody> response) {
        //將Response寫入到從磁盤中，詳見下面分析
        //注意，這個(gè)方法是運(yùn)行在子線程中的
        writeResponseToDisk(path, response, downloadListener);
      }

      @Override
      public void onFailure(@NonNull Call<ResponseBody> call, @NonNull Throwable throwable) {
        downloadListener.onFail("網(wǎng)絡(luò)錯(cuò)誤～");
      }
    });
  }
}

private static void writeResponseToDisk(String path, Response<ResponseBody> response, DownloadListener downloadListener) {
    //從response獲取輸入流以及總大小
    writeFileFromIS(new File(path), response.body().byteStream(), response.body().contentLength(), downloadListener);
  }

  private static int sBufferSize = 8192;

  //將輸入流寫入文件
  private static void writeFileFromIS(File file, InputStream is, long totalLength, DownloadListener downloadListener) {
    //開始下載
    downloadListener.onStart();

    //創(chuàng)建文件
    if (!file.exists()) {
      if (!file.getParentFile().exists())
        file.getParentFile().mkdir();
      try {
        file.createNewFile();
      } catch (IOException e) {
        e.printStackTrace();
        downloadListener.onFail("createNewFile IOException");
      }
    }

    OutputStream os = null;
    long currentLength = 0;
    try {
      os = new BufferedOutputStream(new FileOutputStream(file));
      byte data[] = new byte[sBufferSize];
      int len;
      while ((len = is.read(data, 0, sBufferSize)) != -1) {
        os.write(data, 0, len);
        currentLength += len;
        //計(jì)算當(dāng)前下載進(jìn)度
        downloadListener.onProgress((int) (100 * currentLength / totalLength));
      }
      //下載完成，并返回保存的文件路徑
      downloadListener.onFinish(file.getAbsolutePath());
    } catch (IOException e) {
      e.printStackTrace();
      downloadListener.onFail("IOException");
    } finally {
      try {
        is.close();
      } catch (IOException e) {
        e.printStackTrace();
      }
      try {
        if (os != null) {
          os.close();
        }
      } catch (IOException e) {
        e.printStackTrace();
      }
    }
  }

String url = "";
      String path = "";
      DownloadUtil.download(url, path, new DownloadListener() {
        @Override
        public void onStart() {
          //運(yùn)行在子線程
        }

        @Override
        public void onProgress(int progress) {
          //運(yùn)行在子線程
        }

        @Override
        public void onFinish(String path) {
          //運(yùn)行在子線程
        }

        @Override
        public void onFail(String errorInfo) {
          //運(yùn)行在子線程
        }
      });