摘要:第一篇只介紹了的基本用法,暫時還無法看出的優勢。不僅把每個事件多帶帶處理,還會把它們看做一個隊列。在事件處理過程中出異常時,會被觸發,同時隊列自動終止,不允許再有事件發出。可以使用或來創建一個,并為它定義事件觸發規則。
前言
最近經常看到RxJava這個字眼,也看到很多人在博客中推薦使用RxJava。好奇的我怎么能錯過,于是Google了一下,說RxJava好用的和說RxJava難用的都有,于是自己也親自嘗試了一下(感覺不容易上手)。寫博客記錄下學習的過程,一方面作為鞏固,另一方面希望能幫助到初學者。
(第一篇只介紹了RxJava的基本用法,暫時還無法看出RxJava的優勢。切莫著急,隨著慢慢深入就能體會到RxJava帶來的方便了)
參考:給 Android 開發者的 RxJava 詳解介紹
(本文部分內容引用自該博客)
在GitHub主頁上的介紹:
a library for composing asynchronous and event-based programs using observable sequences for the Java VM
翻譯過來就是:
一個在 Java VM 上使用可觀測的序列來組成異步的、基于事件的程序的庫
對于新手們來說這個太抽象了,我們(我也是新手)需要看到看到一個更加具體的解釋,簡單來說,它就是一個實現異步操作的庫。(還是不懂?看代碼更實在)
優點RxJava的好處就在于它的簡潔性,邏輯簡單的時候看不出RxJava的優勢,想必大家都知道在調度過程比較復雜的情況下,異步代碼經常會既難寫也難被讀懂。這時候RxJava的優勢就來了,隨著程序邏輯變得越來越復雜,它依然能夠保持簡潔。
觀察者模式首先要先介紹一下觀察者模式(可能比喻的不夠恰當,意思到了就好);
觀察者:監視著被觀察者的行為,當被觀察者某個狀態改變的時候會通知觀察者,觀察者會執行對應的操作;
被觀察者:被監視的對象,當某個狀態改變的時候會通知觀察者;
訂閱(或注冊):將觀察者和被觀察者建立聯系。
(很亂?來個栗子?)
這里舉一個我個常用的例子,點擊Button后觸發OnClickListener
中的onClick()事件。在這個事件中他們的角色分別如下:
觀察者:OnClickListener;
被觀察者:Button;
訂閱(或注冊):setOnClickListener()。
RxJava在上面介紹了觀察者模式,這里也將RxJava中的三個角色進行一下角色分配
觀察者:Observer;
被觀察者:Observable;
訂閱(或注冊):subscribe()。
觀察者
Observer 即觀察者,它決定事件觸發的時候將有怎樣的行為。
RxJava 觀察者的事件回調方法除了普通事件onNext()(相當于onClick()/onEvent())之外,還定義了兩個特殊的事件:onCompleted()和onError()。
onCompleted(): 事件隊列完結。RxJava 不僅把每個事件多帶帶處理,還會把它們看做一個隊列。RxJava 規定,當不會再有新的onNext()發出時,需要觸發onCompleted()方法作為標志。
onError(): 事件隊列異常。在事件處理過程中出異常時,onError()
會被觸發,同時隊列自動終止,不允許再有事件發出。
在一個正確運行的事件序列中,onCompleted()和onError()有且只有一個,并且是事件序列中的最后一個。需要注意的是,onCompleted()
和onError()二者也是互斥的,即在隊列中調用了其中一個,就不應該再調用另一個。
被觀察者
Observable 即被觀察者,它決定什么時候觸發事件以及觸發怎樣的事件。可以使用create()、just(T...)、from(T[])或from(Iterable extends T>)來創建一個 Observable ,并為它定義事件觸發規則。
訂閱
創建了Observable和Observer之后,再用subscribe()方法將它們聯結起來
直接看代碼吧,這里只展示了RxJava的基本用法,暫時看不出RxJava的優勢。
使用例:打印機個字符串
添加依賴
compile "io.reactivex:rxjava:1.0.14" compile "io.reactivex:rxandroid:1.0.1"
//創建一個觀察者 Observerobserver = new Observer () { @Override public void onCompleted() { Log.i(TAG, "Completed"); } @Override public void onError(Throwable e) { Log.i(TAG, "Error"); } @Override public void onNext(String s) { Log.i(TAG, s); } }; //使用Observable.create()創建被觀察者 Observable observable1 = Observable.create(new Observable.OnSubscribe () { @Override public void call(Subscriber super String> subscriber) { subscriber.onNext("Hello"); subscriber.onNext("Wrold"); subscriber.onCompleted(); } }); //訂閱 observable1.subscribe(observer);
以上用到的都是rx包里面的,別用錯了!!!
上面完成了一次Rxjava的基本使用。
擴展Subscriber
除了Observer接口之外,RxJava 還內置了一個實現了Observer的抽象:Subscriber。Subscriber對Observer接口進行了一些擴展,但他們的基本使用方式是完全一樣的:
Subscribersubscriber = new Subscriber () { @Override public void onNext(String s) { Log.d(tag, "Item: " + s); } @Override public void onCompleted() { Log.d(tag, "Completed!"); } @Override public void onError(Throwable e) { Log.d(tag, "Error!"); } };
不僅基本使用方式一樣,實質上,在 RxJava 的 subscribe 過程中,Observer也總是會先被轉換成一個Subscriber再使用。如圖:
所以如果你只想使用基本功能,選擇Observer和Subscriber是完全一樣的。它們的區別對于使用者來說主要有兩點:
onStart(): 這是Subscriber增加的方法。它會在 subscribe 剛開始,而事件還未發送之前被調用,可以用于做一些準備工作,例如數據的清零或重置。這是一個可選方法,默認情況下它的實現為空。需要注意的是,如果對準備工作的線程有要求(例如彈出一個顯示進度的對話框,這必須在主線程執行),onStart()就不適用了,因為它總是在 subscribe 所發生的線程被調用,而不能指定線程。要在指定的線程來做準備工作,可以使用doOnSubscribe()方法,具體可以在后面的文中看到。
unsubscribe(): 這是Subscriber所實現的另一個接口Subscription
的方法,用于取消訂閱。在這個方法被調用后,Subscriber將不再接收事件。一般在這個方法調用前,可以使用isUnsubscribed()先判斷一下狀態。unsubscribe()這個方法很重要,因為在subscribe()之后,Observable會持有Subscriber的引用,這個引用如果不能及時被釋放,將有內存泄露的風險。所以最好保持一個原則:要在不再使用的時候盡快在合適的地方(例如onPause()onStop()等方法中)調用unsubscribe()來解除引用關系,以避免內存泄露的發生。
Observable
Observable的其他幾種創建方法,一下Observable等價于之前使用Create()創建的Observable:
1、使用Observable.just()創建被觀察者
Observable observable2 = Observable.just("Hello", "World");
2、使用Observable.from()創建被觀察者
String [] words = {"Hello", "World"}; Observable observable3 = Observable.from(words);
或
List小結list = new ArrayList (); list.add("Hellow"); list.add("Wrold"); Observable observable4 = Observable.from(list);
目前沒看出RxJava的任何好處,感覺代碼還多了~~~
(別急,因為是第一篇,我只介紹了他們之間的關系以及最基礎的用法。后面的幾篇我會介紹RxJava的其他功能,還有一些復雜的嵌套關系的處理,到時候知道RxJava的強大之處了)
更多:
Android RxJava的使用(二)Action
Android RxJava的使用(三)轉換(map、flatMap)
Android RxJava的使用(四)線程控制 —— Scheduler
以上有錯誤之處感謝指出
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/73384.html
摘要:前兩篇的使用一基本用法的使用二介紹了的基本用法,對還不了解的請先看以上兩篇。這篇為大家講解中和的使用。注意對這些發射的數據做的是合并操作,因此它們可能是交錯的。如果要保證順的的話,可以使用。其他操作符除了和之外,還有其他操作符以供使用。 前兩篇Android RxJava的使用(一)基本用法、Android RxJava的使用(二)Action介紹了RxJava的基本用法,對Rxjav...
摘要:回顧在上一節的使用一基本用法中,介紹了的基本用法。它同樣只有一個方法,這個方法也無返回值,但有一個參數與同理,由于和也是單參數無返回值的,因此可以將和打包起來傳入以實現不完整定義的回調的使用定義三個對象,分別打包。 回顧 在上一節Android RxJava的使用(一)基本用法中,介紹了RxJava的基本用法。下面來回顧下實現一次RxJava的基本使用。例:分別打印Hello、 Wor...
閱讀 742·2021-07-25 21:37
閱讀 3654·2019-08-30 15:55
閱讀 2572·2019-08-30 15:54
閱讀 1717·2019-08-30 15:44
閱讀 3123·2019-08-30 15:44
閱讀 859·2019-08-30 15:43
閱讀 1024·2019-08-29 15:36
閱讀 3038·2019-08-29 10:58