通過上一節(jié)的學(xué)習(xí)我們知道了rxjava是什么(需要看一的朋友點(diǎn)這里Rxjava入門 一)，以及怎樣利用rxjava打印輸出字符串和數(shù)組代箭。總結(jié)起來就是：Observable發(fā)射事件，subscribe訂閱observable事件并迭代執(zhí)行唬涧。

但是我們知道我們平時(shí)所接觸的事件流程遠(yuǎn)遠(yuǎn)沒有這么簡單。有時(shí)候我們需要把數(shù)據(jù)經(jīng)過復(fù)雜的變換然后才能為我們所用盛撑。同樣碎节，rxjava的開發(fā)人員也已經(jīng)為我們想到了這些。并且創(chuàng)造了一系列操作符為我們所用抵卫。

創(chuàng)建操作

上一節(jié)我們已經(jīng)接觸了from和just兩個(gè)創(chuàng)建方式狮荔，其實(shí)也是兩個(gè)操作符。
除此之外還有Create介粘、Range殖氏、Repeat、Start姻采、Timer等方式

Create

官方解釋：使用一個(gè)函數(shù)從頭開始創(chuàng)建一個(gè)Observable
你可以使用 Create 操作符從頭開始創(chuàng)建一個(gè)Observable,給這個(gè)操作符傳遞一個(gè)接受觀察者 作為參數(shù)的函數(shù),編寫這個(gè)函數(shù)讓它的行為表現(xiàn)為一個(gè)Observable--恰當(dāng)?shù)恼{(diào)用觀察者的 onNext,onError和onCompleted方法雅采。
??一個(gè)形式正確的有限Observable必須嘗試調(diào)用觀察者的onCompleted正好一次或者它的 onError正好一次,而且此后不能再調(diào)用觀察者的任何其它方法。
??RxJava將這個(gè)操作符實(shí)現(xiàn)為 create 方法慨亲。
??建議你在傳遞給 create 方法的函數(shù)中檢查觀察者的 isUnsubscribed 狀態(tài),以便在沒有觀察者的時(shí)候,讓你的Observable停止發(fā)射數(shù)據(jù)或者做昂貴的運(yùn)算婚瓜。

示例代碼:

Observable.create(new Observable.OnSubscribe<Integer>() {
   @Override
   public void call(Subscriber<? super Integer> observer) {
       try {
           if (!observer.isUnsubscribed()) {
               for (int i = 1; i < 5; i++) {
                   observer.onNext(i);
               }
               observer.onCompleted();
           }
       } catch (Exception e) {
           observer.onError(e);
} }
} ).subscribe(new Subscriber<Integer>() {
       @Override
       public void onNext(Integer item) {
           System.out.println("Next: " + item);
}
       @Override
       public void onError(Throwable error) {
           System.err.println("Error: " + error.getMessage());
       }
       @Override
       public void onCompleted() {
           System.out.println("Sequence complete.");
       }
});

從例子我們可以看到。重新創(chuàng)建一個(gè)observable我們可以掌控訂閱者對事件的執(zhí)行方式刑棵。

Repeat

創(chuàng)建一個(gè)發(fā)射特定數(shù)據(jù)重復(fù)多次的Observable
??Repeat重復(fù)地發(fā)射數(shù)據(jù)巴刻。某些實(shí)現(xiàn)允許你重復(fù)的發(fā)射某個(gè)數(shù)據(jù)序列,還有一些允許你限制重 復(fù)的次數(shù)。
??RxJava將這個(gè)操作符實(shí)現(xiàn)為 repeat 方法蛉签。它不是創(chuàng)建一個(gè)Observable,而是重復(fù)發(fā)射原始 Observable的數(shù)據(jù)序列,這個(gè)序列或者是無限的,或者通過 repeat(n) 指定重復(fù)次數(shù)胡陪。
??repeat 操作符默認(rèn)在 trampoline 調(diào)度器上執(zhí)行沥寥。有一個(gè)變體可以通過可選參數(shù)指定 Scheduler。

repeat

關(guān)于創(chuàng)建的操作符就講到這里督弓，相關(guān)的其它方式可以在這里查看

變換操作符

變換操作符的目的是講數(shù)據(jù)變?yōu)槲覀冃枰念愋陀Ｒ姷淖儞Q操作符有 Buffer、FlatMap愚隧、GroupBy蒂阱、Map、Scan狂塘。

