原文鏈接

Rxjava正在Android開(kāi)發(fā)者中變得越來(lái)越流行。唯一的問(wèn)題就是上手不容易，尤其是大部分人之前都是使用命令式編程語(yǔ)言。但是一旦你弄明白了，你就會(huì)發(fā)現(xiàn)Rxjava真是太棒了。這里僅僅是幫助你了解Rxjava , 整個(gè)系統(tǒng)共有四篇文章，希望你看完這四篇文章之后能夠了解Rxjava背后的思想，并喜歡上Rxjava。

基礎(chǔ)

• Rxjava最核心的兩個(gè)東西是Observables (被觀察者，事件源) 和Subscribers (觀察者)。Obserables發(fā)出一系列事件，Subscribers處理這些事件。這里的事件可以是任何你感興趣的東西（觸摸事件，web接口調(diào)用返回的數(shù)據(jù)...）
• 一個(gè)Observable可以發(fā)出零個(gè)或者多個(gè)事件，直到結(jié)束或者出錯(cuò)。每發(fā)出一個(gè)事件，就會(huì)調(diào)用它的Subscriber的onNext()方法，最后調(diào)用Subscriber.onNext()或者Subscriber.onError()結(jié)束。
• Rxjava看起來(lái)很像設(shè)計(jì)模式中的觀察者模式，但是有一點(diǎn)明顯不同，那就是如果一個(gè)Observaber沒(méi)有任何的Subscriber，那么這個(gè)Observable是不會(huì)發(fā)出任何事件的。

Hello Word

創(chuàng)建一個(gè)Observable對(duì)象很簡(jiǎn)單，直接調(diào)用Observable.create()即可

Observable<String> myObservable = Observable.create( 
      new Observable.OnSubscribe<String>() {  
      @Override  
      public void call(Subscriber<? super String> sub) {  
          sub.onNext("Hello, world!");  
          sub.onCompleted();  
           }  
        }  
    );

這里定義的Observable對(duì)象僅僅發(fā)出一個(gè)Hello Word字符串，然后就結(jié)束了。接著我們創(chuàng)建一個(gè)Subscriber來(lái)處理Observable 對(duì)象發(fā)出的字符串。

Subscriber<String> mySubscriber = new Subscriber<String>() {  
    @Override  
    public void onNext(String s) { System.out.println(s); }  
  
    @Override  
    public void onCompleted() { }  
  
    @Override  
    public void onError(Throwable e) { }  
};  

這里Subscriber僅僅就是打印Observable發(fā)出的字符串。通過(guò)Subscriber函數(shù)就可以將我們定義的myObservable對(duì)象和mySubscriber對(duì)象關(guān)聯(lián)起來(lái)，這樣就完成了Subscriber對(duì)Observable的訂閱。

myObservable.subscribe(mySubscriber);  

一旦mySubscriber訂閱了myObservable就是調(diào)用mySubscriber對(duì)象的onNext()和onComplete()方法，mySubscriber就回打印出Hello Word!

更簡(jiǎn)潔的代碼

是不是覺(jué)得僅僅為了打印一個(gè)hello word 要寫(xiě)這么多代碼太啰嗦？ 我這里主要是為了展示Rxjava背后的原理而采用了這種比較啰嗦的寫(xiě)法，Rxjava其實(shí)提供了很多便捷的函數(shù)來(lái)幫助我們減少代碼量。

• 首先來(lái)看看如何簡(jiǎn)化Observable對(duì)象的創(chuàng)建過(guò)程。Rxjava內(nèi)置了很多簡(jiǎn)化創(chuàng)建Observable對(duì)象的函數(shù)，比如Observable.jus()就是用來(lái)創(chuàng)建只發(fā)出一個(gè)事件就結(jié)束的Observable對(duì)象，上面創(chuàng)建Observable對(duì)象就可以簡(jiǎn)化為一行

Observable<String> myObservable = Observable.just("Hello, world!");  

• 接下來(lái)看如何簡(jiǎn)化Subscriber,上面的例子中，我們其實(shí)并不關(guān)心OnComplete和OnError, 我們只需要在onNext的時(shí)候做一些處理，這時(shí)候就可以食用Action1類(lèi)。

Action1<String> onNextAction = new Action1<String>() {  
    @Override  
    public void call(String s) {  
        System.out.println(s);  
    }  
}; 

• subscriber方法有一個(gè)重載版本，接受三個(gè)Action1的參數(shù)，分別對(duì)應(yīng)OnNext,OnComplete,OnError函數(shù)。

myObservable.subscribe(onNextAction, onErrorAction, onCompleteAction);  

這里我們并不關(guān)心onError和onComplete,所以只需要一個(gè)參數(shù)就可以

myObservable.subscribe(onNextAction);  
// Outputs "Hello, world!" 

上面的代碼最終可以寫(xiě)成這樣

Observable.just("Hello ,Word!")
         .subscriber(new Action1<String>(){
         @overrider
         public void call(String s){
                    System.out.println(s);
         }
});

使用java8的lambda可以使代碼更簡(jiǎn)潔

