rxjava怎样处理错误异常

在RxJava中，处理错误异常通常使用onError方法。当Observable在发射数据过程中遇到错误时，它会调用onError方法通知订阅者。订阅者可以通过实现Observer接口或使用RxJavaPlugins.setErrorHandler()全局处理错误。

以下是使用Observer接口处理错误的示例：

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class RxJavaErrorHandlingExample {
    public static void main(String[] args) {
        Observable.just("Hello", "World", "RxJava")
                .map(s -> {
                    if (s.equals("World")) {
                        throw new RuntimeException("Error: World");
                    }
                    return s;
                })
                .subscribe(new Observer<String>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        // 在订阅时执行
                    }

                    @Override
                    public void onNext(String s) {
                        // 在接收到数据时执行
                        System.out.println(s);
                    }

                    @Override
                    public void onError(Throwable e) {
                        // 在遇到错误时执行
                        System.err.println("Error: " + e.getMessage());
                    }

                    @Override
                    public void onComplete() {
                        // 在完成时执行
                        System.out.println("Completed");
                    }
                });
    }
}

在这个示例中，我们使用map操作符模拟了一个错误。当遇到字符串"World"时，抛出一个运行时异常。Observer的onError方法会捕获这个异常并处理它。

如果你想在整个应用程序中全局处理错误，可以使用RxJavaPlugins.setErrorHandler()方法：

import io.reactivex.plugins.RxJavaPlugins;

public class RxJavaGlobalErrorHandlingExample {
    public static void main(String[] args) {
        // 设置全局错误处理器
        RxJavaPlugins.setErrorHandler(e -> {
            System.err.println("Global Error: " + e.getMessage());
        });

        Observable.just("Hello", "World", "RxJava")
                .map(s -> {
                    if (s.equals("World")) {
                        throw new RuntimeException("Error: World");
                    }
                    return s;
                })
                .subscribe(
                        s -> System.out.println(s),
                        e -> System.err.println("Local Error: " + e.getMessage()),
                        () -> System.out.println("Completed")
                );
    }
}

在这个示例中，我们设置了一个全局错误处理器，它会捕获所有未处理的异常。当遇到错误时，全局错误处理器和本地错误处理器都会被调用。