在看了網(wǎng)上多篇rxjava和retrofit的文章后，大概有了一個(gè)初步的認(rèn)識(shí)，剛好要做一個(gè)多圖上傳的功能，就拿它開刀吧。下面的內(nèi)容將基于之前實(shí)現(xiàn)方式和使用rxjava實(shí)現(xiàn)之間的異同展開，初次寫筆記不喜就噴。
普通版多圖上傳
由于目前手機(jī)照片動(dòng)輒幾M的大小，如果不做處理就直接上傳，我就笑笑不說話（給個(gè)眼神你自己體會(huì)）。所以，上傳分為兩步：對(duì)圖片進(jìn)行壓縮和請(qǐng)求上傳。下面請(qǐng)看偽代碼（PS：自己不會(huì)寫后臺(tái)，項(xiàng)目后臺(tái)不能拿來用，所以只能給偽代碼了）
//圖片集合
List<String> imgs = new ArrayList<>();
//壓縮后的圖片路徑集合
List<String> tmpImgs = new ArrayList<>();
Handler mHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
//TODO 收到消息后調(diào)用網(wǎng)絡(luò)請(qǐng)求上傳
}
};
public void compressImages() {
new Thread(new Runnable() {
@Override
public void run() {
for (String path : imgs) {
//TODO 調(diào)用壓縮圖片的方法，壓縮后保存在一個(gè)臨時(shí)文件夾中
tmpImgs.add("壓縮后路徑");
}
mHandler.sendEmptyMessage(0);
}
}).start();
}
看完后是不是覺得很麻煩，好吧可能僅僅是我實(shí)現(xiàn)的麻煩而已。都說使用rxjava后邏輯鏈會(huì)變得更清晰，就看看是不是這樣，下面請(qǐng)看用rxjava后的偽代碼：
@Multipart
@POST("your address")
Observable<String> uploadImgs(@PartMap Map<String, RequestBody> map, @Part("imgs") MultipartBody body);
//先定義一個(gè)請(qǐng)求接口，除了圖片可能還有其他一些參數(shù)需要上傳，所以還定義了個(gè)map。接下來開始正文：
public void upload() {
final Map<String, RequestBody> map = new HashMap<>();
map.put("userId", RequestBody.create(MediaType.parse("form-data"),"1");
final MultipartBody.Builder builder = new MultipartBody.Builder();
Observable.from(imgs)
.map(new Func1<String, String>() {
@Override
public String call(String path) {
//調(diào)用圖片壓縮，返回壓縮后路徑tmp_path
//注意，F(xiàn)iledata是后臺(tái)給你的對(duì)應(yīng)的字段
builder.addFormDataPart("Filedata", "avatar.png", RequestBody.create(MultipartBody.FORM, new File(tmp_path)));
return path;
}
}).last()
.flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(String path) {
return apiService.uploadImgs(map, builder.build());
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
//錯(cuò)誤處理
}
@Override
public void onNext(String res) {
//成功后處理
}
});
}
黑人問號(hào)臉？代碼看起來還是很多啊，你TM在逗我。聽本汪開始胡說八道：
1、首先定義個(gè)Map，這個(gè)就是用來上傳其他參數(shù)用的，為什么value是RequestBody類型的，用String不就可以了嗎，瞎裝什么逼啊。好吧，本汪開始也是這么認(rèn)為的，結(jié)果傳到服務(wù)器的值自帶‘’加成，傳個(gè)1過去變成了‘1’，正打算一本正經(jīng)的找后臺(tái)談?wù)劦?，發(fā)現(xiàn)自己傳上去的就是這樣（臉紅ing）。然后發(fā)現(xiàn)用@part注解的，如果不使用RequestBody，會(huì)自動(dòng)加上‘’，這點(diǎn)至今不知為何，還請(qǐng)懂的小伙伴釋疑。
2、然后是MultipartBody.Builder，顧名思義，能添加多個(gè)RequestBody，用來添加多個(gè)圖片。好了，小火車要開動(dòng)了。
3、簡(jiǎn)單說下接下來這一大段代碼是干嘛的，當(dāng)然建立在你已經(jīng)了解rxjava的from、map、flatmap、last是用來干嘛的基礎(chǔ)上，不甚明白的小伙伴可以先看看張磊BaronZhang的文集http://m.itdecent.cn/p/ec9849f2e510。
a、from會(huì)將imgs集合拆分成單個(gè)的String發(fā)送出去
b、map的作用是在此進(jìn)行圖片壓縮，并將壓縮后的圖片添加到MultipartBody.Builder，相當(dāng)于for循環(huán)壓縮了圖片。
c、flatmap這里，可謂是成敗再次一舉了。這里有一個(gè)轉(zhuǎn)換，注意map處理后返回的String依然是一個(gè)String類型，經(jīng)過flatmap后將轉(zhuǎn)化為 Observable<String>，也就是我們圖片上傳后返回的結(jié)果。
d、好了，到此為止好像已經(jīng)達(dá)到我們一條鏈下來就實(shí)現(xiàn)了圖片上傳的功能了，感覺是要清晰那么一點(diǎn)（如果沒有，那我還TM瞎折騰什么）。哎，別走啊你把last忽略掉是什么鬼。
e、如果不在map后添加last方法，大家可以試一試，保證后臺(tái)白眼都要翻到天上去了。由于from一個(gè)一個(gè)的發(fā)送，所以每一個(gè)對(duì)象都會(huì)在flatmap這里調(diào)用一次uploadImgs方法，這樣肯定是不行了，加last方法后，只會(huì)發(fā)送發(fā)送從map出來的序列的最后一個(gè)對(duì)象，這樣就保證在所有圖片都?jí)嚎s完成并且加入后MultipartBody.Builder后再調(diào)用uploadImgs方法，并且只會(huì)調(diào)用一次。
以上就是我用rxjava+retrofit做多圖上傳的小筆記，可能看完你也還不知道我TM在說什么鬼，或者給一個(gè)大寫鄙視，然而并沒有什么x用，我還是繼續(xù)敲著代碼。最后還是要感謝一下張磊BaronZhang的，畢竟文章也看了問題也問了_。
（PS：不知道這樣是不是正確的使用方法，還請(qǐng)大神們斧正O(∩_∩)O~）
