浅谈RxJava处理业务异常的几种方式

在RxJava中，对于发生的业务异常，我们需要合理地处理它们。本文将为你详细讲解RxJava处理业务异常的几种方式。

方式一：使用onErrorReturn

onErrorReturn操作符可以自定义需要返回的异常。当遇到一个发生了异常的Observable时，它会立即将预先定义好的值或者引用返回给订阅者。

下面是一个简单的示例：

Observable.just(1, 2, 3, 4, 5)
        .map(integer -> {
            if (integer == 3) {
                throw new RuntimeException("发生了业务异常");
            }
            return integer;
        })
        .onErrorReturn(integer -> -1)
        .subscribe(integer -> {
            System.out.println("收到数据 " + integer);
        }, throwable -> {
            System.out.println("发生了异常 " + throwable.getMessage());
        });

在上面的示例中，当发生了业务异常时，我们通过使用onErrorReturn返回了一个值，其输出结果如下：

收到数据 1
收到数据 2
发生了异常 发生了业务异常
收到数据 -1
收到数据 5

方式二：使用onErrorResumeNext

onErrorResumeNext操作符可以让我们在遇到异常时将一个备用的Observable作为当前Observable的替代品。

下面是一个简单的示例：

Observable.just(1, 2, 3, 4, 5)
        .map(integer -> {
            if (integer == 3) {
                throw new RuntimeException("发生了业务异常");
            }
            return integer;
        })
        .onErrorResumeNext(throwable -> Observable.just(6, 7, 8))
        .subscribe(integer -> {
            System.out.println("收到数据 " + integer);
        }, throwable -> {
            System.out.println("发生了异常 " + throwable.getMessage());
        });

在上面的示例中，当发生了业务异常时，我们通过使用onErrorResumeNext将一个备用的Observable作为当前的替代品，其输出结果如下：

收到数据 1
收到数据 2
发生了异常 发生了业务异常
收到数据 6
收到数据 7
收到数据 8

总结

本文介绍了RxJava处理业务异常的两种方式：使用onErrorReturn和onErrorResumeNext。虽然这两种方式不是最全面、最细致的异常处理方式，但是对于处理一些简单业务场景中的异常，它们还是很实用的。

参考资料：
- RxJava处理业务异常的几种方案