Map操作符

官方解釋：Map 操作符對原始Observable發(fā)射的每一項(xiàng)數(shù)據(jù)應(yīng)用一個(gè)你選擇的函數(shù),然后返回一個(gè)發(fā)射 這些結(jié)果的Observable录煤。

使用map操作符，我們可以將數(shù)據(jù)轉(zhuǎn)換后再進(jìn)行發(fā)射

map

??如圖所示荞胡，我們將每個(gè)數(shù)據(jù)*10然后輸出數(shù)據(jù)會依次按照原始順序*10然后輸出.

下面我們舉個(gè)例子

 Observable.just("1010101010").map(new Func1<String, Integer>() {
            @Override
            public Integer call(String s) {
                return Integer.parseInt(s);
            }
        }).subscribe(new Subscriber<Integer>() {
            @Override
            public void onCompleted() {

            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onNext(Integer integer) {
                System.out.println(integer);
            }
        });


06-03 14:55:13.927 358-358/? I/System.out: 1010101010

我們可以看到妈踊，我們通過map操作符將String類型轉(zhuǎn)換為int類型然后打印輸出。map泛型第一個(gè)參數(shù)是原始數(shù)據(jù)類型泪漂，第二個(gè)是你需要的類型廊营。在此不再過多贅述。

FlatMap操作符

官方解釋：FlatMap 將一個(gè)發(fā)射數(shù)據(jù)的Observable變換為多個(gè)Observables,然后將它們發(fā)射的數(shù)據(jù)合并 后放進(jìn)一個(gè)單獨(dú)的Observable
??FlatMap 操作符使用一個(gè)指定的函數(shù)對原始Observable發(fā)射的每一項(xiàng)數(shù)據(jù)執(zhí)行變換操作,這 個(gè)函數(shù)返回一個(gè)本身也發(fā)射數(shù)據(jù)的Observable,然后 FlatMap 合并這些Observables發(fā)射的數(shù) 據(jù),最后將合并后的結(jié)果當(dāng)做它自己的數(shù)據(jù)序列發(fā)射萝勤。
??這個(gè)方法是很有用的,例如,當(dāng)你有一個(gè)這樣的Observable:它發(fā)射一個(gè)數(shù)據(jù)序列,這些數(shù) 據(jù)本身包含Observable成員或者可以變換為Observable,因此你可以創(chuàng)建一個(gè)新的 Observable發(fā)射這些次級Observable發(fā)射的數(shù)據(jù)的完整集合露筒。

flatmap

官網(wǎng)文檔意思是，利用flatmap可以將一個(gè)Observable發(fā)射的數(shù)據(jù)轉(zhuǎn)換成多個(gè)Observable發(fā)射敌卓，然后將其發(fā)射的數(shù)據(jù)整合到一起慎式，組成所需要的發(fā)射序列

我們來舉個(gè)例子

<pre>
Observable.just("a.b.c.d.e.f.g").flatMap(new Func1<String, Observable<String>>() {
@Override
public Observable<String> call(String s) {
return Observable.from(s.split("\."));
}
}).subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onNext(String s) {
            System.out.println(s);
        }
    });

06-03 15:09:29.456 13428-13428/? I/System.out: a
06-03 15:09:29.456 13428-13428/? I/System.out: b
06-03 15:09:29.456 13428-13428/? I/System.out: c
06-03 15:09:29.456 13428-13428/? I/System.out: d
06-03 15:09:29.456 13428-13428/? I/System.out: e
06-03 15:09:29.456 13428-13428/? I/System.out: f
06-03 15:09:29.456 13428-13428/? I/System.out: g

</pre>

從代碼中我們可以看到，我將字符串“a.b.c.d.e.f.g”用.符號分割開成長度為7的字符數(shù)組趟径，然后利用Observable.from方式重新創(chuàng)建了數(shù)量為7的發(fā)射序列瘪吏，然后依次進(jìn)行發(fā)射。然后在依次subscribe中執(zhí)行蜗巧。
??變換操作符就先講到這里掌眠，剩下的可在這里學(xué)習(xí).

過濾操作符

