Error Handling 错误处理

末蓝、 2022-07-29 10:37 256阅读 0赞

很多操作符可用于对Observable发射的`onError`通知做出响应或者从错误中恢复，例如，你可以：

1.  吞掉这个错误，切换到一个备用的Observable继续发射数据
2.  吞掉这个错误然后发射默认值
3.  吞掉这个错误并立即尝试重启这个Observable
4.  吞掉这个错误，在一些回退间隔后重启这个Observable

这是操作符列表：

*  [**`onErrorResumeNext( )`**][onErrorResumeNext] — 指示Observable在遇到错误时发射一个数据序列
 *  [**`onErrorReturn( )`**][onErrorReturn] — 指示Observable在遇到错误时发射一个特定的数据
 *  [**`onExceptionResumeNext( )`**][onExceptionResumeNext] — instructs an Observable to continue emitting items after it encounters an exception (but not another variety of throwable)指示Observable遇到错误时继续发射数据
 *  [**`retry( )`**][retry] — 指示Observable遇到错误时重试
 *  [**`retryWhen( )`**][retryWhen] — 指示Observable遇到错误时，将错误传递给另一个Observable来决定是否要重新给订阅这个Observable

=========================================================、

# Catch #

从`onError`通知中恢复发射数据

![catch][]

`Catch`操作符拦截原始Observable的`onError`通知，将它替换为其它的数据项或数据序列，让产生的Observable能够正常终止或者根本不终止。

在某些ReactiveX的实现中，有一个叫`onErrorResumeNext`的操作符，它的行为与`Catch`相似。

RxJava将`Catch`实现为三个不同的操作符：

**`onErrorReturn`**

让Observable遇到错误时发射一个特殊的项并且正常终止。

**`onErrorResumeNext`**

让Observable在遇到错误时开始发射第二个Observable的数据序列。

**`onExceptionResumeNext`**

让Observable在遇到错误时继续发射后面的数据项。

### onErrorReturn ###

![onErrorReturn][onErrorReturn 1]

`onErrorReturn`方法返回一个镜像原有Observable行为的新Observable，后者会忽略前者的`onError`调用，不会将错误传递给观察者，作为替代，它会发发射一个特殊的项并调用观察者的`onComleted`方法。

*  Javadoc: [onErrorReturn(Func1)][onErrorReturn_Func1]

### onErrorResumeNext ###

![onErrorResumeNext][onErrorResumeNext 1]

`onErrorResumeNext`方法返回一个镜像原有Observable行为的新Observable，后者会忽略前者的`onError`调用，不会将错误传递给观察者，作为替代，它会开始镜像另一个，备用的Observable。

*  Javadoc: [onErrorResumeNext(Func1)][onErrorResumeNext_Func1]
 *  Javadoc: [onErrorResumeNext(Observable)][onErrorResumeNext_Observable]

### onExceptionResumeNext ###

![onExceptionResumeNext][onExceptionResumeNext 1]

和`onErrorResumeNext`类似，`onExceptionResumeNext`方法返回一个镜像原有Observable行为的新Observable，也使用一个备用的Observable，不同的是，如果`onError`收到的`Throwable`不是一个`Exception`，它会将错误传递给观察者的`onError`方法，不会使用备用的Observable。

*  Javadoc: [onExceptionResumeNext(Observable)][onExceptionResumeNext_Observable]

[onErrorResumeNext]: https://github.com/mcxiaoke/RxDocs/blob/master/operators/Catch.md#onErrorResumeNext
[onErrorReturn]: https://github.com/mcxiaoke/RxDocs/blob/master/operators/Catch.md#onErrorReturn
[onExceptionResumeNext]: https://github.com/mcxiaoke/RxDocs/blob/master/operators/Catch.md#onExceptionResumeNext
[retry]: https://github.com/mcxiaoke/RxDocs/blob/master/operators/Retry.md#retry
[retryWhen]: https://github.com/mcxiaoke/RxDocs/blob/master/operators/Retry.md#retryWhen
[catch]: https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/catch.png
[onErrorReturn 1]: https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/onErrorReturn.png
[onErrorReturn_Func1]: http://reactivex.io/RxJava/javadoc/rx/Observable.html#onErrorReturn%28rx.functions.Func1%29
[onErrorResumeNext 1]: https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/onErrorResumeNext.png
[onErrorResumeNext_Func1]: http://reactivex.io/RxJava/javadoc/rx/Observable.html#onErrorResumeNext%28rx.functions.Func1%29
[onErrorResumeNext_Observable]: http://reactivex.io/RxJava/javadoc/rx/Observable.html#onErrorResumeNext%28rx.Observable%29
[onExceptionResumeNext 1]: https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/onExceptionResumeNextViaObservable.png
[onExceptionResumeNext_Observable]: http://reactivex.io/RxJava/javadoc/rx/Observable.html#onExceptionResumeNext%28rx.Observable%29