溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
1.前言
最近要做一個帶進度條下載文件的功能，網上看了一圈，發現好多都是基于 OkHttpClient 添加攔截器來實現的，個人覺得略顯復雜，所以還是采用最簡單的方法來實現：基于文件寫入來進行進度的監聽。
2.實現步驟
2.1 設計監聽接口
根據需求設計一下接口：
public interface DownloadListener {
void onStart();//下載開始
void onProgress(int progress);//下載進度
void onFinish(String path);//下載完成
void onFail(String errorInfo);//下載失敗
}
如果還需下載速度等等，可以自行設計接口和參數。
2.2 編寫網絡接口Service
public interface DownloadService {
@Streaming
@GET
Call<ResponseBody> download(@Url String url);
}
跟正常接口寫法基本一致，需要注意的是要添加 @Streaming 注解。
默認情況下， Retrofit 在處理結果前會將服務器端的 Response 全部讀進內存。如果服務器端返回的是一個非常大的文件，則容易發生oom。使用 @Streaming 的主要作用就是把實時下載的字節就立馬寫入磁盤，而不用把整個文件讀入內存。
2.3 開始網絡請求
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")
//通過線程池獲取一個線程，指定callback在子線程中運行。
.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寫入到從磁盤中，詳見下面分析
//注意，這個方法是運行在子線程中的
writeResponseToDisk(path, response, downloadListener);
}
@Override
public void onFailure(@NonNull Call<ResponseBody> call, @NonNull Throwable throwable) {
downloadListener.onFail("網絡錯誤～");
}
});
}
}
在 Retrofit 中， Callback 默認運行在主線程中，如果我們直接將 Response 寫到磁盤這一操作直接運行在主線程中，會報 NetworkOnMainThreadException 異常。所以必須放在子線程中去運行。
目前為止，都還是一個很正常的網絡請求。所以，還是很簡單的。下面重頭戲來了。
2.4 監聽下載進度
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();
//創建文件
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;
//計算當前下載進度
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();
}
}
}
所以，實際就是通過監聽文件的寫入來實現進度的監聽。
2.5 使用例子
String url = "";
String path = "";
DownloadUtil.download(url, path, new DownloadListener() {
@Override
public void onStart() {
//運行在子線程
}
@Override
public void onProgress(int progress) {
//運行在子線程
}
@Override
public void onFinish(String path) {
//運行在子線程
}
@Override
public void onFail(String errorInfo) {
//運行在子線程
}
});
注意，上面的回調都是運行在子線程中。如果需要更新UI等操作，可以使用Handler等來進行更新。
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