過濾操作符可以用于過濾和選擇Observable發(fā)射的數(shù)據(jù)序列。常見的過濾操作符有 filter惧蛹、takeLast扇救、skip、skipLast香嗓、take迅腔、first、takeFirst靠娱、timeout等沧烈。過濾操作符看字面意思我想你已經(jīng)知道差不多了。在這里我們不做重點(diǎn)解釋像云。先舉幾個(gè)例子锌雀。

Filter

官方解釋：只發(fā)射通過了謂詞測試的數(shù)據(jù)項(xiàng)蚂夕。
Filter 操作符使用你指定的一個(gè)謂詞函數(shù)測試數(shù)據(jù)項(xiàng),只有通過測試的數(shù)據(jù)才會被發(fā)射。

示例代碼：

Observable.just(1, 2, 3, 4, 5)
          .filter(new Func1<Integer, Boolean>() {
              @Override
              public Boolean call(Integer item) {
                return( item < 4 );
              }
          }).subscribe(new Subscriber<Integer>() {
        @Override
        public void onNext(Integer item) {
            System.out.println("Next: " + item);
        }
        @Override
        public void onError(Throwable error) {
            System.err.println("Error: " + error.getMessage());
        }
        @Override
        public void onCompleted() {
            System.out.println("Sequence complete.");
        }
});

輸出

Next: 1
Next: 2
Next: 3
Sequence complete.

剩余的操作符可以在這里這里繼續(xù)學(xué)習(xí)腋逆。

rxjava操作符類型還有很多婿牍，這里就不再列舉了，有需要的可以看官方文檔惩歉。這里還有一本中文版文檔等脂。需要的請點(diǎn)擊閱讀或下載。

Rxjava結(jié)合RxAndroid使用

調(diào)度器（Scheduler）

說到這里我們先提一下調(diào)度器的概念撑蚌。

如果你想給Observable操作符鏈添加多線程功能,你可以指定操作符(或者特定的 Observable)在特定的調(diào)度器(Scheduler)上執(zhí)行上遥。
??某些ReactiveX的Observable操作符有一些變體,它們可以接受一個(gè)Scheduler參數(shù)。這個(gè)參 數(shù)指定操作符將它們的部分或全部任務(wù)放在一個(gè)特定的調(diào)度器上執(zhí)行争涌。
??使用ObserveOn和SubscribeOn操作符,你可以讓Observable在一個(gè)特定的調(diào)度器上執(zhí)行, ObserveOn指示一個(gè)Observable在一個(gè)特定的調(diào)度器上調(diào)用觀察者的onNext, onError和 onCompleted方法,SubscribeOn更進(jìn)一步,它指示Observable將全部的處理過程(包括發(fā)射 數(shù)據(jù)和通知)放在特定的調(diào)度器上執(zhí)行粉楚。

Android是UI單線程的，所以在進(jìn)行大量數(shù)據(jù)處理或者請求網(wǎng)絡(luò)的時(shí)候我們經(jīng)常要用到開啟子線程異步處理數(shù)據(jù)亮垫。這時(shí)候我們就需要用到調(diào)度器了.
Rxjava使用調(diào)度器為我們提供了多種開啟異步的方式模软。
如圖：

rxjava_schedule

看圖得知，Schedulers.io( )操作符處理異步數(shù)據(jù)時(shí)是最適合我們使用的饮潦。

指定一個(gè)觀察者在哪個(gè)調(diào)度器上觀察這個(gè)Observable撵摆，我們可以使用ObserveOn操作符
??指定Observable自身在哪個(gè)調(diào)度器上執(zhí)行我們可以使用SubscribeOn操作符

RxAndroid

RxAndroid是Rxjava的擴(kuò)展，是由JakeWharton編寫害晦，目的是使Android可以優(yōu)雅地處理異步請求并且完美融合Rxjava使用。RxAndroid為我們提供了一個(gè)AndroidSchedulers.mainThread()調(diào)度器暑中，我們可以在observer中自由切換線程壹瘟。

我們先寫個(gè)例子：

 Observable.just("one", "two", "three", "four", "five")
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(/* an Observer */);

這樣Observable會在子線程里處理事件，處理結(jié)果會發(fā)送到onnext回調(diào)方法中去鳄逾。

今天就先說這么多了稻轨，這一篇主要講了Rxjava的操作符和RxAndroid使用，下一章將結(jié)合Retrofit使用雕凹。