Retrofit+Rxjava實(shí)現(xiàn)文件上傳和下載功能
Retrofit簡(jiǎn)介:
在Android API4.4之后，Google官方使用了square公司推出的okHttp替換了HttpClient的請(qǐng)求方式。后來(lái)square公司又推出了基于okHttp的網(wǎng)絡(luò)請(qǐng)求框架：Retrofit。
什么是 RxJava？
RxJava 是一個(gè)響應(yīng)式編程框架，采用觀察者設(shè)計(jì)模式。所以自然少不了 Observable 和 Subscriber 這兩個(gè)東東了。
RxJava 是一個(gè)開(kāi)源項(xiàng)目，地址：https://github.com/ReactiveX/RxJava
還有一個(gè)RxAndroid，用于 Android 開(kāi)發(fā)，添加了 Android 用的接口。地址：https://github.com/ReactiveX/RxAndroid
每個(gè)應(yīng)用基本都會(huì)涉及到文件的上傳或下載，最普遍的一般也就是上傳頭像或者照片，下載安裝包了，本篇文章就這兩點(diǎn)簡(jiǎn)單說(shuō)一下retrofit+rxjava的對(duì)文件的上傳和下載。
1.上傳
首先說(shuō)一下單文件上傳,一般上傳頭像等會(huì)用到 .
1).寫(xiě)api @Multipart
@POST
( "" )//引號(hào)內(nèi)為地址Observable httpName(@PartMultipartBody.Part file);
2).寫(xiě)presenter的方法
public void httpName(File file) {
RequestBody requestBody = RequestBody. create (MediaType. parse ( "image/png" ), file);
MultipartBody.Part part = MultipartBody.Part. createFormData ( "file" , file.getName() , requestBody);
Observable observable = api. httpName (part);
…rajava+retrofit處理邏輯
}
3)調(diào)用方法發(fā)起請(qǐng)求
mPresenter. httpName (f);
其中f我為你要上傳的文件對(duì)象
以圖片為例,經(jīng)過(guò)裁剪后將其轉(zhuǎn)化為文件對(duì)象方法如下
@Override
protected void onActivityResult(int requestCode, int resultCode, Intent data) {
if (data != null) {
Bundle bundle = data.getExtras();
if (bundle != null) {
bitmap = bundle.getParcelable("data");
File f = new File(this.getFilesDir(), (new Date()).getTime() + ".png");
if (f.exists()) {f.delete();}
try {
FileOutputStream out = new FileOutputStream(f);
bitmap.compress(Bitmap.CompressFormat.PNG, 90, out);
out.flush();
out.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
f = null;
} catch (IOException e) {
e.printStackTrace();
f = null;
}
if (f != null) {
mPresenter. httpName(f);
}}}//括號(hào)可能多或者少,自己添吧
再說(shuō)一下多文件上傳,以及附帶有參數(shù)的請(qǐng)求,類(lèi)似這樣
mPresenter.httpUpLoadMore(id,phone, File1, File2, File3);
@Multipart
@POST("")
Observable<ResponseBody> httpUpLoadMore (@Query("id") String id, @Query("phone") String phone, @Part MultipartBody.Part file1, @Part MultipartBody.Part file2, @Part MultipartBody.Part file3);
這里附帶參數(shù)用@FieldMap Map maps也可以,用query好像不太恰當(dāng)
后面只需要像傳單文件一樣
RequestBody requestBody1/2/3 = RequestBody.create(MediaType.parse("image/png"), file1/2/3);;
MultipartBody.Part part1/2/3 = MultipartBody.Part.createFormData("file", file1/2/3.getName() , requestBody1/2/3);
Observable bservable= api.httpUpLoadMore(id,phone,part1,part2,part3);
……
2下載
1)寫(xiě)api
@Streaming//下載大文件時(shí)需要加上 @GET Observable > download(@Url String url);
2)Presenter方法
mApi.download (path)
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.io())
.flatMap(new Func1,Observable>() {
@Override
public Observablecall(Response response) {
boolean b = writeToFile(response, file);//將返回的流轉(zhuǎn)寫(xiě)入到file對(duì)象中
final Boolean aBoolean =Boolean.valueOf(b);
return Observable.create(new Observable.OnSubscribe(){
@Override
public void call(Subscriber subscriber) {
try {
subscriber.onNext(aBoolean);
subscriber.onCompleted();
} catch (Exceptione) {
subscriber.onError(ExceptionManager.handleException(e));}}});}})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1(){
@Override
public void call(Boolean bean) {}
}, new Action1(){
@Override
public void call(Throwablethrowable) {}});
[if !supportLineBreakNewLine]
[endif]
private boolean writeToFile(Responsebody,File file) {
try {
InputStream inputStream = null;
OutputStream outputStream = null;
try {
byte[] fileReader = new byte[2048];
inputStream =body.body().byteStream();
outputStream = new FileOutputStream(file);
while (true) {
int read =inputStream.read(fileReader);
if (read == -1) break;
outputStream.write(fileReader, 0, read);
}
outputStream.flush();
return true;
} catch (IOException e) {
return false;
} finally {
if (inputStream != null) {
inputStream.close();
}
if (outputStream != null) {
outputStream.close();
}}
} catch (IOException e) {
return false;
}}
3)調(diào)用方法發(fā)起下載請(qǐng)求
mPresenter.httpToDownload(downPath, file);//file為你下載下來(lái)的文件要存放的位置
因本人app中用的是rxjava1,所以一些rxjava+retrofit處理邏輯寫(xiě)的不細(xì)甚至有些亂,所以大家可以自己作相應(yīng)修改,不要拿來(lái)就用.
總結(jié)
以上所述是小編給大家介紹的Retrofit+Rxjava實(shí)現(xiàn)文件上傳和下載功能，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
- 基于Ok+Rxjava+retrofit實(shí)現(xiàn)斷點(diǎn)續(xù)傳下載
- Retrofit+RxJava實(shí)現(xiàn)帶進(jìn)度下載文件
- 基于Retrofit+Rxjava實(shí)現(xiàn)帶進(jìn)度顯示的下載文件
- Retrofit+Rxjava下載文件進(jìn)度的實(shí)現(xiàn)
- RxJava+Retrofit+OkHttp實(shí)現(xiàn)多文件下載之?dāng)帱c(diǎn)續(xù)傳
- RxJava2.x+ReTrofit2.x多線程下載文件的示例代碼
- Retrofit Rxjava實(shí)現(xiàn)圖片下載、保存并展示實(shí)例
- Retrofit+RxJava實(shí)現(xiàn)帶進(jìn)度條的文件下載
相關(guān)文章
java swing實(shí)現(xiàn)的掃雷游戲及改進(jìn)版完整示例
這篇文章主要介紹了java swing實(shí)現(xiàn)的掃雷游戲及改進(jìn)版,結(jié)合完整實(shí)例形式對(duì)比分析了java使用swing框架實(shí)現(xiàn)掃雷游戲功能與相關(guān)操作技巧,需要的朋友可以參考下2017-12-12
這篇文章主要介紹了mybatis-plus如何禁用一級(jí)緩存的方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
Spring?Boot中使用Spring?Retry重試框架的操作方法
這篇文章主要介紹了Spring?Retry?在SpringBoot?中的應(yīng)用,介紹了RetryTemplate配置的時(shí)候，需要設(shè)置的重試策略和退避策略，需要的朋友可以參考下2022-04-04
詳解MyBatis直接執(zhí)行SQL查詢及數(shù)據(jù)批量插入
這篇文章主要介紹了MyBatis直接執(zhí)行SQL查詢及數(shù)據(jù)批量插入的相關(guān)知識(shí)，需要的朋友一起學(xué)習(xí)吧2016-01-01
解決Java執(zhí)行Cmd命令出現(xiàn)的死鎖問(wèn)題
這篇文章主要介紹了關(guān)于Java執(zhí)行Cmd命令出現(xiàn)的死鎖問(wèn)題解決,解決方法就是在waitfor()方法之前讀出窗口的標(biāo)準(zhǔn)輸出、輸出、錯(cuò)誤緩沖區(qū)中的內(nèi)容，本文給大家介紹的非常詳細(xì)，需要的朋友可以參考下2022-07-07
這篇文章主要介紹了Java的字節(jié)緩沖流與字符緩沖流解析,Java 緩沖流是Java I/O庫(kù)中的一種流,用于提高讀寫(xiě)數(shù)據(jù)的效率,它通過(guò)在內(nèi)存中創(chuàng)建緩沖區(qū)來(lái)減少與底層設(shè)備的直接交互次數(shù),從而減少了I/O操作的開(kāi)銷(xiāo),需要的朋友可以參考下2023-11-11
Java使用Condition實(shí)現(xiàn)精準(zhǔn)喚醒線程詳解
這篇文章主要為大家詳細(xì)介紹了Java如何使用Condition實(shí)現(xiàn)精準(zhǔn)喚醒線程效果，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以跟隨小編一起了解一下2023-02-02
logback-spring.xml的配置及示例詳解(直接復(fù)制粘貼可用)
在使用logback作為日志框架時(shí),可以創(chuàng)建一個(gè)名為logback-spring.xml的配置文件來(lái)自定義日志輸出的格式和方式,下面這篇文章主要給大家介紹了關(guān)于logback-spring.xml的配置及示例詳解的相關(guān)資料,文中的代碼直接復(fù)制粘貼可用,需要的朋友可以參考下2024-01-01
這篇文章主要給大家介紹了關(guān)于Spring中統(tǒng)一異常處理的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用spring具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2018-09-09
Servlet連接數(shù)據(jù)庫(kù)實(shí)現(xiàn)用戶登錄的實(shí)現(xiàn)示例
本文主要介紹了Servlet連接數(shù)據(jù)庫(kù)實(shí)現(xiàn)用戶登錄的實(shí)現(xiàn)示例，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06