RxJava正在Android開發(fā)者中變的越來越流行。唯一的問題就是上手不容易越走，尤其是大部分人之前都是使用命令式編程語言蜜氨。但是一旦你弄明白了蚜迅，你就會發(fā)現(xiàn)RxJava真是太棒了。這里僅僅是幫助你了解RxJava诬乞，整個系列共有四篇文章册赛，希望你看完這四篇文章之后能夠了解RxJava背后的思想，并且喜歡上RxJava丽惭。
基礎(chǔ)
RxJava最核心的兩個東西是Observables（被觀察者击奶，事件源）和Subscribers（觀察者）。Observables發(fā)出一系列事件责掏，Subscribers處理這些事件柜砾。這里的事件可以是任何你感興趣的東西（觸摸事件，web接口調(diào)用返回的數(shù)據(jù)换衬。痰驱。证芭。）一個Observable可以發(fā)出零個或者多個事件，知道結(jié)束或者出錯担映。每發(fā)出一個事件废士，就會調(diào)用它的Subscriber的onNext方法，最后調(diào)用Subscriber.onNext()或者Subscriber.onError()結(jié)束蝇完。
Rxjava的看起來很想設(shè)計模式中的觀察者模式官硝，但是有一點明顯不同，那就是如果一個Observerble沒有任何的的Subscriber短蜕，那么這個Observable是不會發(fā)出任何事件的氢架。
Hello World
創(chuàng)建一個Observable對象很簡單，直接調(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對象僅僅發(fā)出一個Hello World字符串朋魔，然后就結(jié)束了岖研。接著我們創(chuàng)建一個Subscriber來處理Observable對象發(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ā)出的字符串警检。通過subscribe函數(shù)就可以將我們定義的myObservable對象和mySubscriber對象關(guān)聯(lián)起來孙援，這樣就完成了subscriber對observable的訂閱。
myObservable.subscribe(mySubscriber);
一旦mySubscriber訂閱了myObservable扇雕，myObservable就是調(diào)用mySubscriber對象的onNext和onComplete方法拓售，mySubscriber就會打印出Hello World！
更簡潔的代碼
是不是覺得僅僅為了打印一個hello world要寫這么多代碼太啰嗦镶奉？我這里主要是為了展示RxJava背后的原理而采用了這種比較啰嗦的寫法邻辉，RxJava其實提供了很多便捷的函數(shù)來幫助我們減少代碼。首先來看看如何簡化Observable對象的創(chuàng)建過程腮鞍。RxJava內(nèi)置了很多簡化創(chuàng)建Observable對象的函數(shù)值骇，比如Observable.just就是用來創(chuàng)建只發(fā)出一個事件就結(jié)束的Observable對象，上面創(chuàng)建Observable對象的代碼可以簡化為一行
Observable<String> myObservable = Observable.just("Hello, world!");
接下來看看如何簡化Subscriber移国，上面的例子中吱瘩，我們其實并不關(guān)心OnComplete和OnError，我們只需要在onNext的時候做一些處理迹缀，這時候就可以使用Action1類使碾。
Action1<String> onNextAction = new Action1<String>() {
@Override
public void call(String s) {
System.out.println(s);
}
};
subscribe方法有一個重載版本，接受三個Action1類型的參數(shù)祝懂，分別對應(yīng)OnNext票摇，OnComplete， OnError函數(shù)砚蓬。
myObservable.subscribe(onNextAction, onErrorAction, onCompleteAction);
這里我們并不關(guān)心onError和onComplete矢门，所以只需要第一個參數(shù)就可以
myObservable.subscribe(onNextAction);
//上面的代碼最終可以寫成這樣
Observable.just("Hello, world!")
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
System.out.println(s);
}
});
//使用java8的lambda可以使代碼更簡潔
Observable.just("Hello, world!").subscribe(s -> System.out.println(s));
Android開發(fā)中，強烈推薦使用retrolambda這個gradle插件，這樣你就可以在你的代碼中使用lambda了祟剔。
變換
讓我們做一些更有趣的事情吧隔躲！比如我想在hello world中加上我的簽名，你可能會想到去修改Observable對象：
Observable.just("Hello, world! -Dan").subscribe(s -> System.out.println(s));
如果你能夠改變Observable對象物延，這當(dāng)然是可以的宣旱，但是如果你不能修改Observable對象呢？比如Observable對象是第三方庫提供的叛薯？比如我的Observable對象被多個Subscriber訂閱浑吟，但是我只想在對某個訂閱者做修改呢？那么在Subscriber中對事件進行修改怎么樣呢耗溜？比如下面的代碼：
Observable.just("Hello, world!").subscribe(s -> System.out.println(s + " -Dan"));
這種方式仍然不能讓人滿意买置，因為我希望我的Subscribers越輕量越好，因為我有可能會在mainThread中運行subscriber强霎。另外，根據(jù)響應(yīng)式函數(shù)編程的概念蓉冈，Subscribers更應(yīng)該做的事情是“響應(yīng)”城舞，響應(yīng)Observable發(fā)出的事件，而不是去修改寞酿。如果我能在某些中間步驟中對“Hello World家夺！”進行變換是不是很酷？
操作符（Operators）
操作符就是為了解決對Observable對象的變換的問題伐弹，操作符用于在Observable和最終的Subscriber之間修改Observable發(fā)出的事件拉馋。RxJava提供了很多很有用的操作符。比如map操作符惨好，就是用來把把一個事件轉(zhuǎn)換為另一個事件的煌茴。
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可以簡化為
Observable.just("Hello, world!")
.map(s -> s + " -Dan")
.subscribe(s -> System.out.println(s));
是不是很酷？map()操作符就是用于變換Observable對象的日川，map操作符返回一個Observable對象蔓腐，這樣就可以實現(xiàn)鏈?zhǔn)秸{(diào)用，在一個Observable對象上多次使用map操作符龄句，最終將最簡潔的數(shù)據(jù)傳遞給Subscriber對象回论。
map操作符進階
map操作符更有趣的一點是它不必返回Observable對象返回的類型，你可以使用map操作符返回一個發(fā)出新的數(shù)據(jù)類型的observable對象分歇。比如上面的例子中傀蓉，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可以進一步簡化代碼：
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));
不服靶草？
是不是覺得我們的例子太簡單，不足以說服你岳遥？你需要明白下面的兩點:1.Observable和Subscriber可以做任何事情Observable可以是一個數(shù)據(jù)庫查詢奕翔，Subscriber用來顯示查詢結(jié)果；Observable可以是屏幕上的點擊事件浩蓉，Subscriber用來響應(yīng)點擊事件派继；Observable可以是一個網(wǎng)絡(luò)請求，Subscriber用來顯示請求結(jié)果捻艳。2.Observable和Subscriber是獨立于中間的變換過程的驾窟。在Observable和Subscriber中間可以增減任何數(shù)量的map。整個系統(tǒng)是高度可組合的认轨，操作數(shù)據(jù)是一個很簡單的過程绅络。
