RxJava系列文章目錄導(dǎo)讀：

一跨嘉、RxJava create操作符的用法和源碼分析
二跳夭、RxJava map操作符用法詳解
三岸浑、RxJava flatMap操作符用法詳解
四、RxJava concatMap操作符用法詳解
五秫舌、RxJava onErrorResumeNext操作符實(shí)現(xiàn)app與服務(wù)器間token機(jī)制
六的妖、RxJava retryWhen操作符實(shí)現(xiàn)錯(cuò)誤重試機(jī)制
七、RxJava 使用debounce操作符優(yōu)化app搜索功能
八足陨、RxJava concat操作處理多數(shù)據(jù)源
九嫂粟、RxJava zip操作符在Android中的實(shí)際使用場景
十、RxJava switchIfEmpty操作符實(shí)現(xiàn)Android檢查本地緩存邏輯判斷
十一墨缘、RxJava defer操作符實(shí)現(xiàn)代碼支持鏈?zhǔn)秸{(diào)用
十二星虹、combineLatest操作符的高級(jí)使用
十三、RxJava導(dǎo)致Fragment Activity內(nèi)存泄漏問題
十四镊讼、interval宽涌、takeWhile操作符實(shí)現(xiàn)獲取驗(yà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操作符就是合并多個(gè)數(shù)據(jù)流狠毯，
然后發(fā)送(Emit)最終合并的數(shù)據(jù)护糖。

二、zip操作符實(shí)際案例

需求描述：

在很多app種都會(huì)有圖片上傳的功能嚼松，比如商品的評(píng)價(jià)，
客戶端允許用戶拍照上傳(可能多張)锰扶，
把圖片上傳到又拍云(現(xiàn)在很多中小型公司都是用又拍云作為圖片服務(wù)器)献酗，
然后獲取圖片的url，再把圖片的信息（圖片url坷牛，圖片大泻辟恕）發(fā)送給服務(wù)器。

主要邏輯：

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

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

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

        //需要上傳的圖片
        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)上傳則不應(yī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ù)甩苛。

代碼的注釋非常詳細(xì)，我就不再贅述了俏站！

對(duì)于復(fù)雜的業(yè)務(wù)讯蒲，使用RxJava來解決，感覺行云流水般肄扎，再也不用各種復(fù)雜的嵌套了墨林。 :D）

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