今天變動(dòng)接口闪唆，發(fā)現(xiàn)新版的后端接口不能批量上傳圖片（以前接口可以扔一堆本地圖片地址進(jìn)去秽褒，然后統(tǒng)一返回一個(gè)list），只能單張圖片上傳腊凶，比較頭大芙粱，并且圖片數(shù)量是不確定的祭玉，用for循環(huán)遍歷，調(diào)用上傳接口的話春畔，本地添加flag脱货，每次返回一張就判斷一次的話岛都，到時(shí)能實(shí)現(xiàn)，但是這樣做很蠢振峻。
于是又去看了一下Rxjava的api文檔臼疫，發(fā)現(xiàn)用fromIterable 操作符可以逐次發(fā)射list的中的數(shù)據(jù)，然后用flatmap轉(zhuǎn)換一下扣孟，調(diào)用圖片上傳的接口烫堤，可以研究一下，于是實(shí)驗(yàn)一下：
List<String> resultString = new ArrayList<>();
Observable
.fromIterable(fileList)
.flatMap((Function<String, ObservableSource<BaseResModel<UploadFilesJavaResModel>>>) s -> {
MultipartBody.Builder builder = new MultipartBody.Builder().setType(MultipartBody.FORM);
File file = new File(s);
RequestBody body = RequestBody.create(MediaType.parse("application/octet-stream"), file);
//這里進(jìn)行一些特定字段處理處理凤价，每個(gè)項(xiàng)目可能不同就寫了
MultipartBody multipartBody = builder.build();
return RetrofitFactory.getApi("上傳圖片").fileUpload(multipartBody);
})
.compose(TransformUtils.defaultSchedulers())
.subscribe(new Observer< String>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(String s) {
//在這里將每次返回的圖片地址加到list中去
resultString.add(s);
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
// 當(dāng)都有返回值的時(shí)候鸽斟，在這里進(jìn)行下一步操作
}
});
這樣看上去功能能實(shí)現(xiàn)了，但是發(fā)現(xiàn)流程寫死了利诺，完全違背了RxJava變化莫測(cè)的靈活性湾盗，比如現(xiàn)在同時(shí)需要多個(gè)接口的返回值，才能進(jìn)行下一步的操作立轧，很多同學(xué)第一就想到用zip操作符格粪，這很對(duì)，但是zip操作符氛改，是操作的多個(gè)Observable帐萎，而剛剛寫的已經(jīng)進(jìn)行subscribe操作了，失去了變換的可能性了胜卤。疆导。。只能想別的辦法了葛躏。澈段。
有沒(méi)有一種操作符可以合并fromIterable返回的結(jié)果呢？于是谷歌舰攒、百度败富、RxJava操作官方的API，果然發(fā)現(xiàn)了一個(gè)叫toList的操作符摩窃，toList()操作符的目的應(yīng)該是將所有的數(shù)據(jù)放進(jìn)一個(gè)List中去兽叮，等所有數(shù)據(jù)處理完畢后將這個(gè)List傳遞給這里的subscribe
那就有希望進(jìn)行靈活變換了
但是在實(shí)際使用的時(shí)候，發(fā)現(xiàn)猾愿，toList操作符鹦聪，返回的時(shí)一個(gè)Single，如果需要用zip操作符去合并多組的observable的時(shí)候蒂秘，就不適用了泽本。
@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final Single<List<T>> toList() {
return toList(16);
}
只能繼續(xù)看api和谷歌，又發(fā)現(xiàn)了一個(gè)神奇的操作符：flatMapObservable姻僧，大概的意思是對(duì)Single的數(shù)據(jù)執(zhí)行flatMap操作规丽，然后返回一個(gè)Observable：
public Observable<List<UploadFilesJavaResModel>> javaUploadFilesa(List<String> fileList, final String type) {
return Observable
.fromIterable(fileList)
.flatMap((Function<String, ObservableSource<BaseResModel<UploadFilesJavaResModel>>>) url -> {
MultipartBody.Builder builder = new MultipartBody.Builder().setType(MultipartBody.FORM);
File file = new File(url);
int index = url.lastIndexOf("/");
String fileName = url.substring(index + 1);
RequestBody body = RequestBody.create(MediaType.parse("application/octet-stream"), file);
//這里進(jìn)行一些特定字段處理處理蒲牧，每個(gè)項(xiàng)目可能不同就寫了
MultipartBody multipartBody = builder.build();
return RetrofitFactory.getApi("上傳圖片").fileUpload(multipartBody);
})
//考慮一下上傳失敗的情況，拋出異常嘁捷，在訂閱里面處理
.map(uploadFilesResModelBaseResModel -> {
if (uploadFilesResModelBaseResModel.isSuccess()) {
return uploadFilesResModelBaseResModel.getData();
} else {
String errorMsg = "照片上傳失敗!";
throw new ApiException(errorMsg);
}
})
.toList()
.flatMapObservable(uploadFilesJavaResModels -> Observable.create(e -> {
e.onNext(uploadFilesJavaResModels);
e.onComplete();
}));
//toList下面用的是lambda表達(dá)式，如果看不懂显熏，下面代碼是沒(méi)有用lambda表達(dá)式的原始代碼（lambda表達(dá)式對(duì)于
//簡(jiǎn)化代碼具有神奇的效果雄嚣，但是由于省略了內(nèi)部類，閱讀起來(lái)有一定困難喘蟆，特別是不熟悉api調(diào)用的情況下）
// .flatMapObservable(new Function<List<UploadFilesJavaResModel>, ObservableSource<List<UploadFilesJavaResModel>>>() {
// @Override
// public ObservableSource<List<UploadFilesJavaResModel>> apply(List<UploadFilesJavaResModel> list) throws Exception {
//
// return Observable.create(new ObservableOnSubscribe<List<UploadFilesJavaResModel>>() {
// @Override
// public void subscribe(ObservableEmitter<List<UploadFilesJavaResModel>> e) throws Exception {
// e.onNext(list);
// e.onComplete();
// }
// });
// }
// });
這樣缓升，就傳入一個(gè)數(shù)組的圖片，然后進(jìn)行上傳操作蕴轨，返回的也是一系列圖片在服務(wù)器上的地址~問(wèn)題得到了解決港谊。
RxJava還是非常強(qiáng)大的，操作符非常多橙弱，自己常用的也就那么幾個(gè)歧寺，慢慢研究吧~~
