RxJava的doOnError如何处理错误

在RxJava中，doOnError操作符用于在Observable执行过程中捕获错误，并在错误发生时执行一些操作。doOnError不会终止Observable的执行，它只是简单地观察错误并执行指定的操作。如果你想要处理错误并继续Observable的执行，你可以使用onErrorResumeNext或retry操作符。

下面是一个使用doOnError处理错误的示例：

import io.reactivex.Observable;
import io.reactivex.functions.Consumer;

public class RxJavaDoOnErrorExample {
    public static void main(String[] args) {
        Observable.just(1, 2, 3, 4, 5)
                .map(number -> {
                    if (number == 3) {
                        throw new RuntimeException("Error: " + number);
                    }
                    return number;
                })
                .doOnError(new Consumer<Throwable>() {
                    @Override
                    public void accept(Throwable throwable) throws Exception {
                        System.out.println("Error occurred: " + throwable.getMessage());
                    }
                })
                .subscribe(
                        number -> System.out.println("Received number: " + number),
                        throwable -> System.out.println("Error in subscribe: " + throwable.getMessage())
                );
    }
}

在这个示例中，我们创建了一个包含1到5的Observable。当遇到数字3时，我们抛出一个异常。doOnError操作符捕获这个异常并打印错误信息。然后，订阅者会收到一个错误通知。

如果你想要在发生错误时继续Observable的执行，你可以使用onErrorResumeNext操作符：

import io.reactivex.Observable;
import io.reactivex.functions.Function;

public class RxJavaOnErrorResumeNextExample {
    public static void main(String[] args) {
        Observable.just(1, 2, 3, 4, 5)
                .map(number -> {
                    if (number == 3) {
                        throw new RuntimeException("Error: " + number);
                    }
                    return number;
                })
                .onErrorResumeNext(new Function<Throwable, Observable<? extends Number>>() {
                    @Override
                    public Observable<? extends Number> apply(Throwable throwable) throws Exception {
                        System.out.println("Error occurred: " + throwable.getMessage());
                        return Observable.just(6); // 返回一个新的Observable以继续执行
                    }
                })
                .subscribe(
                        number -> System.out.println("Received number: " + number),
                        throwable -> System.out.println("Error in subscribe: " + throwable.getMessage())
                );
    }
}

在这个示例中，当遇到数字3时，我们抛出一个异常。onErrorResumeNext操作符捕获这个异常并打印错误信息，然后返回一个新的Observable（包含数字6），使得原始Observable可以继续执行。