rxjava 中的异常处理答案

【问题标题】：Exception handling in rxjavarxjava 中的异常处理
【发布时间】：2023-03-22 14:33:01
【问题描述】：

我正在尝试习惯 rxjava 并且我正在尝试在 Observable 中调用下面的 QuoteReader。我不确定如何处理抛出的异常，

public class QuoteReader {
   public Map<String, Object> getQuote() throws IOException{
       OkHttpClient okHttpClient = new OkHttpClient();
       Request request = new Request.Builder().url("http://quotes.rest/qod.json").build();
       Gson gson = new Gson();
       Map<String, Object> responseMap = null;

       try(Response response = okHttpClient.newCall(request).execute()) {
         responseMap = gson.fromJson(response.body().string(), Map.class);
         System.out.println("response map : "+responseMap);
       } catch(IOException ioe) {
         ioe.printStackTrace();
         throw ioe;
       } finally {
         okHttpClient = null;
         request = null;
       }
    return responseMap;
  }
}

以下是我正在尝试编写的 rx 代码，

rx.Observable.just(new QuoteReader().getQuote()) //compile time error saying unhandled exception
              .subscribe(System.out::println);

我应该如何更新代码来处理异常。谢谢！

【问题讨论】：

您应该将代码包装在 try/catch 块中，或者声明您的方法会引发异常。

标签： java lambda exception-handling rx-java reactive-programming

【解决方案1】：

使用fromCallable 允许你的方法抛出（另外，它会被延迟评估，而不是在你进入 Observable 世界之前）：

rx.Observable.fromCallable(() -> new QuoteReader().getQuote())
          .subscribe(System.out::println, Throwable::printStackTrace);

【讨论】：

【解决方案2】：

Observable 还有另一种工厂方法，称为create。这为您提供了一个 Observer 作为 lambda 表达式的输入。 Observer 是一种回调对象，具有三种方法：onNext(T t)、onError(Throwable e) 和onCompleted。我读到你是 RxJava 的新手，所以这里有一点额外的补充说明：Rx 合约指定 Observer 可以接收零个或多个 onNext 调用，然后是也许 onError 或 onCompleted 致电。在正则表达式中看起来像：onNext* (onError|onCompleted)?。

现在你知道了，你可以使用Observable.create来实现你的操作：

Observable.create(observer -> {
  try {
    observer.onNext(new QuoteReader.getQuote());
    observer.onCompleted();
  }
  catch (Throwable e) {
    observer.onError(e);
  }
}

请注意，在您订阅此 Observable 之前，此代码不会执行任何操作，就像您在问题中所做的那样！

【讨论】：

【解决方案3】：

可观察管道不允许您抛出异常。您必须使用 runtimeExceptions。所以改变你的代码应该是这样的。

     try(Response response = okHttpClient.newCall(request).execute()) {
        responseMap = gson.fromJson(response.body().string(), Map.class);
        System.out.println("response map : "+responseMap);
   } catch(IOException ioe) {
     ioe.printStackTrace();
     new RuntimeException(ioe);

你可以在这里看到一个实际的例子https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/errors/ObservableExceptions.java

【讨论】：

github 链接抛出 404