Spring WebClient聚合多个401 UNAUTHORIZED错误以引发Exceptions.CompositeException

Question

当WebClient使用错误的令牌异步调用外部api(使用不同的查询参数)时，前几个调用返回401 UNAUTHORIZED，控制流因< code >异常而停止。CompositeException。我们在< code>WebClient实例中添加了如下过滤器，用于检查4xx和5xx响应状态代码，以抛出自定义异常

private final ExchangeFilterFunction responseFilter() {
    return ExchangeFilterFunction
            .ofResponseProcessor(response -> response.statusCode().isError() ? error(() -> new CustomException("API Error")) : just(response));

private WebClient buildWebClient(WebClient.Builder builder) {
    return builder
            .filter(responseFilter())
            .build();
}

现在的问题是，当第一次调用返回错误（401）时，CustomException不会被抛出，而是聚合了一堆调用并抛出Exceptions.CompositeException。在日志中，我们可以看到在复合失败之前至少有 3 或 4 401 个未授权。当第一个失败时，它不会引发预期的自定义异常。此WebClient调用发生在Flux内部.zip我不确定这是否与该问题有关。

Answer 1

当使用任何DelayError变量运算符时，reactor会将任何异常（如果超过1）收集到CompositeException中。

Reactor 提供了一个实用方法 Exceptions.unwrapMultiple，如果您只想在上游传播子集或单个错误，则帮助将复合异常解压缩到可抛出对象列表中 - Java 文档

Exceptions.unwrapMultiple

尝试将可抛投对象解包到可投掷对象列表中。这仅在所述 Throwable 是由 multiple（Throwable...） 构建的复合异常的情况下完成的，在这种情况下，列表包含包装为复合中的抑制异常的异常。在任何其他情况下，列表仅包含输入 Throwable（或者在空输入的情况下为空）。

例

下面是一个小示例，使用< code>unwrapMultiple仅传播< code>CompositeException中的第一个< code>Throwable。

    Flux<Object> range = Flux.range(1, 10)
            .flatMapDelayError(i -> Mono.error(new IllegalArgumentException(String.format("Error: %s", i))), 10, 1)
            .onErrorResume(throwable -> Mono.error(Exceptions.unwrapMultiple(throwable).get(0)));
    StepVerifier.create(range)
            .expectError(IllegalArgumentException.class)
            .verify();