RxJava系列之concat 、merge操作符及项目实际使用

1.concat、merge概述

• concat将两个发射器合并成一个发射器, 依次发送，发送完一个再接着发送第二个。如下图所示
  concat.png
• marge合并多个Observables的发射物， Merge 可能会让合并的Observables发射的数据交错，这也就是和concat的较大区别(挨个发送)
  merge.png
  由上图即可理解，不用等到 发射器 A 发送完所有的事件再进行发射器 B 的发送，他们是可以参杂交互发射事件。

其他

concat（） /concatArray（）的区别：

concat（）组合被观察者数量<=4,concatArray()组合被观察者>4

merge（）/mergeArray（）的区别

merge（）组合被观察者数量≤4个,mergeArray（）则可＞4个

应用

• 从磁盘 / 内存 /网络缓存中获取缓存数据

(1)设置第1个Observable：检查内存缓存是否有该数据的缓存

// 该2变量用于模拟内存缓存 & 磁盘缓存中的数据
        String memoryCache = null;
        String diskCache = "从磁盘缓存中获取数据";

        Observable<String> memory = Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> emitter) throws Exception {

                // 先判断内存缓存有无数据
                if (memoryCache != null) {
                    // 若有该数据，则发送
                    emitter.onNext(memoryCache);
                } else {
                    // 若无该数据，则直接发送结束事件
                    emitter.onComplete();
                }
            }
        });

(2)设置第2个Observable：检查磁盘缓存是否有该数据的缓存

        Observable<String> disk = Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> emitter) throws Exception {
                // 先判断磁盘缓存有无数据
                if (diskCache != null) {
                    // 若有该数据，则发送
                    emitter.onNext(diskCache);
                } else {
                    // 若无该数据，则直接发送结束事件
                    emitter.onComplete();
                }
            }
        });

(3)设置第3个Observable：通过网络获取数据

        Observable<String> network = Observable.just("从网络中获取数据");

(4)通过concat（） 和 firstElement（）操作符实现缓存功能

1. 通过concat（）合并memory、disk、network 3个被观察者的事件（即检查内存缓存、磁盘缓存 & 发送网络请求）并将它们按顺序串联成队列
2. 通过firstElement()，从串联队列中取出并发送第1个有效事件（Next事件），即依次判断检查memory、disk、network

        Observable.concat(memory, disk, network)
                .firstElement()
                .subscribe(new Consumer<String>() {
                    @Override
                    public void accept( String s) throws Exception {
                        Log.d(TAG,"最终获取的数据来源 =  "+ s);
                    }
                });

本例的逻辑为：
a. firstElement()取出第1个事件 = memory，即先判断内存缓存中有无数据缓存；当memoryCache = null，所以发送结束事件（视为无效事件）
b. 继续取出第2个事件 = disk，即判断磁盘缓存中有无数据缓存：当diskCache ≠ null，即磁盘缓存中有数据，所以发送Next事件（有效事件）
c. 即firstElement()已发出第1个有效事件（disk事件），就停止判断