2. 程式人生 > >RxJava之錯誤處理

RxJava之錯誤處理

阿新 • • 發佈：2019-01-09

在Observable發射資料時，有時傳送onError通知，導致觀察者不能正常接收資料。可是，有時我們希望對Observable發射的onError通知做出響應或者從錯誤中恢復。此時我們該如何處理呢？下面我們瞭解下RxJava錯誤處理相關的操作符。

catch

流程圖

這裡寫圖片描述

概述

catch操作符攔截原Observable的onError通知，將它替換為其它的資料項或資料序列，讓產生的Observable能夠正常終止或者根本不終止。

在RxJava中，catch實現為三個不同的操作符：

  • onErrorReturn:讓Observable遇到錯誤時發射一個特殊的項並且正常終止。
  • onErrorResumeNext:讓Observable在遇到錯誤時開始發射第二個Observable的資料序列。
  • onExceptionResumeNext:讓Observable在遇到錯誤時繼續發射後面的資料項。

onErrorReturn

流程圖

這裡寫圖片描述

概述

onErrorReturn方法建立並返回一個擁有類似原Observable的新Observable，後者會忽略前者的onError呼叫，不會將錯誤傳遞給觀察者，作為替代，它會通過引數函式，建立一個特殊項併發發射，最後呼叫觀察者的onCompleted方法。

API

Javadoc: onErrorReturn(Func1))

示例程式碼

Observable.create(new Observable.OnSubscribe<Student>() {
    @Override
    public void call(Subscriber<? super Student> subscriber) {
        subscriber.onNext(getListOfStudent().get(0));
        subscriber.onNext(getListOfStudent().get(1));
        subscriber.onNext(getListOfStudent().get(2));
        subscriber.onError(new Throwable("do onError"));
        subscriber.onNext(getListOfStudent().get(3));
        subscriber.onNext(getListOfStudent().get(4));
        subscriber.onNext(getListOfStudent().get(5));
    }
}).subscribeOn(Schedulers.io())
        .onErrorReturn(new Func1<Throwable, Student>() {
            @Override
            public Student call(Throwable throwable) {
                return new Student(1001, "error - 1 ", 10);
            }
        }).observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Student>() {

            @Override
            public void onStart() {
                super.onStart();
                mAdaStudent.clear();
            }

            @Override
            public void onCompleted() {
                Log.i(TAG, "do onCompleted");
            }

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

            @Override
            public void onNext(Student student) {
                Log.i(TAG, "do onNext");
                mAdaStudent.addData(student);
            }
        });

Log列印

OperateActivity: do onNext
Student{id='1'name='A', age=23}
OperateActivity: do onNext
Student{id='2'name='B', age=33}
OperateActivity: do onNext
Student{id='3'name='C', age=24}
OperateActivity: do onNext
Student{id='1001'name='error - 1 ', age=10}
OperateActivity: do onCompleted

示例解析

在手動建立Observale時，當Observable傳送了第三個資料後，Observable傳送了onError通知，然後又傳送了2個數據。而在onErrorReturn方法處理中，其引數函式中，建立並返回了一個特殊項( new Student(1001, “error - 1 “, 10)).

從Log列印可以看出，觀察者並沒有執行onError方法，意味著Observale並沒有接收到onError通知，而是接收到了一個特殊項後，呼叫了onCompleted方法，結束了此次訂閱。而這個特殊項，正是在onErrorReturn中引數函式中，建立的特殊項。

onErrorResumeNext

流程圖

這裡寫圖片描述

概述

onErrorResumeNext方法建立並返回一個擁有類似原Observable的新Observable，後者會忽略前者的onError呼叫，不會將onError通知傳遞給觀察者，但作為替代，=新的Observable開始發射資料。

onErrorResumeNext方法與onErrorReturn()方法類似，都是攔截原Observable的onError通知，不同的是攔截後的處理方式，onErrorReturn建立並返回一個特殊項，而onErrorResumeNext建立並返回一個新的Observabl，觀察者會訂閱它，並接收其發射的資料。

API

Javadoc: onErrorResumeNext(Func1))
Javadoc: onErrorResumeNext(Observable))

示例程式碼

