如何使用 Retrofit + RxJava 处理来自并行 Web 请求的错误？答案

【问题标题】：How to handle errors from parallel web requests using Retrofit + RxJava?如何使用 Retrofit + RxJava 处理来自并行 Web 请求的错误？
【发布时间】：2019-03-22 18:31:03
【问题描述】：

我有这样的情况，我并行发出一些 Web 请求。有时我进行这些调用，所有请求都会看到相同的错误（例如 no-network）：

void main() {
    Observable.just("a", "b", "c")
            .flatMap(s -> makeNetworkRequest())
            .subscribe(
                    s -> {
                        // TODO
                    },
                    error -> {
                        // handle error
                    });
}

Observable<String> makeNetworkRequest() {
    return Observable.error(new NoNetworkException());
}

class NoNetworkException extends Exception {
}

根据时间，如果一个请求在其他请求之前发出 NoNetworkException，Retrofit/RxJava 将处理/中断其他请求。对于每个正在进行的请求，我将看到以下日志之一（不是全部三个）++：

<-- HTTP FAILED: java.io.IOException: Canceled
<-- HTTP FAILED: java.io.InterruptedIOException
<-- HTTP FAILED: java.io.InterruptedIOException: thread interrupted

我将能够处理订阅者中的 NoNetworkException 错误，并且下游的所有内容都将被处理掉，一切正常。

但是根据时间，如果两个或更多网络请求发出NoNetworkException，那么第一个将触发上述事件，处理下游的所有内容。第二个NoNetworkException 将无处可去，我会得到可怕的UndeliverableException。这与记录在 here 的示例 #1 相同。

在上面的文章中，作者建议使用错误处理程序。如果我希望再次听到同样的错误，显然retry/retryWhen 没有意义。我不明白onErrorResumeNext/onErrorReturn 在这里如何提供帮助，除非我将它们映射到可恢复的东西以便下游处理：

Observable.just("a", "b", "c")
        .flatMap(s ->
                makeNetworkRequest()
                        .onErrorReturn(error -> {
                            // eat actual error and return something else
                            return "recoverable error";
                        }))
        .subscribe(
                s -> {
                    if (s.equals("recoverable error")) {
                        // handle error
                    } else {
                        // TODO
                    }
                },
                error -> {
                    // handle error
                });

但这似乎很不稳定。

我知道另一种解决方案是使用RxJavaPlugins.setErrorHandler() 设置全局错误处理程序。这似乎也不是一个很好的解决方案。我可能想在我的应用程序的不同部分以不同的方式处理 NoNetworkException。

那么我还有什么其他选择？在这种情况下，其他人会怎么做？这一定很常见。

** 我不完全了解谁在打断/处置谁。 RxJava 是否会处理 flatmap 中的所有其他请求，从而导致 Retrofit 取消请求？或者改造是否取消请求，导致每个平面图中的请求发出上述 IOExceptions 之一？我想回答这个问题并不重要，只是好奇。

++ 根据线程池，可能并非所有 a、b 和 c 请求都在进行中。

【问题讨论】：

你真的经历过吗？在来自媒体帖子的给定示例中，所有操作员都可以并行运行他们的 observables，这将导致所描述的情况。但是，在您的示例中，您有一个平面图。我正在努力理解这两个可观察对象如何失败。据我所知，flatmap 需要完成第一个 observable 才能运行下一个。换句话说，如果一个错误，另一个根本不应该运行。我错过了什么吗？
我认为您正在考虑 concatmap 它将“串行”运行内部 Observables
不是真的，我的意思是至少在你的例子中我觉得很奇怪你设法得到这种行为。这就是为什么我问你是否确定你遇到了同样的问题。在我使用的应用程序中，我有几个像你这样的案例，但从未遇到过这个问题，这就是我感兴趣的原因。
按照我的理解，对于每个just发射，都会有一个makeNetworkRequest()#1，但这不会阻止just发射另一个，这将触发makeNetworkRequest()#2，等等。问题是错误使用者无法在发出网络请求 #1 和 #2 中使用潜在错误，因为第一个错误会错误地结束流。除非我看错了……：p
您是否尝试过将flatMap() 与delayErrors=true 一起使用？

标签： retrofit2 rx-java2

【解决方案1】：

您是否尝试过将 flatMap() 与 delayErrors=true 一起使用？

【讨论】：