Spring WebFlux Mono 的异常中断 Mono.zip

Question

假设我有两个使用 spring webclient 的调用。两者的定义如下，在 .onStatus 中抛出异常：

public Mono<Model> getCall(String path) {
    webClient.get()
            .uri(path)
            .retrieve()
            .onStatus(HttpStatus::isError, errorHandler())}

这是异常函数errorHandler()：

private Function<ClientResponse, Mono<? extends Throwable>> errorHandler() {
    return clientResponse -> clientResponse.bodyToMono(ErrorResponse.class).
            flatMap(errorBody -> Mono.error(new CustomException(clientResponse.statusCode().value(), "exception", errorBody)));

在我的 Mono.zip 中，我将其定义如下：

Mono.zip(getCall(call1),
         getCall(call2))
         .block;

问题是，如果其中一个调用引发异常，我将无法再获得至少一个结果。尝试使用：

.onErrorContinue(CustomException.class, (error, output) -> log.error("CustomException !" + error + output))

那么如何使用 Mono.zip 处理异常，就像我们使用 try catch 一样，但又不停止执行并获得成功调用的结果？ 谢谢你

Answer 1

如果您的输出为空状态，您可以执行以下操作：

.onErrorResume(CustomException.class, e -> Model.empty())

如果你没有空状态，你应该将输出包装到Optional：

.map(Optional::of)
.onErrorResume(CustomException.class, e -> Optional.empty())

在任何情况下，这些运算符都应该链接到getCall 方法。例如：

public Mono<Model> getCall(String path) {
    return webClient.get()
            .uri(path)
            .retrieve()
            .onStatus(HttpStatus::isError, errorHandler())     
            .retrieve()
            .bodyToMono(Model.class)
            .onErrorResume(CustomException.class, e -> Model.empty());
}