Observable.create(new Observable.OnSubscribe<Student>() {
    @Override
    public void call(Subscriber<? super Student> subscriber) {
        subscriber.onNext(getListOfStudent().get(0));
        subscriber.onNext(getListOfStudent().get(1));
        subscriber.onNext(getListOfStudent().get(2));
        subscriber.onError(new Throwable("do onError"));
        subscriber.onNext(getListOfStudent().get(3));
        subscriber.onNext(getListOfStudent().get(4));
        subscriber.onNext(getListOfStudent().get(5));
    }
}).subscribeOn(Schedulers.io())
        .onErrorResumeNext(new Func1<Throwable, Observable<Student>>() {
            @Override
            public Observable<Student> call(Throwable throwable) {
                return Observable.just(new Student(1001, "error - 1 ", 10), new Student(1002, "error - 2 ", 10));
            }
        }).observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Student>() {

            @Override
            public void onStart() {
                super.onStart();
                mAdaStudent.clear();
            }

            @Override
            public void onCompleted() {
                Log.i(TAG, "do onCompleted");
            }

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

            @Override
            public void onNext(Student student) {
                Log.i(TAG, "do onNext");
                Log.i(TAG, student.toString());
                mAdaStudent.addData(student);
            }
            });

Log列印

OperateActivity: do onNext
Student{id='1'name='A', age=23}
OperateActivity: do onNext
Student{id='2'name='B', age=33}
OperateActivity: do onNext
Student{id='3'name='C', age=24}
OperateActivity: do onNext
Student{id='1001'name='error - 1 ', age=10}
OperateActivity: do onNext
Student{id='1002'name='error - 2 ', age=10}
OperateActivity: do onCompleted

示例解析

在手動建立Observale時，當Observable傳送了第三個資料後，Observable傳送了onError通知，然後又傳送了2個數據。在onErrorResumeNext方法中的引數函式中，建立了一個新的Observable。

從Log列印可以看出，觀察者並沒有執行onError方法，意味著Observale並沒有接收到onError通知，而是接收到了新建的建立了一個新的Observable發射的出具。在新Observable發射完資料後，呼叫了onCompleted方法，結束了此次訂閱。

onExceptionResumeNext

流程圖

這裡寫圖片描述

概述

onExceptionResumeNext方法與onErrorResumeNext方法類似建立並返回一個擁有類似原Observable的新Observable，，也使用這個備用的Observable。不同的是，如果onError收到的Throwable不是一個Exception，它會將錯誤傳遞給觀察者的onError方法，不會使用備用的Observable。

API

Javadoc: onExceptionResumeNext(Observable))

示例程式碼

Observable.create(new Observable.OnSubscribe<Student>() {
    @Override
    public void call(Subscriber<? super Student> subscriber) {
        subscriber.onNext(getListOfStudent().get(0));
        subscriber.onNext(getListOfStudent().get(1));
        subscriber.onNext(getListOfStudent().get(2));
        subscriber.onError(new Throwable("do onError"));
        subscriber.onNext(getListOfStudent().get(3));
        subscriber.onNext(getListOfStudent().get(4));
        subscriber.onNext(getListOfStudent().get(5));
    }
}).subscribeOn(Schedulers.io())
        .onExceptionResumeNext(Observable.just(new Student(1001, "error - 1 ", 10),
                new Student(1002, "error - 2 ", 10)))
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Student>() {

            @Override
            public void onStart() {
                super.onStart();
                mAdaStudent.clear();
            }

            @Override
            public void onCompleted() {
                Log.i(TAG, "do onCompleted");
            }

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

            @Override
            public void onNext(Student student) {
                Log.i(TAG, "do onNext");
                Log.i(TAG, student.toString());
                mAdaStudent.addData(student);
            }
        });

 Observable.create(new Observable.OnSubscribe<Student>() {
        @Override
        public void call(Subscriber<? super Student> subscriber) {
            subscriber.onNext(getListOfStudent().get(0));
            subscriber.onNext(getListOfStudent().get(1));
            subscriber.onNext(getListOfStudent().get(2));
            subscriber.onError(new Exception("do onError"));
            subscriber.onNext(getListOfStudent().get(3));
            subscriber.onNext(getListOfStudent().get(4));
            subscriber.onNext(getListOfStudent().get(5));
        }
    }) ***

Log列印

1.
do onError  
2.
OperateActivity: do onNext
Student{id='1'name='A', age=23}
OperateActivity: do onNext
Student{id='2'name='B', age=33}
OperateActivity: do onNext
Student{id='3'name='C', age=24}
OperateActivity: do onNext
Student{id='1001'name='error - 1 ', age=10}
OperateActivity: do onNext
Student{id='1002'name='error - 2 ', age=10}
OperateActivity: do onCompleted

示例解析

