Android Retrofit文件下載進(jìn)度顯示問題的解決方法
綜述
在Retrofit2.0使用詳解這篇文章中詳細(xì)介紹了retrofit的用法。并且在retrofit中我們可以通過ResponseBody進(jìn)行對(duì)文件的下載。但是在retrofit中并沒有為我們提供顯示下載進(jìn)度的接口。在項(xiàng)目中，若是用戶下載一個(gè)文件，無(wú)法實(shí)時(shí)給用戶顯示下載進(jìn)度，這樣用戶的體驗(yàn)也是非常差的。那么下面就介紹一下在retrofit用于文件的下載如何實(shí)時(shí)跟蹤下載進(jìn)度。
演示
Retrofit文件下載進(jìn)度更新的實(shí)現(xiàn)
在retrofit2.0中他依賴于Okhttp，所以如果我們需要解決這個(gè)問題還需要從這個(gè)OKhttp來(lái)入手。在Okhttp中有一個(gè)依賴包Okio。Okio也是有square公司所開發(fā)，它是java.io和java.nio的補(bǔ)充，使用它更容易訪問、存儲(chǔ)和處理數(shù)據(jù)。在這里需要使用Okio中的Source類。在這里Source可以看做InputStream。對(duì)于Okio的詳細(xì)使用在這里就不在介紹。下面來(lái)看一下具體實(shí)現(xiàn)。
在這里我們首先寫一個(gè)接口，用于監(jiān)聽下載的進(jìn)度。對(duì)于文件的下載，我們需要知道下載的進(jìn)度，文件的總大小，以及是否操作完成。于是有了下面這樣一個(gè)接口。
package com.ljd.retrofit.progress;
/**
* Created by ljd on 3/29/16.
*/
public interface ProgressListener {
/**
* @param progress 已經(jīng)下載或上傳字節(jié)數(shù)
* @param total 總字節(jié)數(shù)
* @param done 是否完成
*/
void onProgress(long progress, long total, boolean done);
}
對(duì)于文件的下載我們需要重寫ResponseBody類中的一些方法。
package com.ljd.retrofit.progress;
import java.io.IOException;
import okhttp3.MediaType;
import okhttp3.ResponseBody;
import okio.Buffer;
import okio.BufferedSource;
import okio.ForwardingSource;
import okio.Okio;
import okio.Source;
/**
* Created by ljd on 3/29/16.
*/
public class ProgressResponseBody extends ResponseBody {
private final ResponseBody responseBody;
private final 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 {
long bytesRead = super.read(sink, byteCount);
totalBytesRead += bytesRead != -1 ? bytesRead : 0;
progressListener.onProgress(totalBytesRead, responseBody.contentLength(), bytesRead == -1);
return bytesRead;
}
};
}
}
在上面ProgressResponseBody類中，我們計(jì)算已經(jīng)讀取文件的字節(jié)數(shù)，并且調(diào)用了ProgressListener接口。所以這個(gè)ProgressListener接口是在子線程中運(yùn)行的。
下面就來(lái)看一下是如何使用這個(gè)ProgressResponseBody。
package com.ljd.retrofit.progress;
import android.util.Log;
import java.io.IOException;
import okhttp3.Interceptor;
import okhttp3.OkHttpClient;
/**
* Created by ljd on 4/12/16.
*/
public class ProgressHelper {
private static ProgressBean progressBean = new ProgressBean();
private static ProgressHandler mProgressHandler;
public static OkHttpClient.Builder addProgress(OkHttpClient.Builder builder){
if (builder == null){
builder = new OkHttpClient.Builder();
}
final ProgressListener progressListener = new ProgressListener() {
//該方法在子線程中運(yùn)行
@Override
public void onProgress(long progress, long total, boolean done) {
Log.d("progress:",String.format("%d%% done\n",(100 * progress) / total));
if (mProgressHandler == null){
return;
}
progressBean.setBytesRead(progress);
progressBean.setContentLength(total);
progressBean.setDone(done);
mProgressHandler.sendMessage(progressBean);
}
};
//添加攔截器，自定義ResponseBody，添加下載進(jìn)度
builder.networkInterceptors().add(new Interceptor() {
@Override
public okhttp3.Response intercept(Chain chain) throws IOException {
okhttp3.Response originalResponse = chain.proceed(chain.request());
return originalResponse.newBuilder().body(
new ProgressResponseBody(originalResponse.body(), progressListener))
.build();
}
});
return builder;
}
public static void setProgressHandler(ProgressHandler progressHandler){
mProgressHandler = progressHandler;
}
}
我們通過為OkhttpClient添加一個(gè)攔截器來(lái)使用我們自定義的ProgressResponseBody。并且在這里我們可以通過實(shí)現(xiàn)ProgressListener接口。來(lái)獲取下載進(jìn)度了。但是在這里依然存在一個(gè)問題，剛才說(shuō)到這個(gè)ProgressListener接口運(yùn)行在子線程中。也就是說(shuō)在ProgressListener這個(gè)接口中我們無(wú)法進(jìn)行ui操作。而我們獲取文件下載的進(jìn)度往往則是需要一個(gè)進(jìn)度條進(jìn)行ui顯示。顯然這并不是我們想要的結(jié)果。
在這個(gè)時(shí)候我們就需要使用Handler了。我們可以通過Handler將子線程中的ProgressListener的數(shù)據(jù)發(fā)送到ui線程中進(jìn)行處理。也就是說(shuō)我們?cè)赑rogressListener接口中的操作只是將其參數(shù)通過Handler發(fā)送出去。很顯然在上面的代碼中我們通過ProgressHandler來(lái)發(fā)送消息。那么就來(lái)看一下具體操作。
這里我們創(chuàng)建一個(gè)對(duì)象，用于存放ProgressListener中的參數(shù)。
package com.example.ljd.retrofit.pojo;
import java.util.ArrayList;
import java.util.List;
/**
* Created by ljd on 3/29/16.
*/
public class RetrofitBean {
private Integer total_count;
private Boolean incompleteResults;
private List<Item> items = new ArrayList<Item>();
/**
*
* @return
* The totalCount
*/
public Integer getTotalCount() {
return total_count;
}
/**
*
* @param totalCount
* The total_count
*/
public void setTotalCount(Integer totalCount) {
this.total_count = totalCount;
}
/**
*
* @return
* The incompleteResults
*/
public Boolean getIncompleteResults() {
return incompleteResults;
}
/**
*
* @param incompleteResults
* The incomplete_results
*/
public void setIncompleteResults(Boolean incompleteResults) {
this.incompleteResults = incompleteResults;
}
/**
*
* @return
* The items
*/
public List<Item> getItems() {
return items;
}
}
然后我們?cè)趧?chuàng)建一個(gè)ProgressHandler類。
package com.ljd.retrofit.progress;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
/**
* Created by ljd on 4/12/16.
*/
public abstract class ProgressHandler {
protected abstract void sendMessage(ProgressBean progressBean);
protected abstract void handleMessage(Message message);
protected abstract void onProgress(long progress, long total, boolean done);
protected static class ResponseHandler extends Handler{
private ProgressHandler mProgressHandler;
public ResponseHandler(ProgressHandler mProgressHandler, Looper looper) {
super(looper);
this.mProgressHandler = mProgressHandler;
}
@Override
public void handleMessage(Message msg) {
mProgressHandler.handleMessage(msg);
}
}
}
上面的ProgressHandler他是一個(gè)抽象類。在這里我們需要通過Handler對(duì)象進(jìn)行發(fā)送和處理消息。于是定義了兩個(gè)抽象方法sendMessage和handleMessage。之后又定義了一個(gè)抽象方法onProgress來(lái)處理下載進(jìn)度的顯示，而這個(gè)onProgress則是我們需要在ui線程進(jìn)行調(diào)用。最后創(chuàng)建了一個(gè)繼承自Handler的ResponseHandler內(nèi)部類。為了避免內(nèi)存泄露我們使用static關(guān)鍵字。
下面來(lái)創(chuàng)建一個(gè)DownloadProgressHandler類，他繼承于ProgressHandler，用來(lái)發(fā)送和處理消息。
package com.ljd.retrofit.progress;
import android.os.Looper;
import android.os.Message;
/**
* Created by ljd on 4/12/16.
*/
public abstract class DownloadProgressHandler extends ProgressHandler{
private static final int DOWNLOAD_PROGRESS = 1;
protected ResponseHandler mHandler = new ResponseHandler(this, Looper.getMainLooper());
@Override
protected void sendMessage(ProgressBean progressBean) {
mHandler.obtainMessage(DOWNLOAD_PROGRESS,progressBean).sendToTarget();
}
@Override
protected void handleMessage(Message message){
switch (message.what){
case DOWNLOAD_PROGRESS:
ProgressBean progressBean = (ProgressBean)message.obj;
onProgress(progressBean.getBytesRead(),progressBean.getContentLength(),progressBean.isDone());
}
}
}
在這里我們接收到消息以后調(diào)用抽象方法onProgress，這樣一來(lái)我們只需要?jiǎng)?chuàng)建一個(gè)DownloadProgressHandler對(duì)象，實(shí)現(xiàn)onProgress即可。
對(duì)于上面的分析，下面我們就來(lái)看一下是如何使用的。
package com.example.ljd.retrofit.download;
import android.app.ProgressDialog;
import android.os.Environment;
import android.os.Looper;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import com.example.ljd.retrofit.R;
import com.ljd.retrofit.progress.DownloadProgressHandler;
import com.ljd.retrofit.progress.ProgressHelper;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import butterknife.ButterKnife;
import butterknife.OnClick;
import okhttp3.OkHttpClient;
import okhttp3.ResponseBody;
import retrofit2.Call;
import retrofit2.Callback;
import retrofit2.Response;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;
public class DownloadActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_download);
ButterKnife.bind(this);
}
@Override
protected void onDestroy() {
ButterKnife.unbind(this);
super.onDestroy();
}
@OnClick(R.id.start_download_btn)
public void onClickButton(){
retrofitDownload();
}
private void retrofitDownload(){
//監(jiān)聽下載進(jìn)度
final ProgressDialog dialog = new ProgressDialog(this);
dialog.setProgressNumberFormat("%1d KB/%2d KB");
dialog.setTitle("下載");
dialog.setMessage("正在下載，請(qǐng)稍后...");
dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
dialog.setCancelable(false);
dialog.show();
Retrofit.Builder retrofitBuilder = new Retrofit.Builder()
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.baseUrl("http://msoftdl.#");
OkHttpClient.Builder builder = ProgressHelper.addProgress(null);
DownloadApi retrofit = retrofitBuilder
.client(builder.build())
.build().create(DownloadApi.class);
ProgressHelper.setProgressHandler(new DownloadProgressHandler() {
@Override
protected void onProgress(long bytesRead, long contentLength, boolean done) {
Log.e("是否在主線程中運(yùn)行", String.valueOf(Looper.getMainLooper() == Looper.myLooper()));
Log.e("onProgress",String.format("%d%% done\n",(100 * bytesRead) / contentLength));
Log.e("done","--->" + String.valueOf(done));
dialog.setMax((int) (contentLength/1024));
dialog.setProgress((int) (bytesRead/1024));
if(done){
dialog.dismiss();
}
}
});
Call<ResponseBody> call = retrofit.retrofitDownload();
call.enqueue(new Callback<ResponseBody>() {
@Override
public void onResponse(Call<ResponseBody> call, Response<ResponseBody> response) {
try {
InputStream is = response.body().byteStream();
File file = new File(Environment.getExternalStorageDirectory(), "12345.apk");
FileOutputStream fos = new FileOutputStream(file);
BufferedInputStream bis = new BufferedInputStream(is);
byte[] buffer = new byte[1024];
int len;
while ((len = bis.read(buffer)) != -1) {
fos.write(buffer, 0, len);
fos.flush();
}
fos.close();
bis.close();
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
public void onFailure(Call<ResponseBody> call, Throwable t) {
}
});
}
}
總結(jié)
對(duì)于上面的實(shí)現(xiàn)我們可以看出是通過OkhttpClient實(shí)現(xiàn)的。也正是由于在retrofit2.0中它依賴于OkHttp，因此對(duì)于OkHttp的功能retrofit也都具備。利用這一特性，我們可以通過定制OkhttpClient來(lái)配置我們的retrofit。
源碼下載：https://github.com/lijiangdong/retrofit-example
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
- Android文件下載進(jìn)度條的實(shí)現(xiàn)代碼
- Android zip文件下載和解壓實(shí)例
- Android實(shí)現(xiàn)文件下載進(jìn)度顯示功能
- Android 文件下載三種基本方式
- Android實(shí)現(xiàn)簡(jiǎn)單的文件下載與上傳
- Android 將文件下載到指定目錄的實(shí)現(xiàn)代碼
- Android文件下載功能實(shí)現(xiàn)代碼
- Android基于HttpUrlConnection類的文件下載實(shí)例代碼
- android實(shí)現(xiàn)文件下載功能
- Android簡(jiǎn)單實(shí)現(xiàn)文件下載
相關(guān)文章
Android簡(jiǎn)單實(shí)現(xiàn)自定義流式布局的方法
這篇文章主要介紹了Android簡(jiǎn)單實(shí)現(xiàn)自定義流式布局的方法,結(jié)合實(shí)例形式分析了Android流式布局的原理與實(shí)現(xiàn)技巧,需要的朋友可以參考下2016-07-07
Java和Android的LRU緩存及實(shí)現(xiàn)原理
本文主要介紹 Java和Android的LRU緩存及實(shí)現(xiàn)原理，這里整理了詳細(xì)的資料，有興趣的小伙伴可以參考下便于學(xué)習(xí)理解2016-08-08
android開發(fā)教程之實(shí)現(xiàn)listview下拉刷新和上拉刷新效果
這篇文章主要介紹了android實(shí)現(xiàn)listview下拉刷新和上拉刷新效果,Android的ListView上拉下拉刷新，原理都一樣，在Touch事件中操作header/footer的paddingTop屬性，需要的朋友可以參考下2014-02-02
這篇文章主要為大家詳細(xì)介紹了Android TabWidget底部顯示效果的三種方式，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-03-03
Android 在程序運(yùn)行時(shí)申請(qǐng)權(quán)限的實(shí)例講解
下面小編就為大家分享一篇Android 在程序運(yùn)行時(shí)申請(qǐng)權(quán)限的實(shí)例講解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來(lái)看看吧2018-01-01
這篇文章主要介紹了Android中捕捉menu按鍵點(diǎn)擊事件的方法,涉及Android響應(yīng)menu菜單項(xiàng)點(diǎn)擊事件的相關(guān)技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-07-07
Android開發(fā)之資源文件用法實(shí)例總結(jié)
這篇文章主要介紹了Android開發(fā)之資源文件用法,結(jié)合實(shí)例形式總結(jié)分析了Android開發(fā)過程中針對(duì)資源文件的常見操作技巧,需要的朋友可以參考下2016-02-02
這篇文章主要介紹了Android中處理崩潰異常的相關(guān)資料,需要的朋友可以參考下2015-12-12
Android實(shí)現(xiàn)簡(jiǎn)單的照相功能
這篇文章主要為大家詳細(xì)介紹了Android實(shí)現(xiàn)簡(jiǎn)單的照相功能，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-03-03
Android編程之控件可拖動(dòng)的實(shí)現(xiàn)方法
這篇文章主要介紹了Android編程之控件可拖動(dòng)的實(shí)現(xiàn)方法,實(shí)例分析了Android響應(yīng)點(diǎn)擊及觸摸事件的相關(guān)技巧,需要的朋友可以參考下2016-02-02