Retrofit+RxJava實(shí)現(xiàn)帶進(jìn)度條文件下載的方法

這篇文章將為大家詳細(xì)講解有關(guān)Retrofit+RxJava實(shí)現(xiàn)帶進(jìn)度條文件下載的方法，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

項(xiàng)目中需要使用到更新版本，因此研究了一下Retrofit的下載文件，和進(jìn)度條效果，其間也遇到了一些坑，寫出來加深一下記憶，也為別的同學(xué)提供一下思路。

先說一下版本控制吧，通用做法基本上是通過接口獲取服務(wù)器存儲(chǔ)的app版本號(hào)，與應(yīng)用的版本號(hào)進(jìn)行比較，版本較低就去更新，先看一下如何獲取應(yīng)用版本號(hào)吧

PackageManager packageManager = mActivity.getPackageManager();

 PackageInfo packageInfo = null;

 try {
 packageInfo = packageManager.getPackageInfo(mActivity.getPackageName(), 0);
 } catch (PackageManager.NameNotFoundException e) {
 e.printStackTrace();
 }

 String versionName = packageInfo.versionName;

可以看到使用的是Context中的getPackageManager方法來獲取PackageManager 對(duì)象，該對(duì)象可用于獲取版本的一些信息。

上面的屬于附內(nèi)容，接下來就是關(guān)于Retrofit+RxJava實(shí)現(xiàn)進(jìn)度條下載文件的功能，Retrofit本身不提供進(jìn)度條顯示的功能，但Retrofit默認(rèn)使用Okhttp來進(jìn)行網(wǎng)絡(luò)請(qǐng)求，這里就可以自定義攔截器來進(jìn)行攔截，實(shí)現(xiàn)進(jìn)度。Okhttp的Demo中也為我們提供了一份代碼，需要的可以去參考一下Progress.javar，可以看到攔截器的設(shè)置：

public class ProgressResponseBody extends ResponseBody {

 private ResponseBody responseBody;

 private ProgressListener progressListener;

 private BufferedSource bufferedSource;


 public ProgressResponseBody(ResponseBody responseBody,ProgressListener progressListener){

 this.responseBody=responseBody;

 this.progressListener=progressListener;
 }


 @Override
 public MediaType contentType() {

 return responseBody.contentType();
 }

 @Override
 public long contentLength() {

 return responseBody.contentLength();
 }

 @Override
 public BufferedSource source() {

 if(bufferedSource==null){

 bufferedSource= Okio.buffer(source(responseBody.source()));
 }

 return bufferedSource;
 }


 private Source source(Source source) {
 return new ForwardingSource(source) {
 long totalBytesRead = 0L;

 @Override
 public long read(Buffer sink, long byteCount) throws IOException {
 //當(dāng)前讀取字節(jié)數(shù)
 long bytesRead = super.read(sink, byteCount);
 //增加當(dāng)前讀取的字節(jié)數(shù)，如果讀取完成了bytesRead會(huì)返回-1
 totalBytesRead += bytesRead != -1 ? bytesRead : 0;
 //回調(diào)，如果contentLength()不知道長度，會(huì)返回-1

 progressListener.onProgress(totalBytesRead,responseBody.contentLength(),bytesRead,bytesRead==-1);
 return bytesRead;
 }
 };
 }
}

ProgressListener 用來監(jiān)聽進(jìn)度變化，回調(diào)到ProgressInterceptor中，ProgressInterceptor是一個(gè)自定義的攔截器，可以看一下代碼

public class ProgressInterceptor implements Interceptor {

 @Override
 public Response intercept(Chain chain) throws IOException {

 Response response=chain.proceed(chain.request());
 return response.newBuilder().body(new ProgressResponseBody(response.body(),progressListener)).build();
 }
 static final ProgressListener progressListener=new ProgressListener() {
 @Override
 public void onProgress(long progress, long total, long speed, boolean done) {

 Log.i("log","progress="+progress+"total="+total);
 }
 };
}

為了便于獲取progress，可以通過OkHttpClient的addNetworkInterceptor方法直接添加一個(gè)自定義的攔截器，例如：

 //為Okhttp設(shè)置攔截器
 OkHttpClient client = new OkHttpClient.Builder()
 .addNetworkInterceptor(new Interceptor() {
 @Override public Response intercept(Chain chain) throws IOException {
  Response originalResponse = chain.proceed(chain.request());
  return originalResponse.newBuilder()
  .body(new ProgressResponseBody(originalResponse.body(), progressListener))
  .build();
 }
 })
 .build();

 //進(jìn)度回調(diào)監(jiān)聽
 ProgressListener progressListener=new ProgressListener() {
 @Override
 public void onProgress(long progress, long total, long speed, boolean done) {

 Message message=new Message();

 message.obj=new AmallLoadBean(progress,total);

 progressHandler.sendMessage(message);
 }
 };