在建立Observale傳送OnError通知時，error採用了兩種方式，一個是Throwable,另外一個是Exception。從列印的Log中可以看出，在採用第一種方式時，原Observable直接傳送了onError通知，並結束髮射。但是採用發射Exception作為onError通知時，原Observale的onError通知被攔截，並使用了onExceptionResumeNext()建立的備用Observale。正如概述中敘述的，onExceptionResumeNext方法至攔截原Observale中Exception作為onError的通知，並將在引數函式中建立的備用Observable中的資料發射出去。

retry

流程圖

這裡寫圖片描述

概述

retry()操作符將攔截原Observable傳遞onError給觀察者，而是重新訂閱此Observable。由於是重新訂閱會造成資料重複。

在RxJava中，retry()操作符有幾個變體

retry()變體在出現onError通知時，將無限的重新訂閱原Observable.

retry(long)變體通過引數指定最多重新訂閱的次數，如果次數超了，它不會嘗試再次訂閱，它會把最新的一個onError通知傳遞給它的觀察者。

retry(Func2)變體通過引數接受兩個引數的函式，引數為重試次數和導致發射onError通知的Throwable，而函式返回一個布林值，如果返回true，retry應該再次訂閱原Observable，如果返回false，retry會將最新的一個onError通知傳遞給它的觀察者。

API

Javadoc: retry()
Javadoc: retry(long)
Javadoc: retry(Func2)

示例程式碼

Observable.create(new Observable.OnSubscribe<Student>() {
    @Override
    public void call(Subscriber<? super Student> subscriber) {
        subscriber.onNext(getListOfStudent().get(0));
        subscriber.onNext(getListOfStudent().get(1));
        subscriber.onNext(getListOfStudent().get(2));
        if (isError) {
            subscriber.onError(new Throwable("do onError"));
            isError = false;
        }

        subscriber.onNext(getListOfStudent().get(3));
        subscriber.onNext(getListOfStudent().get(4));
        subscriber.onNext(getListOfStudent().get(5));
    }
}).retry(3)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Student>() {

            @Override
            public void onStart() {
                super.onStart();
                mAdaStudent.clear();
            }

            @Override
            public void onCompleted() {
                Log.i(TAG, "do onCompleted");
            }

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

            @Override
            public void onNext(Student student) {
                Log.i(TAG, "do onNext");
                Log.i(TAG, student.toString());
                mAdaStudent.addData(student);
            }
        });

Log列印

OperateActivity: do onNext
Student{id='1'name='A', age=23}
OperateActivity: do onNext
Student{id='2'name='B', age=33}
OperateActivity: do onNext
Student{id='3'name='C', age=24}
OperateActivity: do onNext
Student{id='1'name='A', age=23}
OperateActivity: do onNext
Student{id='2'name='B', age=33}
OperateActivity: do onNext
Student{id='3'name='C', age=24}
OperateActivity: do onNext
Student{id='4'name='D', age=24}
OperateActivity: do onNext
Student{id='5'name='E', age=33}
OperateActivity: do onNext
Student{id='6'name='F', age=23}

示例解析

從示例程式碼中可以看出，第一次訂閱時，發射完第三個通知後，傳送onError通知。但，通過Log列印可以清晰的看出，onError通知並沒有發射出去，而是重新訂閱，將之前發射的資料，重新發了一遍。正如之前說的，retry()操作符會攔截onError通知並重新訂閱，但是會造成資料的重複。

retryWhen

流程圖

這裡寫圖片描述

概述

retryWhen()預設在trampoline排程器上執行，可以通過引數指定其它的排程器。

API

Javadoc: retryWhen(Func1)
Javadoc: retryWhen(Func1,Scheduler)

示例程式碼

1.
Observable.create(new Observable.OnSubscribe<Student>() {
    @Override
    public void call(Subscriber<? super Student> subscriber) {
        subscriber.onNext(getListOfStudent().get(0));
        subscriber.onNext(getListOfStudent().get(1));
        subscriber.onNext(getListOfStudent().get(2));
        if (isError) {
            subscriber.onError(new Throwable("do onError"));
            isError = false;
        }

        subscriber.onNext(getListOfStudent().get(3));
        subscriber.onNext(getListOfStudent().get(4));
        subscriber.onNext(getListOfStudent().get(5));
    }
}).subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<Student>() {

            @Override
            public void onStart() {
                super.onStart();
                mAdaStudent.clear();
            }

            @Override
            public void onCompleted() {
                Log.i(TAG, "do onCompleted");
            }

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

            @Override
            public void onNext(Student student) {
                Log.i(TAG, "do onNext");
                Log.i(TAG, student.toString());
                mAdaStudent.addData(student);
            }
        });
