RxJava在Android開發(fā)中越來越流行，RxJava最核心的兩個東西是Observables（被觀察者、事件源）和Subscribers（觀察者）。Observables發(fā)出一系列事件，Subscribers處理這些事件，這里的事件可以是任何你感興趣的東西，比如觸摸事件、web接口調(diào)用返回的數(shù)據(jù)等。

基礎(chǔ)

Observable可以發(fā)出多個事件，知道結(jié)束或者出錯。每發(fā)出一個事件，就會調(diào)用與它綁定的Subscriber的onNext方法。最后調(diào)用Subscriber.onNext()或者Subscriber.onError()結(jié)束

Rxjava看起來很像設(shè)計(jì)模式中的觀察者模式，但是有一點(diǎn)明顯不同，那就是如果一個Observable沒有任何Subscriber，那么這個Observable是不會發(fā)出任何事件的。

• Hello World案例

//創(chuàng)建一個Observable對象，直接調(diào)用Observable.create即可
Observable<String> mObservable = Observable.create( new Observable.onSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> sub) {
         sub.onNext("Hello world");
         sub.onCompleted();
    }
};

這里定義的Observable對象僅僅發(fā)出一個hello world字符串，然后就結(jié)束了。然后我們創(chuàng)建一個Subscriber來處理Observable對象發(fā)出的字符串

Subscriber<String> mySubsriber = new Subscriber<String>() {
    @Override
    public void onCompleted() {    }
    @Override
    public void onError(Throwable throwable) {    }
    @Override
    public void onNext(String s) {
      system.out.println(s);
    }
};
myObservable.subscribe(mySubsriber);

這里subsriber僅僅就是打印Observable發(fā)出的字符串，通過subscribe函數(shù)可以將我們定義的myObservable對象和mySubscriber對象關(guān)聯(lián)起來，這樣就完成Subscriber和Observable的訂閱。一旦訂閱后，myObservable就會調(diào)用mySubscriber對象onNext和onComplete方法，mySubscriber就會打印出Hello world。

等價于

Rxjava其實(shí)提供了很多便捷函數(shù)來幫助我們來減少代碼。
1.利用Observable.just創(chuàng)建只發(fā)出一個事件就結(jié)束的Observable對象。

Observable<String> mOb = Observable.just("hello world");

2.接下來簡化Subscriber，其實(shí)我們關(guān)心的是onNext的一些處理?？梢允褂肁ction1類。
subscribe有一個重載方法，接受三個Action1類型的參數(shù)，分別對應(yīng)onNext、onComplete、onError函數(shù)；

myObservable.subscribe(onNextAction, onErrorAction, onCompleteAction); 

最終簡化代碼

Observable.just("hello world").subscribe(new Action1<String>() {
     @Override  
        public void call(String s) {  
              System.out.println(s);  
        }
});

或者使用java8的ambda使代碼更簡潔
Observable.just("hello world").subscribe(s -> System.out.println(s));

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

操作符

操作符就是為了解決對Observable對象的變換問題，操作符用于在Observable和最終的Subscriber之間修改Observable發(fā)出的事件。Rxjava提供了很多很有用的操作符。

• map操作符：用來把一個事件轉(zhuǎn)換為另一個事件

//打印Hello world -Dan
Observable.just("hello world")
        .map(new Func1<String, String>() {
            @Override
            public String call(String s) {
                return s + " -Dan";
            }
        }).subscribe(s -> System.out.print(s));
或
Observable.just("hello world").map(s -> s + " -Dan").subscribe(s -> System.out.print(s));

map()操作符就是用于變換Observable對象的，map操作符返回一個Observable對象，在一個Observable對象上可以多次使用map操作符，最終把最簡潔的數(shù)據(jù)傳遞給Subscriber對象。map操作符更有趣的一點(diǎn)是它不必返回Observable對象返回的類型，你可以使用map操作符返回一個發(fā)出新的數(shù)據(jù)類型的observable對象。

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))); 
OR
Observable.just("Hello, world!")  
    .map(s -> s.hashCode())  
    .subscribe(i -> System.out.println(Integer.toString(i)));  

前面說過，Subscriber做的事情越少越好，我們再增加一個map操作符

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

總結(jié)

1.Observable和Subscriber可以做任何事情
Observable可以是一個數(shù)據(jù)庫查詢，Subscriber用來顯示查詢結(jié)果；Observable可以是屏幕的點(diǎn)擊事件，Subscriber用來響應(yīng)點(diǎn)擊事件；Observable可以是一個網(wǎng)絡(luò)請求，Subscriber用來顯示請求結(jié)果。
2.Observable和Subs是獨(dú)立于中間的變換過程
在Observable和Subscriber中間可以增減任何數(shù)量map，整個系統(tǒng)是高度可組合的，操作數(shù)據(jù)是一個很簡單的過程。