(轉(zhuǎn))深入淺出RxJava(一:基礎(chǔ)篇)

原文

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ù)是一個很簡單的過程绅络。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市嘁字,隨后出現(xiàn)的幾起案子恩急,更是在濱河造成了極大的恐慌,老刑警劉巖纪蜒,帶你破解...
    沈念sama閱讀 211,042評論 6 490
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件衷恭,死亡現(xiàn)場離奇詭異,居然都是意外死亡纯续,警方通過查閱死者的電腦和手機随珠,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 89,996評論 2 384
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來猬错,“玉大人窗看,你說我怎么就攤上這事【氤矗” “怎么了烤芦?”我有些...
    開封第一講書人閱讀 156,674評論 0 345
  • 文/不壞的土叔 我叫張陵,是天一觀的道長析校。 經(jīng)常有香客問我构罗,道長,這世上最難降的妖魔是什么智玻? 我笑而不...
    開封第一講書人閱讀 56,340評論 1 283
  • 正文 為了忘掉前任遂唧,我火速辦了婚禮,結(jié)果婚禮上吊奢,老公的妹妹穿的比我還像新娘盖彭。我一直安慰自己纹烹,他們只是感情好,可當(dāng)我...
    茶點故事閱讀 65,404評論 5 384
  • 文/花漫 我一把揭開白布召边。 她就那樣靜靜地躺著铺呵,像睡著了一般。 火紅的嫁衣襯著肌膚如雪隧熙。 梳的紋絲不亂的頭發(fā)上片挂,一...
    開封第一講書人閱讀 49,749評論 1 289
  • 那天,我揣著相機與錄音贞盯,去河邊找鬼音念。 笑死,一個胖子當(dāng)著我的面吹牛躏敢,可吹牛的內(nèi)容都是我干的闷愤。 我是一名探鬼主播,決...
    沈念sama閱讀 38,902評論 3 405
  • 文/蒼蘭香墨 我猛地睜開眼件余,長吁一口氣:“原來是場噩夢啊……” “哼讥脐!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起啼器,我...
    開封第一講書人閱讀 37,662評論 0 266
  • 序言:老撾萬榮一對情侶失蹤旬渠,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后镀首,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,110評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡鼠次,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,451評論 2 325
  • 正文 我和宋清朗相戀三年更哄,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片腥寇。...
    茶點故事閱讀 38,577評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡成翩,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出赦役,到底是詐尸還是另有隱情麻敌,我是刑警寧澤,帶...
    沈念sama閱讀 34,258評論 4 328
  • 正文 年R本政府宣布掂摔,位于F島的核電站术羔,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏乙漓。R本人自食惡果不足惜级历,卻給世界環(huán)境...
    茶點故事閱讀 39,848評論 3 312
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望叭披。 院中可真熱鬧寥殖,春花似錦、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,726評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至粤策,卻和暖如春樟澜,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背掐场。 一陣腳步聲響...
    開封第一講書人閱讀 31,952評論 1 264
  • 我被黑心中介騙來泰國打工往扔, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人熊户。 一個月前我還...
    沈念sama閱讀 46,271評論 2 360
  • 正文 我出身青樓萍膛,卻偏偏與公主長得像,于是被迫代替她去往敵國和親嚷堡。 傳聞我的和親對象是個殘疾皇子蝗罗,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,452評論 2 348

推薦閱讀更多精彩內(nèi)容