2.
***
.retryWhen(new Func1<Observable<? extends Throwable>, Observable<?>>() {
    @Override
    public Observable<Throwable> call(Observable<? extends Throwable> observable) {
        return Observable.error(new Throwable(" do retryWhen"));
    }
})
****

Log列印

1.
OperateActivity: do onNext
Student{id=’1’name=’A’, age=23}
OperateActivity: do onNext
Student{id=’2’name=’B’, age=33}
OperateActivity: do onNext
Student{id=’3’name=’C’, age=24}
OperateActivity: do onNext
Student{id=’1’name=’A’, age=23}
OperateActivity: do onNext
Student{id=’2’name=’B’, age=33}
OperateActivity: do onNext
Student{id=’3’name=’C’, age=24}
OperateActivity: do onNext
Student{id=’4’name=’D’, age=24}
OperateActivity: do onNext
Student{id=’5’name=’E’, age=33}
OperateActivity: do onNext
Student{id=’6’name=’F’, age=23}
2.
do onError

示例解析

示例1中，在retryWhend(Func1)的引數函式中，建立並返回了一個可發射資料的Observable物件，而在示例2中，其引數函式，建立並返回了一個發射onError通知的Observable。通過Log列印可以出，示例1在攔截了原Observable中的onError通知，並重新訂閱了原Observable，但是示例2中，觀察者接收了onError通知，意味著原Observable中的onError通知未被攔截，直接發射出去。示例2中，正體現了retryWhen()和retry()的不同之處。

相關推薦

RxJava之錯誤處理

在Observable發射資料時，有時傳送onError通知，導致觀察者不能正常接收資料。可是，有時我們希望對Observable發射的onError通知做出響應或者從錯誤中恢復。此時我們該如何處理呢？下面我們瞭解下RxJava錯誤處理相關的操作符。 catc

PHP之錯誤處理

php錯誤報告　　PHP程序的錯誤發生一般歸屬於下列三個領域：　　1、語法錯誤　　語法錯誤最常見，並且也容易修復。如：代碼中遺漏一個分號。這類錯誤會阻止腳本的執行　　2、運行時錯誤　　這種錯誤一般不會阻止PHP腳本的執行，但會阻止當前要做的事情。輸出一條錯誤，但php腳本繼續執行　　3、邏輯錯誤　　這種錯誤最

Lighttpd1.4.20源代碼分析 筆記 狀態機之錯誤處理和連接關閉

全部 階段 內存 and ces ons keep ren log 這裏所說的錯誤有兩種： 1.http協議規定的錯誤，如404錯誤。 2.server執行過程中的錯誤。如write錯誤。 對於http協議規定的錯誤，這裏的“錯誤”是針對clien

golang教程之錯誤處理

文章目錄 錯誤處理 什麼是錯誤？ 例子 錯誤型別表示 從錯誤中提取更多資訊的不同方法 1.斷言底層結構型別並從結構域中獲取更多資訊 2.斷言底層結構型別並使用方法獲取更多資訊 3.直接比

小白學python之錯誤處理_學習筆記

本文以廖雪峰的官方網站為參考來學習python的。其學習連結為廖雪峰小白學python教程。 本文是學習到python的定製類。參考連結廖雪峰python錯誤處理。 本學習筆記僅供參考。 筆記： 在作業系統提供的呼叫中，返回錯誤碼非常常見。 比如，開啟檔案的函式op

SpringBoot——web開發之錯誤處理機制

一、SpringBoot提供的預設錯誤處理 1、在瀏覽器端訪問時，出現錯誤時響應一個錯誤頁面： 2、在其他客戶端訪問時，響應json資料： 3、錯誤處理機制的原理，參照錯誤自動配置類——ErrorMvcAutoConfiguration，在錯誤自動配置類中，配置

《程式碼大全》之錯誤處理技術（Error-Handling Techniques）

1、返回中立值        處理錯誤資料的最佳做法就是繼續執行操作並簡單地返回一個沒有危害的數值。 2、換用一下正確的資料        在處理資料流的時候，有時只需返回下一個正確的資料即可。 3、返回

JavaScript之錯誤處理

