這篇文章主要介紹了RxJava2配置及使用的示例分析，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

尋烏ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書(shū)未來(lái)市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)公司的ssl證書(shū)銷(xiāo)售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：18982081108（備注：SSL證書(shū)合作）期待與您的合作！

RxJava2.0是一個(gè)非常棒的流式編程,采用的觀察者模式思想,事件的產(chǎn)生者產(chǎn)生事間之后發(fā)送給綁定的接受者,接受順序與發(fā)送順序一致.

依賴(lài):

compile 'io.reactivex.rxjava2:rxjava:2.0.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

簡(jiǎn)單使用:

//觀察者模式,這里產(chǎn)生事件,事件產(chǎn)生后發(fā)送給接受者,但是一定要記得將事件的產(chǎn)生者和接收者捆綁在一起,否則會(huì)出現(xiàn)錯(cuò)誤
Observable.create(new ObservableOnSubscribe() {
  @Override
  public void subscribe(ObservableEmitter e) throws Exception {
    //這里調(diào)用的方法會(huì)在產(chǎn)生事件之后會(huì)發(fā)送給接收者,接收者對(duì)應(yīng)方法會(huì)收到
    e.onNext("hahaha");
    e.onError(new Exception("wulala"));
    e.onComplete();
  }/*--
}).subscribe(new Observer() {
  //接受者,根據(jù)事件產(chǎn)生者產(chǎn)生的事件調(diào)用不同方法
  @Override
  public void onSubscribe(Disposable d) {
    Log.e(TAG, "onSubscribe: ");
  }

  @Override
  public void onNext(String value) {
    Log.e(TAG, "onNext: " + value);
  }

  @Override
  public void onError(Throwable e) {
    Log.e(TAG, "onError: ", e);
  }

  @Override
  public void onComplete() {
    Log.e(TAG, "onComplete: ");
  }
});

我們來(lái)用圖解一下這其中發(fā)生了什么事:

上游朝下游發(fā)送數(shù)據(jù),經(jīng)過(guò)subscribe使上下游產(chǎn)生關(guān)系,即達(dá)成訂閱.

解析1:

ObservableEmitter,這是個(gè)啥東西?Emitter:顧名思義,即Rxjava的發(fā)射器,通過(guò)這個(gè)發(fā)射器,即可發(fā)送事件-----通過(guò)調(diào)用onNext,onError,onComplete方法發(fā)送不同事件.

注意:

雖然RxJava可以進(jìn)行事件發(fā)送,但這并不意味著你可以隨便發(fā)送,這其中需要遵循一些規(guī)則.

onNext:你可以發(fā)送無(wú)數(shù)個(gè)onNext,發(fā)送的每個(gè)onNext接受者都會(huì)接收到.

onError:當(dāng)發(fā)送了onError事件之后,發(fā)送者onError之后的事件依舊會(huì)繼續(xù)發(fā)送,但是接收者當(dāng)接收到onError之后就會(huì)停止接收事件了.

onComplete:當(dāng)發(fā)送了onComplete事件之后,發(fā)送者的onComplete之后的事件依舊會(huì)繼續(xù)發(fā)送,但是接收者接收到onComplete之后就停止接收事件了.

onError事件和onComplete事件是互斥的,但是這并不代表你配置了多個(gè)onError和onComplete一定會(huì)崩潰,多個(gè)onComplete是可以正常運(yùn)行的,但是只會(huì)接收到第一個(gè),之后的就不會(huì)再接收到了,多個(gè)onError時(shí),只會(huì)接收到第一個(gè),第二個(gè)會(huì)直接造成程序崩潰.

解析2:

Disposable又是個(gè)啥東西,翻譯之后百度告訴我這東西叫做一次性的,是用來(lái)控制發(fā)送者和接受者之間的紐帶的,默認(rèn)為false,表示發(fā)送者和接受者直接的通信閥門(mén)關(guān)閉,可以正常通信,在調(diào)用dispose()方法之后,閥門(mén)開(kāi)啟,會(huì)阻斷發(fā)送者和接收者之間的通信,從而斷開(kāi)連接.

重載方法:

 subscribe();     //表示發(fā)送者隨意發(fā)送數(shù)據(jù),接受者什么都不管,什么都不接收.
     subscribe(Consumer onNext) {}   //只響應(yīng)onNext()事件,其他的事件忽略.
     subscribe(Consumer onNext, Consumer onError) {}     //含義同上
     subscribe(Consumer onNext, Consumer onError, Action onComplete) {}     //含義同上
     subscribe(Consumer onNext, Consumer onError, Action onComplete, Consumer onSubscribe) {}   //含義同上

解析3:

默認(rèn)情況下,發(fā)送者和接收者都運(yùn)行在主線程,但是這顯然是不符合實(shí)際需求的,我們?cè)谌粘Ｊ褂弥?通常用的最多的就是在子線程進(jìn)行各種耗時(shí)操作,然后發(fā)送到主線程進(jìn)行,難道我們就沒(méi)有辦法繼續(xù)用這個(gè)優(yōu)秀的庫(kù)了?想多了你,一個(gè)優(yōu)秀的庫(kù)如果連這都想不到,怎么能被稱(chēng)為優(yōu)秀呢,RxJava中有線程調(diào)度器,通過(guò)線程調(diào)度器,我們可以很簡(jiǎn)單的實(shí)現(xiàn)這種效果,下面放代碼.

Observable.create(new ObservableOnSubscribe() {
  @Override
  public void subscribe(ObservableEmitter e) throws Exception {
    e.onNext("hahaha");
    e.onNext("hahaha");
    e.onNext("hahaha");
    Log.e(TAG,"運(yùn)行在什么線程" + Thread.currentThread().getName());
    e.onComplete();
  }
}).subscribeOn(Schedulers.newThread())        //線程調(diào)度器,將發(fā)送者運(yùn)行在子線程
 .observeOn(AndroidSchedulers.mainThread())     //接受者運(yùn)行在主線程
 .subscribe(new Observer() {
  @Override
  public void onSubscribe(Disposable d) {
    Log.e(TAG, "onSubscribe: ");
    Log.e(TAG,"接收在什么線程" + Thread.currentThread().getName());
  }

  @Override
  public void onNext(String value) {
    Log.e(TAG, "onNext: " + value);
  }

  @Override
  public void onError(Throwable e) {
    Log.e(TAG, "onError: ", e);
  }

  @Override
  public void onComplete() {
    Log.e(TAG, "onComplete: ");
  }
});

最終結(jié)果:

可以看到我們只加了兩行代碼,就實(shí)現(xiàn)了效果,還有比這個(gè)更優(yōu)秀,更簡(jiǎn)單的么?

注意事項(xiàng):

subscribeOn(),只有在第一次調(diào)用的時(shí)候生效,之后不管調(diào)用多少次,只會(huì)以第一次為準(zhǔn).

observeOn(),可以被調(diào)用多次,每次調(diào)用都會(huì)更改線程.

RxJava線程池中的幾個(gè)線程選項(xiàng)

1.  - Schedulers.io()      io操作的線程, 通常io操作,如文件讀寫(xiě).

2.  - Schedulers.computation()      計(jì)算線程,適合高計(jì)算,數(shù)據(jù)量高的操作.

3.  - Schedulers.newThread()      創(chuàng)建一個(gè)新線程,適合子線程操作.

4. - AndroidSchedulers.mainThread()      Android的主線程,主線程

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“RxJava2配置及使用的示例分析”這篇文章對(duì)大家有幫助，同時(shí)也希望大家多多支持創(chuàng)新互聯(lián)，關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，更多相關(guān)知識(shí)等著你來(lái)學(xué)習(xí)!

分享標(biāo)題：RxJava2配置及使用的示例分析-創(chuàng)新互聯(lián)
文章轉(zhuǎn)載：http://weahome.cn/article/ccppeo.html