1.RX依賴?
? ? ? compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
? ? ? compile 'io.reactivex.rxjava2:rxjava:2.1.0'
? ? ? Github上的源碼:
? ? ? ?rxjava地址:https://github.com/ReactiveX/RxJava
? ? ? rxandroid github 地址:https://github.com/ReactiveX/RxAndroid
2.RX基本概念
2.1.觀察者:Observer，
? ? ? ?監(jiān)視著被觀察者的行為误窖，當(dāng)被觀察者某個(gè)狀態(tài)改變的時(shí)候會(huì)通知觀察者忿磅，觀察者會(huì)執(zhí)行對(duì)應(yīng)的操作饼疙；
2.2.被觀察者:Observable
? ? ? ? 被監(jiān)視的對(duì)象宴杀，當(dāng)某個(gè)狀態(tài)改變的時(shí)候會(huì)通知觀察者启上；
2.3.訂閱.subscribe()
? ? ? ? 將觀察者和被觀察者建立聯(lián)系薛训。
2.4.舉例
? ? ? ? ?其實(shí)在android中也有類似的例子: ?textview.setOnClick(new OnClickListener()) ,在上述的例子中textview就是被觀察者盆佣，OnClickListener就是觀察者座慰，setOnClick()就是把兩者關(guān)聯(lián)起來的橋梁陨舱，同理subscribe()就是如同setOnClick()的角色
2.5.代碼介紹
? ? ? ?觀察者中的
? ? ? onError():事件隊(duì)列異常。在事件處理過程中出異常時(shí)版仔，onError()會(huì)被觸發(fā)游盲，同時(shí)隊(duì)列自動(dòng)終止，不允許再有事件發(fā)出邦尊。
? ? ? onNext():表示處理觀察到的事件
? ? ? onCompleted():事件隊(duì)列完結(jié)
? ? ? onSubscribe(Disposable d ):表示當(dāng)觀察者被訂閱時(shí)的回調(diào)一般進(jìn)行一些預(yù)處理背桐，最開始被調(diào)用的地方,如果要截?cái)喟l(fā)送事件只用調(diào)用d.dispose()，觀察者就不會(huì)接收到事件了蝉揍！
3.RX簡(jiǎn)寫
? ? 有時(shí)候我們只關(guān)注觀察者中OnNext()方法链峭，并不關(guān)心其他方法。Subscribe()重載了多個(gè)方法又沾，可以讓我們只關(guān)注其中的onNext方法弊仪。被觀察者要調(diào)用觀察者的onNext()方法:如下面的代碼
? ? ? 用ObservableEmitter對(duì)象來調(diào)用onNext方法，但是我們可以簡(jiǎn)寫成:
? ? ? 同時(shí)我們可以將被觀察者封裝成List數(shù)組杖刷，用fromIterable(list)來發(fā)送事件
4.RX常用數(shù)據(jù)操作符
4.1.Filter
? ? ? ? ?顧名思義就是對(duì)發(fā)送過來的數(shù)據(jù)源進(jìn)行過濾励饵，篩選出符合條件的。
4.2.Map?
從上面的例子我們可以看出這個(gè)map()操作符是可以對(duì)數(shù)據(jù)進(jìn)行轉(zhuǎn)化
4.3.flatMap
將被觀察者的事件重新解析轉(zhuǎn)化成新的被觀察者對(duì)象數(shù)組滑燃，但是并不保證發(fā)送的順序
如果想要保證發(fā)送的順序役听，需要用concatMap()操作符來保證！
應(yīng)用場(chǎng)景:找到這個(gè)部門下所有警員的名字
5.RX線程切換
subscribeOn()發(fā)送事件產(chǎn)生的線程
observeOn()指定事件消耗的線程
Schedulers.newThread():產(chǎn)生一個(gè)新的線程表窘，效率低于Schedulers.io
Schedulers.io():代表io操作的線程,通常用于網(wǎng)絡(luò),讀寫文件等io密集型的操作
AndroidSchedulers.mainThread():主線程典予，即UI線程
Schedulers.computation():代表CPU計(jì)算密集型的操作,例如需要大量計(jì)算的操作
同時(shí)observeOn(),subscribeOn()可以多次調(diào)用，意味著可以多次切換線程
6.解決RxJava引起的內(nèi)存泄露
如果工作線程沒有執(zhí)行結(jié)束就退出fragment或者activity乐严，就無法釋放線程中持有的資源瘤袖，比如context等，引起內(nèi)存泄露昂验。所以需要用Rxlifecycle框架來解決這個(gè)問題捂敌。需要依賴的編譯:
compile 'com.trello:rxlifecycle:1.0'
compile 'com.trello:rxlifecycle-components:1.0'
Github 例子:https://github.com/trello/RxLifecycle
以上的例子是用rxlifecycle-compose
7.與Retrofit共同使用
現(xiàn)在主流的網(wǎng)絡(luò)框架是Retrofit，而且Retrofit提供了RxJava完美入口既琴。Rxjava2.x需要額外依賴
compile 'com.jakewharton.retrofit:retrofit2-rxjava2-adapter:1.0.0'
平時(shí)如果activity退出的時(shí)候我們要在onDestroy()方法中寫入call.cancel();防止子線程回到主線程更新UI占婉，這時(shí)候會(huì)引起app崩潰
但是Retrofit和RxJava結(jié)合的時(shí)候，我們要保存Disposable對(duì)象呛梆，在onDestroy時(shí)候調(diào)用dispose()方法锐涯，如果有多個(gè)Disposble(多次的網(wǎng)絡(luò)請(qǐng)求)，用容器CompositeDisposable.add();
取消的時(shí)候CompositeDisposable.clear();
歡迎大家繼續(xù)封裝
8.背壓介紹
在rxjava中會(huì)經(jīng)常遇到一種情況就是被觀察者發(fā)送消息太快以至于它的操作符或者訂閱者不能及時(shí)處理相關(guān)的消息填物。那么隨之而來的就是如何處理這些未處理的消息
最后纹腌，為了大家更好的理解backpressure概念霎终，這里補(bǔ)充說一下Flowable。
Observable在RxJava2.0中新的實(shí)現(xiàn)叫做Flowable升薯， 同時(shí)舊的Observable也保留了莱褒。因?yàn)樵?RxJava1.x 中，有很多事件不被能正確的背壓涎劈，從而拋出MissingBackpressureException广凸。
舉個(gè)簡(jiǎn)單的例子，在RxJava1.x 中的 observeOn蛛枚， 因?yàn)槭乔袚Q了消費(fèi)者的線程谅海，因此內(nèi)部實(shí)現(xiàn)用隊(duì)列存儲(chǔ)事件。在Android中默認(rèn)的 buffersize 大小是16蹦浦，因此當(dāng)消費(fèi)比生產(chǎn)慢時(shí)扭吁， 隊(duì)列中的數(shù)目積累到超過16個(gè)，就會(huì)拋出MissingBackpressureException盲镶， 初學(xué)者很難明白為什么會(huì)這樣侥袜，使得學(xué)習(xí)曲線異常得陡峭。
而在2.0 中溉贿，Observable 不再支持背壓枫吧，而Flowable 支持非阻塞式的背壓。Flowable是RxJava2.0中專門用于應(yīng)對(duì)背壓（Backpressure）問題宇色。所謂背壓九杂，即生產(chǎn)者的速度大于消費(fèi)者的速度帶來的問題，比如在Android中常見的點(diǎn)擊事件宣蠕，點(diǎn)擊過快則經(jīng)常會(huì)造成點(diǎn)擊兩次的效果尼酿。其中，F(xiàn)lowable默認(rèn)隊(duì)列大小為128植影。并且規(guī)范要求，所有的操作符強(qiáng)制支持背壓涎永。幸運(yùn)的是思币， Flowable 中的操作符大多與舊有的 Observable 類似。
背壓產(chǎn)生原因羡微，請(qǐng)參考某位大神的博客:http://blog.csdn.net/jdsjlzx/article/details/52717636
谷饿。
