android上传图片文件至c 服务器,Android 史上最优雅的实现文件上传、下载及进度的监听...
本文已授權「劉望舒」微信公眾號獨家原創發布
前言
本文將直接使用RxHttp庫實現文件上傳、下載、斷點下載、進度的監聽，不對RxHttp做過多講解，如果對RxHttp不了解，請移步
本文目的在于讓更多的讀者知道RxHttp庫，如果您已閱讀上面4篇文章，本文可直接跳過，感謝你的支持。🙏🙏。
上傳
RxHttp.postForm("http://...") //發送Form表單形式的Post請求
.add("key", "value")
.add("file1", new File("xxx/1.png")) //添加file對象
.add("file2", new File("xxx/2.png"))
.asString() //asXXX操作符，是異步操作
.as(RxLife.asOnMain(this)) //感知生命周期，并在主線程回調
.subscribe(s -> {
//上傳成功，拿到Http返回值，這里返回值為String類型
}, throwable -> {
//上傳失敗
});
復制代碼
注：如果需要對Http的返回值做解析，可在使用asParser操作符時，傳入一個解析器Parser
帶進度上傳
帶進度上傳使用asUpload(Progress,Scheduler)操作符
RxHttp.postForm("http://www.......") //發送Form表單形式的Post請求
.add("key1", "value1")//添加參數，非必須
.add("file1", new File("xxx/1.png"))
.asUpload(progress -> {
//上傳進度回調,0-100，僅在進度有更新時才會回調,最多回調101次，最后一次回調Http執行結果
int currentProgress = progress.getProgress(); //當前進度 0-100
long currentSize = progress.getCurrentSize(); //當前已上傳的字節大小
long totalSize = progress.getTotalSize(); //要上傳的總字節大小
}, AndroidSchedulers.mainThread())//指定主線程回調
.as(RxLife.as(this)) //感知生命周期
.subscribe(s -> { //s為String類型，由SimpleParser類里面的泛型決定的
//上傳成功，處理相關邏輯
}, throwable -> {
//上傳失敗，處理相關邏輯
});
復制代碼
注：如果需要對Http的返回值做解析，可使用asUpload(Parser,Progress,Scheduler)方法，傳入一個解析器Parser
下載
//文件存儲路徑
String destPath = getExternalCacheDir() + "/" + System.currentTimeMillis() + ".apk";
RxHttp.get("http://update.9158.com/miaolive/Miaolive.apk")
.asDownload(destPath) //注意這里使用asDownload操作符，并傳入本地路徑
.as(RxLife.asOnMain(this)) //感知生命周期，并在主線程回調
.subscribe(s -> {
//下載成功,回調文件下載路徑
}, throwable -> {
//下載失敗
});
復制代碼
帶進度下載
帶進度下載使用asDownload(String,Consumer,Scheduler)方法
//文件存儲路徑
String destPath = getExternalCacheDir() + "/" + System.currentTimeMillis() + ".apk";
RxHttp.get("http://update.9158.com/miaolive/Miaolive.apk")
.asDownload(destPath, progress -> {
//下載進度回調,0-100，僅在進度有更新時才會回調，最多回調101次，最后一次回調文件存儲路徑
int currentProgress = progress.getProgress(); //當前進度 0-100
long currentSize = progress.getCurrentSize(); //當前已下載的字節大小
long totalSize = progress.getTotalSize(); //要下載的總字節大小
}, AndroidSchedulers.mainThread()) //指定主線程回調
.as(RxLife.as(this)) //感知生命周期
.subscribe(s -> {//s為String類型，這里為文件存儲路徑
//下載完成，處理相關邏輯
}, throwable -> {
//下載失敗，處理相關邏輯
});
復制代碼
斷點下載
斷點下載相較于下載，僅需要調用setRangeHeader方法傳入開始及結束位置即可(結束位置不傳默認為文件末尾)，其它沒有任何差別
String destPath = getExternalCacheDir() + "/" + "Miaobo.apk";
long length = new File(destPath).length(); //已下載的文件長度
RxHttp.get("http://update.9158.com/miaolive/Miaolive.apk")
.setRangeHeader(length) //設置開始下載位置，結束位置默認為文件末尾
.asDownload(destPath)
.as(RxLife.asOnMain(this)) //加入感知生命周期的觀察者
.subscribe(s -> { //s為String類型
Log.e("LJX", "breakpointDownloadAndProgress=" + s);
//下載成功，處理相關邏輯
}, throwable -> {
//下載失敗，處理相關邏輯
});
復制代碼
帶進度斷點下載
帶進度斷點下載相較于帶進度下載僅需要調用setRangeHeader方法傳入開始及結束位置即可(結束位置不傳默認為文件末尾)，其它沒有任何差別
String destPath = getExternalCacheDir() + "/" + "Miaobo.apk";
long length = new File(destPath).length(); //已下載的文件長度
RxHttp.get("http://update.9158.com/miaolive/Miaolive.apk")
.setRangeHeader(length) //設置開始下載位置，結束位置默認為文件末尾
.asDownload(destPath, progress -> {
//下載進度回調,0-100，僅在進度有更新時才會回調
int currentProgress = progress.getProgress(); //當前進度 0-100
long currentSize = progress.getCurrentSize(); //當前已下載的字節大小
long totalSize = progress.getTotalSize(); //要下載的總字節大小
}, AndroidSchedulers.mainThread()) //指定主線程回調
.as(RxLife.as(this)) //加入感知生命周期的觀察者
.subscribe(s -> { //s為String類型
//下載成功，處理相關邏輯
}, throwable -> {
//下載失敗，處理相關邏輯
});
復制代碼
注：上面帶進度斷點下載中，返回的進度會從0開始，如果需要銜接上次下載的進度，則調用asDownload(String,long,Consumer,Scheduler)方法傳入上次已經下載好的長度(第二個參數)，如下：
String destPath = getExternalCacheDir() + "/" + "Miaobo.apk";
long length = new File(destPath).length(); //已下載的文件長度
RxHttp.get("http://update.9158.com/miaolive/Miaolive.apk")
.setRangeHeader(length) //設置開始下載位置，結束位置默認為文件末尾
.asDownload(destPath, length, progress -> {
//下載進度回調,0-100，僅在進度有更新時才會回調
int currentProgress = progress.getProgress(); //當前進度 0-100
long currentSize = progress.getCurrentSize(); //當前已下載的字節大小
long totalSize = progress.getTotalSize(); //要下載的總字節大小
}, AndroidSchedulers.mainThread()) //指定主線程回調
.as(RxLife.as(this)) //加入感知生命周期的觀察者
.subscribe(s -> { //s為String類型
//下載成功，處理相關邏輯
}, throwable -> {
//下載失敗，處理相關邏輯
});
復制代碼
多任務下載
多任務下載我們可以使用RxJava的merge操作符，如下：
List> downList = new ArrayList<>();
for (int i = 0; i < 3; i++) {
String destPath = getExternalCacheDir() + "/" + i + ".apk";
String url = "http://update.9158.com/miaolive/Miaolive.apk"
Observable down = RxHttp.get(url)
.asDownload(destPath);
downList.add(down);
}
//通過RxJava內部線程池，多任務并行下載
Observable.merge(downList)
.as(RxLife.as(this))
.subscribe(s -> {
//單個任務下載完成
}, throwable -> {
//下載出錯
}, () -> {
//所有任務下載完成
});
復制代碼
如果想監聽每個任務的下載進度，也簡單，用老方法即可，如下：
List> downList = new ArrayList<>();
for (int i = 0; i < 3; i++) {
String destPath = getExternalCacheDir() + "/" + i + ".apk";
String url = "http://update.9158.com/miaolive/Miaolive.apk"
Observable down = RxHttp.get(url)
.asDownload(destPath, progress -> {
//單個下載任務進度回調
}, AndroidSchedulers.mainThread())
downList.add(down);
}
//通過RxJava內部線程池，多任務并行下載
Observable.merge(downList)
.as(RxLife.as(this))
.subscribe(s -> {
//單個任務下載完成
}, throwable -> {
//下載出錯
}, () -> {
//所有任務下載完成
});
復制代碼
多任務上傳
與多任務下載同理，不再講述。
小結
好了，文件上傳、下載相關就介紹到這里了，到這你會發現，不管是上傳還是下載，進度的監聽都極其的相似，極大的降低了學習成本。怎么樣？是不是很優雅，歡迎打臉！！
最后，很大一部分功勞都要歸功于RxJava的強大，感謝RxJava，向它致敬！！！！
下一文將繼續使用RxJava強大的操作符，看看它與RxHttp又能擦出怎樣的火花。
轉載請注明出處，謝謝🙏
創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎總結
以上是生活随笔為你收集整理的android上传图片文件至c 服务器,Android 史上最优雅的实现文件上传、下载及进度的监听...的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 三星发布三防新机：“复古”可替换电池设计
- 下一篇： android sina oauth2.