RxJava "a library for composing asynchronous and event-based programs using observable sequences for the Java VM"（一個在 Java VM 上使用可觀測的序列來組成異步的、基於事件的程序的庫）。java
Rxjava 來講能夠用三個詞來歸納 「異步」 「高效」 「靈活」react
Android工程引入RxJava-android 請引入Rxandroid庫：compile 'io.reactivex:rxandroid:1.2.1'
一簡介
1.1 Rx結構
響應式編程的主要組成部分是observable, operator和susbscriber,通常響應式編程的信息流以下所示：
Observable -> Operator 1 -> Operator 2 -> Operator 3 -> Subscriber
也就是說，observable是事件的生產者，subscriber是事件最終的消費者。
由於subscriber一般在主線程中執行，所以設計上要求其代碼儘量簡單，只對事件進行響應，而修改事件的工做所有由operator執行。
在響應式編程中，應該牢記如下兩點：everything is a stream（一切皆流）don't break the chain（不要打斷鏈式結構）
1.2 最簡單的模式
若是咱們不須要修改事件，就不須要在observable和subscriber中插入operator。這時的Rx結構以下：
Obsevable -> Subscriber
這看起來很像設計模式中的觀察者模式，他們最重要的區別之一在於在沒有subscriber以前，observable不會產生事件。android
拓展的觀察者模式web
二. 基本實現數據庫
1) 建立 Observer
Observer 即觀察者，它決定事件觸發的時候將有怎樣的行爲。
2) 建立 Observable
Observable 即被觀察者，它決定何時觸發事件以及觸發怎樣的事件。
3) Subscribe (訂閱)
建立了 Observable和 Observer以後，再用 subscribe()方法將它們聯結起來，整條鏈子就能夠工做了。編程
observable.subscribe(observer);// 或者：observable.subscribe(subscriber);
整個過程當中對象間的關係設計模式
三. 線程控制
線程控制 —— Scheduler (一)
在RxJava 中，Scheduler
——調度器，至關於線程控制器，RxJava 經過它來指定每一段代碼應該運行在什麼樣的線程。RxJava 已經內置了幾個 Scheduler，它們已經適合大多數的使用場景：
Schedulers.immediate(): 直接在當前線程運行，至關於不指定線程。這是默認的 Scheduler。
Schedulers.newThread(): 老是啓用新線程，並在新線程執行操做。
Schedulers.io(): I/O 操做（讀寫文件、讀寫數據庫、網絡信息交互等）所使用的 Scheduler。
Schedulers.computation(): 計算所使用的 Scheduler。
Android 還有一個專用的 AndroidSchedulers.mainThread()，它指定的操做將在 Android 主線程運行。
示例：微信
Observable.just(1, 2, 3, 4)
.subscribeOn(Schedulers.io()) // 指定 subscribe() 發生在 IO 線程
.observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回調發生在主線程
.subscribe(new Action1<Integer>() {
@Override public void call(Integer number) {
Log.d(tag, "number:" + number); } });
線程控制：Scheduler (二)
線程的自由控制:能夠利用 subscribeOn()結合 observeOn()來實現線程控制，讓事件的產生和消費發生在不一樣的線程。網絡
Observable.just(1, 2, 3, 4) // IO 線程，由 subscribeOn() 指定 .subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.map(mapOperator) // 新線程，由 observeOn() 指定
.observeOn(Schedulers.io())
.map(mapOperator2) // IO 線程，由 observeOn() 指定 .observeOn(AndroidSchedulers.mainThread)
.subscribe(subscriber); // Android 主線程，由 observeOn() 指定
多個 subscribeOn()和 observeOn()
混合使用時，線程調度狀態架構
四.操做符
RxJava提供了不少便捷的操做符，即上文提到的Operator,經常使用到的Operator例如map,flatmap等
map( ) — 對序列的每一項都應用一個函數來變換Observable發射的數據序列
Observable.just("images/logo.png") // 輸入類型 String .map(new Func1<String, Bitmap>() {
@Override public Bitmap call(String filePath) {
// 參數類型 String
return getBitmapFromPath(filePath); // 返回類型 Bitmap } }) .subscribe(new Action1<Bitmap>() {
@Override public void call(Bitmap bitmap) {
// 參數類型 Bitmap showBitmap(bitmap); } });
map()方法將參數中的 String對象轉換成一個 Bitmap對象後返回，而在通過 map()方法後，事件的參數類型也由 String轉爲了 Bitmap。這種直接變換對象並返回的，是最多見的也最容易理解的變換。
flatMap( ), concatMap( ), and flatMapIterable( ) — 將Observable發射的數據集合變換爲Observables集合，而後將這些Observable發射的數據平坦化的放進一個單獨的Observable
Student[] students = ...;
Subscriber<Course> subscriber = new Subscriber<Course>() {
@Override public void onNext(Course course) {
Log.d(tag, course.getName()); } ...};
Observable.from(students)
.flatMap(new Func1<Student, Observable<Course>>() {
@Override public Observable<Course> call(Student student) {
return Observable.from(student.getCourses()); } })
.subscribe(subscriber);
從上面的代碼能夠看出， flatMap()和 map()有一個相同點：它也是把傳入的參數轉化以後返回另外一個對象。但須要注意，和 map()不一樣的是， flatMap()中返回的是個 Observable對象，而且這個 Observable對象並非被直接發送到了 Subscriber的回調方法中。
五.java回調地獄
若是你是個Callback高手，善用而且可以用好FutureTask。 那麼在Android中你的代碼可能會頻繁的使用async+callbacks，或者service composition+ error handing，developer productivity 。 那麼關於異步回調的邏輯，你會寫成這樣getData(Callback)、這樣Future<T> getData()，仍是這樣Future<List<T>> getData()，甚至這樣Future<List<Future<T>>> getData() 。。。。。。沒法表達CallBack給java菜鳥帶來的壓力了。。。異步回調的過程當中必需要求時刻保持清醒的頭腦，靈活的意識，劍拔弩張的情緒，不然是寫很差回調事件的
搞張圖提神醒腦下:
everything is a stream（一切皆流）
然而使用RxJava的操做符，咱們能夠避免這些煩人甚至糟糕的回調，讓結構和思路看起來更清晰，經過組合API，只須要約定最終的結果Observable就好了。 而且scheduler的出現，不只解放了線程的切換，讓UI線程與工做線程間的跳轉變得簡單，並且，它的API很豐，也提供了不少使用常見的建議，好比，適用計算任務的Schedulers.computation( )；處理密集IO任務的Schedulers.io( )；以及Schedulers.trampoline( )可以有效避免StackOverflowError，因此很是適合函數的遞歸調用。
五.與EVENTBUS的區別
EventBus是一個發佈 / 訂閱的事件總線。簡單點說，就是兩人約定好怎麼通訊，一人發佈消息，另一個約定好的人立馬接收到你發的消息。
主要區別是，rx裏面當創建起訂閱關係時，你能夠用操做符作任何處理（好比轉換數據，更改數據等等），並且他能處理異步的操做。 eventbus 就至關於廣播，發送了，總能接收到，他在發送後是不能作任何的數據改變，若是要改變，又要從新post一次。
六.RxJava多帶來的好處
先來上張最喜歡的圖：
Observables 和 Observers
１．解決了異步回調CallBack的問題
２．解決線程切換問題，封裝了各類併發實現，如threads, pools, event loops, fibers, actors。
３．可以知道何時訂閱者已經接收了所有的數據。
４．全部的錯誤所有在onError中處理，在操做符不須要處理異常
５．輕量，無依賴庫、Jar包小於1M
６．Java中若是不使用觀察者模式，數據都是主動獲取，即Pull方式，對於列表數據，也是使用Iterator輪詢獲取。RxJava因爲用到了觀察者模式，數據是被動獲取，由被觀察者向觀察者發出通知，即Push方式。
７．數據傳遞方式同步和異步都是鏈式調用，即operation1 -> operation2 -> operation3，這種作法的好處就是即時再複雜的邏輯都簡單明瞭，不容易出錯。
８．比觀察者模式功能更強大，在onNext()回調方法基礎上增長了onCompleted()和OnError()，當事件執行完或執行出錯時回調。此外還能夠很方便的切換事件生產和消費的線程。事件能夠組合處理。
以上是看了這些東西的新的，關於架構方面，結合mvp架構和retrofit等結構化框架流式框架會更清晰
本文分享自微信公衆號 - 喘口仙氣（gh_db8538619cdd）。
若有侵權，請聯繫 support@oschina.cn 刪除。
本文參與「OSC源創計劃」，歡迎正在閱讀的你也加入，一塊兒分享。