這里通過一個(gè)創(chuàng)建一個(gè)繼承自Handler的ProgressHandler靜態(tài)內(nèi)部類用于在主線程中刷新進(jìn)度，順帶提一下，使用static修飾ProgressHandler是因?yàn)殪o態(tài)內(nèi)部類默認(rèn)不持有外部類對(duì)象的引用，需要注意一下Handler的內(nèi)存泄漏，使用一下寫法：

//處理下載版本進(jìn)度
 public class ProgressHandler extends Handler{

 private WeakReference<Activity> mActivityWeakReference;
 public ProgressHandler(Activity activity){

 mActivityWeakReference=new WeakReference<Activity>(activity);

 }

 @Override
 public void handleMessage(Message msg) {
 if(mActivityWeakReference.get()!=null){
 AmallLoadBean amallLoadBean= (AmallLoadBean) msg.obj;
 long progress=amallLoadBean.getProgress();
 long total=amallLoadBean.getTotal();
 float cp=(float)progress/(float)total;

 }
 }
 }

繼續(xù)回到下載文件中，我才用的是Retrofit+RxJava的方法來實(shí)現(xiàn)，寫之前也看了一下別人寫的，好像不全，下滿也遇到了一些小坑，講一下吧：

observable.subscribeOn(Schedulers.io())
 .observeOn(Schedulers.io())
 .doOnNext(new Action1<ResponseBody>() {
  @Override
  public void call(ResponseBody responseBody) {

  saveFiles(responseBody);
  }
 })
 .observeOn(AndroidSchedulers.mainThread())
 .subscribe(new Observer<ResponseBody>() {
  @Override
  public void onCompleted() {
  installApk();

  }

  @Override
  public void onError(Throwable e) {

  ToastUtils.getInstance().showToast("請(qǐng)到應(yīng)用市場(chǎng)下載最新版本");
  }

  @Override
  public void onNext(ResponseBody responseBody) {

  }
 });
 }

通過RxJava的doOnNext在subscribe方法之前存儲(chǔ)文件，這里需要注意的是doOnNext方法需要在子線程中執(zhí)行，調(diào)用.observeOn(Schedulers.io())方法，然后再切換到主線程，否則文件下載不下來。當(dāng)文件下載完成時(shí)，在onCompleted方法中執(zhí)行installApk()方法安裝app。需要注意的是這里需要做權(quán)限的適配，因?yàn)槲业氖亲约悍庋b的因?yàn)榫筒荒贸鰜砹?，挺簡單就自己寫吧。保存文件的代碼給大家放出來了，通俗的語言：

/**
 * 保存文件
 */
 public void saveFiles(ResponseBody responseBody){

 InputStream inputStream = null;

 FileOutputStream fileOutputStream = null;

 byte[] buffer=new byte[2048];

 int len;

 File file=new File(saveFileName);

 if(!file.exists()){

 file.mkdirs();
 }

 try {
 inputStream=responseBody.byteStream();

 fileOutputStream=new FileOutputStream(file);

 while ((len=inputStream.read(buffer))!=-1){

 fileOutputStream.write(buffer,0,len);
 }

 inputStream.close();

 fileOutputStream.close();

 } catch (Exception e) {
 e.printStackTrace();
 }


 }

在安裝文件的時(shí)候，需要注意7.0以后的適配，代碼看看就好，和拍照適配的原理一直，都是Android對(duì)私密性文件的權(quán)限問題

 /**
 * 安裝apk
 *
 */
 private void installApk() {
 File apkfile = new File(saveFileName);
 if (!apkfile.exists()) {
 return;
 }
 //判斷版本號(hào)

 if(Build.VERSION.SDK_INT>=Build.VERSION_CODES.N){
 Uri apkUri = FileProvider.getUriForFile(activity, "******.fileprovider", apkfile);
 Intent install = new Intent(Intent.ACTION_VIEW);
 install.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
 //添加這一句表示對(duì)目標(biāo)應(yīng)用臨時(shí)授權(quán)該Uri所代表的文件
 install.addFlags(Intent.FLAG_GRANT_READ_URI_PERMISSION);
 install.setDataAndType(apkUri, "application/vnd.android.package-archive");
 activity.startActivity(install);

 }else{

 Intent i = new Intent(Intent.ACTION_VIEW);
 i.setDataAndType(Uri.parse("file://" + apkfile.toString()), "application/vnd.android.package-archive");
 activity.startActivity(i);
 }

 }

關(guān)于“Retrofit+RxJava實(shí)現(xiàn)帶進(jìn)度條文件下載的方法”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。