理解RxJava:(三)RxJava的優勢

理解RxJava:(三)RxJava的優勢

在第一部分，講解了RxJava的基本結構。在第二部分，展現了operators的強大之處。可是大家可能仍然沒有被說服，也沒有足夠的理由信服。下面是一些能讓你信服的RxJava框架的優勢。

 錯誤處理

截至當前，咱們一直都忽略onComplete()和onError()方法。它們標誌着Observable中止發出items以及緣由（不論是成功地完成或是不可恢復的錯誤）。

咱們最初的Subscriber有能力監聽onComplete()和onError()事件。動手實現以下所示：

Observable.just("Hello, world!")
    .map(s -> potentialException(s))
    .map(s -> anotherPotentialException(s))
    .subscribe(new Subscriber<String>() {
        @Override
        public void onNext(String s) { System.out.println(s); }

        @Override
        public void onCompleted() { System.out.println("Completed!"); }

        @Override
        public void onError(Throwable e) { System.out.println("Ouch!"); }
    });

假設potentialException()和anotherPotentialException()都能拋出異常。每一個Observable都以調用onCompleted()``onError()方法結束。正由於這樣， 程序的輸出要麼是Completed!，要麼是Ouch!(由於異常的拋出)

關於這個的補充：

• 1.onError()方法在有異常在任意時候被拋出的時候被調用。

  這使得錯誤處理變得更簡單。只須要在最後的時候在一個簡單的方法中處理全部的錯誤便可。

• 2.operators不須要處理異常。

  在Observable鏈上拋出的任何異常均可以留給 Subscriber決定如何處理。由於onError()方法以前的異常都會被跳過。

• 3.咱們能知道Subscriber完成接收items的時候。

  知道任務何時結束有助於代碼的流動。

在錯誤處理上， 這個模式要比傳統的錯誤處理簡單得多。使用回調，必須在每一個回調中處理錯誤。不只僅是形成重複代碼，也意味着每一個回調都須要知道如何處理錯誤，意味着你的回調代碼和調用者高度耦合。

經過RxJava，Observable不須要知道如何處理錯誤。operators不只僅不須要處理錯誤狀態，在關鍵錯誤發生時，它們會自動跳過。咱們能夠把全部的錯誤處理交給Subscriber。

調度者（Schedulers）

你有一個須要作網絡請求的Android應用。由於可能須要耗費很長時間，因而你在其它線程作網絡請求。通常都會遇到這樣的問題。

Android應用的多線程操做很難是由於你必須在正確的線程運行對的代碼。不然應用會閃退。經典的錯誤就是當你在非主線程修改View的狀態。

在RxJava中，咱們能經過subscribeOn()方法指定Observer代碼運行的線程，以及observeOn()方法指定Subscriber運行的線程。

myObservableServices.retrieveImage(url)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(bitmap -> myImageView.setImageBitmap(bitmap));

多麼簡單？個人Subscriber以前的都運行在I/O線程。最後，View的操做發生在主線程。

最厲害的部分是我能綁定subcribeOn()和observeOn()方法到任意的Observable上。
它們僅僅是operators。我不須要擔憂Observable和以前的operators在作什麼。在最後僅僅操做這個就輕易的實現線程的切換。

訂閱（Subscriptions）

還有些東西沒有講解。當你調用Observable.subscribe()，返回的是Subscription。這表明着你的Observable和Subscriber之間的聯繫：

Subscription subscription = Observable.just("Hello, World!")
    .subscribe(s -> System.out.println(s));

可使用Subscription來斷絕這個聯繫：

subscription.unsubscribe();
System.out.println("Unsubscribed=" + subscription.isUnsubscribed());
// 輸出 "Unsubscribed=true"

RxJava取消訂閱的優勢是它能中止方法鏈。若是你有一個複雜的operators鏈，調用unsubscribe方法將終止當前正在運行的代碼。無需額外的操做。

結論

記住這幾篇都是RxJava的入門文章。大家要學的比我如今所講的要多得多。例如，研讀backpressure。我不會在全部地方都用響應式編程。而只會在我想要把複雜邏輯變得更簡單的地方使用。

最初，我計劃這篇文章是這系列的最後一篇。可是一個常見的需求是RxJava在Android中的實際運用。所以，你能繼續閱讀第四部分。我但願這個入門系列能引導大家開始學習使用這個有趣的框架。若是你想要進一步學習，我建議閱讀RxJava的官方wiki。

本文翻譯自Grokking RxJava, Part 3: Reactive with Benefits,著做權歸原做者danlew全部。譯文由JohnTsai翻譯。轉載請註明出處，並保留此段聲明。