RxJava在Android開發(fā)中越來越流行，RxJava最核心的兩個(gè)東西是Observables（被觀察者兴泥、事件源）和Subscribers（觀察者）工育。Observables發(fā)出一系列事件，Subscribers處理這些事件搓彻，這里的事件可以是任何你感興趣的東西如绸，比如觸摸事件、web接口調(diào)用返回的數(shù)據(jù)等旭贬。
基礎(chǔ)
Observable可以發(fā)出多個(gè)事件怔接，知道結(jié)束或者出錯(cuò)。每發(fā)出一個(gè)事件稀轨，就會(huì)調(diào)用與它綁定的Subscriber的onNext方法扼脐。最后調(diào)用Subscriber.onNext()或者Subscriber.onError()結(jié)束
Rxjava看起來很像設(shè)計(jì)模式中的觀察者模式，但是有一點(diǎn)明顯不同，那就是如果一個(gè)Observable沒有任何Subscriber瓦侮，那么這個(gè)Observable是不會(huì)發(fā)出任何事件的艰赞。
- Hello World案例
//創(chuàng)建一個(gè)Observable對(duì)象，直接調(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對(duì)象僅僅發(fā)出一個(gè)hello world字符串肚吏，然后就結(jié)束了方妖。然后我們創(chuàng)建一個(gè)Subscriber來處理Observable對(duì)象發(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對(duì)象和mySubscriber對(duì)象關(guān)聯(lián)起來罚攀，這樣就完成Subscriber和Observable的訂閱党觅。一旦訂閱后，myObservable就會(huì)調(diào)用mySubscriber對(duì)象onNext和onComplete方法斋泄，mySubscriber就會(huì)打印出Hello world杯瞻。
等價(jià)于
Rxjava其實(shí)提供了很多便捷函數(shù)來幫助我們來減少代碼。
1.利用Observable.just創(chuàng)建只發(fā)出一個(gè)事件就結(jié)束的Observable對(duì)象炫掐。
Observable<String> mOb = Observable.just("hello world");
2.接下來簡(jiǎn)化Subscriber魁莉，其實(shí)我們關(guān)心的是onNext的一些處理∽浞希可以使用Action1類沛厨。
subscribe有一個(gè)重載方法，接受三個(gè)Action1類型的參數(shù)摔认，分別對(duì)應(yīng)onNext逆皮、onComplete、onError函數(shù)参袱；
myObservable.subscribe(onNextAction, onErrorAction, onCompleteAction);
最終簡(jiǎn)化代碼
Observable.just("hello world").subscribe(new Action1<String>() {
@Override
public void call(String s) {
System.out.println(s);
}
});
或者使用java8的ambda使代碼更簡(jiǎn)潔
Observable.just("hello world").subscribe(s -> System.out.println(s));
Android開發(fā)中电谣，強(qiáng)烈推薦使用retrolambda這個(gè)gradle插件，這樣你就可以在你的代碼中使用lambda了抹蚀。
操作符
操作符就是為了解決對(duì)Observable對(duì)象的變換問題剿牺，操作符用于在Observable和最終的Subscriber之間修改Observable發(fā)出的事件。Rxjava提供了很多很有用的操作符环壤。
- map操作符：用來把一個(gè)事件轉(zhuǎn)換為另一個(gè)事件
//打印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對(duì)象的晒来，map操作符返回一個(gè)Observable對(duì)象，在一個(gè)Observable對(duì)象上可以多次使用map操作符郑现，最終把最簡(jiǎn)潔的數(shù)據(jù)傳遞給Subscriber對(duì)象湃崩。map操作符更有趣的一點(diǎn)是它不必返回Observable對(duì)象返回的類型，你可以使用map操作符返回一個(gè)發(fā)出新的數(shù)據(jù)類型的observable對(duì)象接箫。
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做的事情越少越好，我們?cè)僭黾右粋€(gè)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可以是一個(gè)數(shù)據(jù)庫(kù)查詢辛友，Subscriber用來顯示查詢結(jié)果薄扁；Observable可以是屏幕的點(diǎn)擊事件，Subscriber用來響應(yīng)點(diǎn)擊事件；Observable可以是一個(gè)網(wǎng)絡(luò)請(qǐng)求邓梅，Subscriber用來顯示請(qǐng)求結(jié)果脱盲。
2.Observable和Subs是獨(dú)立于中間的變換過程
在Observable和Subscriber中間可以增減任何數(shù)量map，整個(gè)系統(tǒng)是高度可組合的震放，操作數(shù)據(jù)是一個(gè)很簡(jiǎn)單的過程宾毒。
