RxJava如何处理错误与异常

在RxJava中，处理错误和异常主要通过以下几种方式：

1. 使用onErrorReturn操作符：当Observable遇到错误时，可以使用onErrorReturn操作符返回一个默认值或者备选数据，而不是抛出异常。这样，订阅者可以继续接收数据流。

Observable.just(1, 2, 3)
        .map(num -> {
            if (num == 2) {
                throw new RuntimeException("Error: num is 2");
            }
            return num;
        })
        .onErrorReturn((Throwable e) -> -1) // 当发生错误时，返回-1
        .subscribe(System.out::println);

2. 使用onErrorResumeNext操作符：当Observable遇到错误时，可以使用onErrorResumeNext操作符提供一个备选的数据流，订阅者将会接收到备选数据流中的数据。

Observable.just(1, 2, 3)
        .map(num -> {
            if (num == 2) {
                throw new RuntimeException("Error: num is 2");
            }
            return num;
        })
        .onErrorResumeNext((Throwable e) -> Observable.just(-1)) // 当发生错误时，返回-1的数据流
        .subscribe(System.out::println);

3. 使用retry操作符：当Observable遇到错误时，可以使用retry操作符重新订阅并重试。可以指定重试次数或者使用自定义的条件来决定是否重试。

Observable.just(1, 2, 3)
        .map(num -> {
            if (num == 2) {
                throw new RuntimeException("Error: num is 2");
            }
            return num;
        })
        .retry(2) // 当发生错误时，重试2次
        .subscribe(System.out::println);

4. 使用doOnError操作符：当Observable遇到错误时，可以使用doOnError操作符执行一些特定的操作，例如记录日志、发送通知等。但请注意，doOnError不会改变数据流，错误仍然会传播给订阅者。

Observable.just(1, 2, 3)
        .map(num -> {
            if (num == 2) {
                throw new RuntimeException("Error: num is 2");
            }
            return num;
        })
        .doOnError((Throwable e) -> System.out.println("Error occurred: " + e.getMessage()))
        .subscribe(System.out::println);

5. 使用catchError操作符：当Observable遇到错误时，可以使用catchError操作符捕获错误并返回一个新的Observable。这样，订阅者可以继续接收数据流，而不会因为错误而终止。

Observable.just(1, 2, 3)
        .map(num -> {
            if (num == 2) {
                throw new RuntimeException("Error: num is 2");
            }
            return num;
        })
        .catchError((Throwable e) -> Observable.just(-1)) // 当发生错误时，返回-1的数据流
        .subscribe(System.out::println);

在实际应用中，可以根据具体需求选择合适的操作符来处理错误和异常。