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

Question

我有这样的情况，我并行发出一些网络请求。有时我进行这些调用并且所有请求都看到相同的错误(例如无网络):

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。这与记录在案的示例 #1 相同 here .

在上面的文章中，作者建议使用错误处理程序。显然，如果我希望再次听到相同的错误，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 取消请求？或者 Retrofit 取消请求，导致每个在平面图中发出上述 IOExceptions 之一的请求？我想回答这个问题并不重要，只是好奇。

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

Answer 1

您是否尝试过使用 delayErrors=true 的 flatMap()？