Observable.just("Hello, world!")  
    .subscribe(s -> System.out.println(s));  

Android開(kāi)發(fā)中，強(qiáng)烈推薦使用retrolambda這個(gè)gradle插件，這樣你就可以在你的代碼中使用lambda了。

變換

讓我們做一些更有趣的事情吧！
比如我想在hello world中加上我的簽名，你可能會(huì)想到去修改Observable對(duì)象：

Observable.just("Hello, world! -Dan")  
    .subscribe(s -> System.out.println(s));  

如果你能夠改變Observable對(duì)象，這當(dāng)然是可以的，但是如果你不能修改Observable對(duì)象呢？比如Observable對(duì)象是第三方庫(kù)提供的？比如我的Observable對(duì)象被多個(gè)Subscriber訂閱，但是我只想在對(duì)某個(gè)訂閱者做修改呢？
那么在Subscriber中對(duì)事件進(jìn)行修改怎么樣呢？比如下面的代碼：

Observable.just("Hello, world!")  
    .subscribe(s -> System.out.println(s + " -Dan"));  

這種方式仍然不能讓人滿(mǎn)意，因?yàn)槲蚁Ｍ业腟ubscribers越輕量越好，因?yàn)槲矣锌赡軙?huì)在mainThread中運(yùn)行subscriber。另外，根據(jù)響應(yīng)式函數(shù)編程的概念，Subscribers更應(yīng)該做的事情是“響應(yīng)”，響應(yīng)Observable發(fā)出的事件，而不是去修改。如果我能在某些中間步驟中對(duì)“Hello World！”進(jìn)行變換是不是很酷？

操作符（Operators）

操作符就是為了解決對(duì)Observable對(duì)象的變換的問(wèn)題，操作符用于在Observable和最終的Subscriber之間修改Observable發(fā)出的事件。RxJava提供了很多很有用的操作符。
比如map操作符，就是用來(lái)把把一個(gè)事件轉(zhuǎn)換為另一個(gè)事件的。

Observable.just("Hello, world!")  
  .map(new Func1<String, String>() {  
      @Override  
      public String call(String s) {  
          return s + " -Dan";  
      }  
  })  
  .subscribe(s -> System.out.println(s));  

使用lambda可以簡(jiǎn)化為

Observable.just("Hello, world!")  
    .map(s -> s + " -Dan")  
    .subscribe(s -> System.out.println(s));  

是不是很酷？map()操作符就是用于變換Observable對(duì)象的，map操作符返回一個(gè)Observable對(duì)象，這樣就可以實(shí)現(xiàn)鏈?zhǔn)秸{(diào)用，在一個(gè)Observable對(duì)象上多次使用map操作符，最終將最簡(jiǎn)潔的數(shù)據(jù)傳遞給Subscriber對(duì)象。

map操作符進(jìn)階

map操作符更有趣的一點(diǎn)是它不必返回Observable對(duì)象返回的類(lèi)型，你可以使用map操作符返回一個(gè)發(fā)出新的數(shù)據(jù)類(lèi)型的observable對(duì)象。
比如上面的例子中，subscriber并不關(guān)心返回的字符串，而是想要字符串的hash值

Observable.just("Hello, world!")  
    .map(new Func1<String, Integer>() {  
        @Override  
        public Integer call(String s) {  
            return s.hashCode();  
        }  
    })  
    .subscribe(i -> System.out.println(Integer.toString(i)));  

很有趣吧？我們初始的Observable返回的是字符串，最終的Subscriber收到的卻是Integer，當(dāng)然使用lambda可以進(jìn)一步簡(jiǎn)化代碼：

Observable.just("Hello, world!")  
    .map(s -> s.hashCode())  
    .subscribe(i -> System.out.println(Integer.toString(i)));  

前面說(shuō)過(guò)，Subscriber做的事情越少越好，我們?cè)僭黾右粋€(gè)map操作符

Observable.just("Hello, world!")  
    .map(s -> s.hashCode())  
    .map(i -> Integer.toString(i))  
    .subscribe(s -> System.out.println(s));  

不服？
是不是覺(jué)得我們的例子太簡(jiǎn)單，不足以說(shuō)服你？你需要明白下面的兩點(diǎn):

• Observable和Subscriber可以做任何事情

Observable可以是一個(gè)數(shù)據(jù)庫(kù)查詢(xún)，Subscriber用來(lái)顯示查詢(xún)結(jié)果；Observable可以是屏幕上的點(diǎn)擊事件，Subscriber用來(lái)響應(yīng)點(diǎn)擊事件；Observable可以是一個(gè)網(wǎng)絡(luò)請(qǐng)求，Subscriber用來(lái)顯示請(qǐng)求結(jié)果。

• Observable和Subscriber是獨(dú)立于中間的變換過(guò)程的。

在Observable和Subscriber中間可以增減任何數(shù)量的map。整個(gè)系統(tǒng)是高度可組合的，操作數(shù)據(jù)是一個(gè)很簡(jiǎn)單的過(guò)程。