WebClient使用ExchangeFilterFunctions向Mono添加处理程序

Question

我想知道向从ExchangeFilterFunction返回的单声道添加功能是否会应用于返回的最终单声道。基本上，我希望通过将一些关注点移出客户机类并添加到ExchangeFilterFunctions中来清理一些客户机代码，我可以将这些关注点添加到客户机中，但我的情况与单个调用有点不同。

    Flux.fromIterable(uris)
        .parallel()
        .runOn(Schedulers.parallel())
        .flatMap(uri -> webClient.get()
            .uri(uri)
            .headers(headers -> headers.addAll(httpHeaders))
            .retrieve()
            .onStatus(
                status -> status.is4xxClientError() || status.is5xxServerError(),
                response -> response.bodyToMono(String.class)
                    .map(body -> new MyCustomException(body, response.statusCode())))
            .bodyToMono(MyResponse.class)
            .map(x -> Tuple.of(x, null))                
            .onErrorMap(ReadTimeoutException.class, th ->
                new MyCustomException(ErrorResponseBuilder.buildError(th), HttpStatus.INTERNAL_SERVER_ERROR)))
        .doOnEach(this::log)
        .sequential();

Answer 1

错误处理逻辑肯定可以被分离出来，这篇Baeldung的文章对此非常有用

另外，我建议对代码进行重构，以便没有任何嵌套的映射/平面映射。这将使您的代码更具可读性，并可能使您了解哪些部分应该提取出来。本文很好地涵盖了这一点