RxJava系列文章目錄導讀：

一、RxJava create操作符的用法和源碼分析
二、RxJava map操作符用法詳解
三、RxJava flatMap操作符用法詳解
四、RxJava concatMap操作符用法詳解
五、RxJava onErrorResumeNext操作符實現(xiàn)app與服務器間token機制
六、RxJava retryWhen操作符實現(xiàn)錯誤重試機制
七、RxJava 使用debounce操作符優(yōu)化app搜索功能
八、RxJava concat操作處理多數(shù)據(jù)源
九、RxJava zip操作符在Android中的實際使用場景
十、RxJava switchIfEmpty操作符實現(xiàn)Android檢查本地緩存邏輯判斷
十一、RxJava defer操作符實現(xiàn)代碼支持鏈式調(diào)用
十二、combineLatest操作符的高級使用
十三、RxJava導致Fragment Activity內(nèi)存泄漏問題
十四、interval、takeWhile操作符實現(xiàn)獲取驗證碼功能

一、zip操作符概述

官方文檔描述：

Returns an Observable that emits the results of a specified combiner function applied to combinations of two items emitted,
in sequence, by two other Observables.

流程圖：
[圖片上傳失敗...(image-3d036b-1516513403287)]

簡單來說zip操作符就是合并多個數(shù)據(jù)流，
然后發(fā)送(Emit)最終合并的數(shù)據(jù)。

二、zip操作符實際案例

需求描述：

在很多app種都會有圖片上傳的功能，比如商品的評價，
客戶端允許用戶拍照上傳(可能多張)，
把圖片上傳到又拍云(現(xiàn)在很多中小型公司都是用又拍云作為圖片服務器)，
然后獲取圖片的url，再把圖片的信息（圖片url，圖片大?。┌l(fā)送給服務器。

主要邏輯：

1,先把所有的圖片上傳到又拍云（比如3張圖片）

2,獲取圖片的url路徑，圖片大小等

3,最后把數(shù)據(jù)全部提交給服務器

        //需要上傳的圖片
        Picture[] ps = xxx;
        Observable.zip(
                Observable.from(ps),
                getUpYunAddress(ps.length),//獲取上傳的url
                new Func2<Picture, UpYunAddress, Picture>() {
                    @Override
                    public Picture call(Picture picture, UpYunAddress upYunAddress) {
                        //如果該圖片已經(jīng)上傳則不應該上傳
                        if (TextUtils.isEmpty(picture.getSource())) {
                            try {
                                //使用又拍云提供的工具類，上傳圖片
                                String path = UpYunUtil.uploadImage(upYunAddress, picture.getLocalUrl());
                                //獲取最終的url
                                String finalUrl = upYunAddress.getPrefix() + path;
                                picture.setSource(finalUrl);
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                        return picture;
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                //上傳成功后獲取圖片大小
                .flatMap(new Func1<Picture, Observable<Picture>>() {
                    @Override
                    public Observable<Picture> call(Picture picture) {
                        if (TextUtils.isEmpty(picture.getHeight()) || TextUtils.isEmpty(picture.getWidth())) {
                            BitmapFactory.Options options;
                            if (!TextUtils.isEmpty(picture.getLocalUrl())) {
                                options = ImageUtil.getBitmapOptions(picture.getLocalUrl());
                                picture.setLocalUrl(null);
                            } else {
                                options = ImageUtil.getBitmapOptions(picture.getSource());
                            }
                            picture.setWidth(String.valueOf(options.outWidth));
                            picture.setHeight(String.valueOf(options.outHeight));
                        }
                        return Observable.just(picture);
                    }
                });
                //最后處理最終的數(shù)據(jù)。

代碼的注釋非常詳細，我就不再贅述了！

對于復雜的業(yè)務，使用RxJava來解決，感覺行云流水般，再也不用各種復雜的嵌套了。 :D）

本文的例子放在github上https://github.com/chiclaim/android-sample/tree/master/rxjava