除錯JavaScript確實是一件痛苦的事，但現在有很多工具方便除錯工作（比如：Firefox的Firebug），更方便準確的檢視錯誤資訊。然而，最新的ECMAScript添加了導演處理機制，採用了從Java中移植過來的模型。ECMAScritp中一些保留字實現了try……

Linux系統程式設計之錯誤處理：perror,strerror和errno

轉自：http://www.linuxidc.com/Linux/2013-07/87238.htm 1，在系統程式設計中錯誤通常通過函式返回值來表示，並通過特殊變數errno來描述。 errno這個全域性變數在<errno.h>標頭檔案中宣告如下：ext

JavaScript之錯誤處理，函式物件

1.*錯誤處理：         錯誤：程式執行過程中，發生的導致程式無法繼續執行的狀態         錯誤處理：即使程式出錯，也要保證程式不退出的機制         Error物件：在發生錯誤時，*自動建立的封裝錯誤資訊的物件                   屬性

SpringBoot之錯誤處理機制以及定製錯誤資訊

一、SpringBoot預設的錯誤處理機制 預設效果： 1）、瀏覽器，返回一個預設的錯誤頁面 瀏覽器傳送請求的請求頭： 2）、如果是其他客戶端，預設響應一個json資料 原理： 可以參照ErrorMvcAutoConfigurat

Kettle使用_1轉換之錯誤處理

需求：通過kettle配置資料轉換失敗的日誌記錄.解決方法:通過表輸入、表輸出、文字檔案輸出等元件完成該功能.1)  配置資料庫連線，這裡輸入連線名、主機名稱、資料庫名稱、資料庫使用者名稱、密碼等資料庫的基本資訊2)  新建立個轉換，或者通過快捷鍵Ctrl+N建立 3） 在核

c之錯誤處理

C 錯誤處理C 語言不提供對錯誤處理的直接支援，但是作為一種系統程式語言，它以返回值的形式允許您訪問底層資料。在發生錯誤時，大多數的 C 或 UNIX 函式呼叫返回 1 或 NULL，同時會設定一個錯誤程式碼 errno，該錯誤程式碼是全域性變數，表示在函式呼叫期間發生了錯誤

PHP之 錯誤 與 異常處理

函數 用戶 exceptio 產生 存放位置 如果 date error_log reporting PHP的錯誤報告有三種： 1.錯誤，語法解析錯誤，致命錯誤2.警告3.註意 錯誤 -> 致命錯誤，會終止已下程序的執行，語法錯誤的話，PHP壓根就沒執行警告 ->

Python學習筆記之面對象與錯誤處理

實現 單繼承 父類 成對 數據類型 itl 同時 屬性 子類 反射 __import__()函數用於加載類和函數 __import__(name[, globals[, locals[, fromlist[, level]]]]) 參數說明： n

Windows核心編程之核心總結（第一章 錯誤處理）（2018.5.26）

Windows核心編程之核心總結前沿 學習Windows核心編程是步入Windows編程殿堂的必經之路，2018年寒假重溫了計算機操作系統知識，前陣子又過學習Windows程序設計方面的基礎，正所謂打鐵要乘熱，所以我又入了Windows核心編程的坑啦，哈哈~ 學習目標 每一章的學習都要明確一個目標，就是你學完

Python3基礎之（二十 八）try 錯誤處理

一、錯誤處理 輸出錯誤：try:, except … as …: 看如下程式碼 try: file=open('eee.txt','r')#會報錯的程式碼 except Exception as e: print(e) 輸出： [Errno 2] No

【SpringBoot學習之路】15.錯誤處理機制

轉載宣告：商業轉載請聯絡作者獲得授權,非商業轉載請註明出處.原文來自 © 呆萌鍾【SpringBoot學習之路】15.錯誤處理機制  SpringBoot預設的錯誤處理機制 預設效果 瀏覽器，返回一個預設的錯誤頁面 瀏覽器傳

Linux上mysql錯誤處理之ERROR 1786 (HY000)

1.錯誤描述 在資料庫中執行語句：CREATE TABLE mis_auto_sagaw_sub_qiyexiaoshougepinzhobak131 SELECT * FROM mis_auto_sagaw_sub_qiyexiaoshougepinzho WHERE m

Glide 入門到精通之十一 ——異常：除錯和錯誤處理

Glide 的 GeneralRequest 類提供了一個方法去設定 log 的級別。不幸的是，在生產過程中，使用這個類並不容易。然而，有一個非常簡單的方法去獲得 Glide 的除錯日誌。你所要做的就是通過 adb 的 shell 來啟用。開啟你的終端，使用