java - 如何在 Spring Flux 错误处理程序中访问引用源对象？

Question

我有一个阻止网络请求的列表，如 List<Mono>我想同时执行。

以下内容通常有效，但是:当发生异常时，我想收集分配给导致异常的请求的映射中的所有错误。

List<Request> bodies;
List<Mono<Response>> monos = requests.stream().map(bodies -> prepareMono(body)).collect(Collectors.toList());

Map<Request, Throwable> errors = new HashMap<>();

List<Response> results = Flux.merge(monos).collectList().onErrorContinue((ex, value) -> {
            //TODO how can I access the <Request> here who caused the exception
            errors.put(<request>, ex);
        }).block();

private Mono<Response> prepareMono(Object body) {
    return webClient.post().syncBody(body).retrieve().bodyToMono(Response.class);
}

问题:如何访问我在错误处理程序中发送的请求正文？

Answer 1

你可以尝试这样的事情:

Flux.fromIterable(requests)
    .flatMap(request -> execute(request))
    .doOnNext(result -> {
        if (result.throwable != null)
        {
            Request request = result.request;
            Throwable throwable = result.throwable;
            // do something
        }
    });

private Mono<Result> execute(Request request)
{
    return WEB_CLIENT.post().syncBody(request).retrieve()
                     .bodyToMono(Response.class)
                     .map(response -> new Result(request, response, null))
                     .onErrorResume(e -> Mono.just(new Result(request, null, e)));
}

private class Result
{
    private Request request;
    private Response response;
    private Throwable throwable;

    private Result(Request request, Response response, Throwable throwable)
    {
        this.request = request;
        this.response = response;
        this.throwable = throwable;
    }
}

不过，在 react 链之外的映射中收集请求错误是相当难看的。