使用 Spring Webclient 同时进行分页 API 调用

Question

我必须使用 Webclient 进行分页 API 调用，最后合并所有结果。 例如：个人最新的 1000 笔交易详情。 在一次通话中，我将在 json 响应（列表）中获得最多 100 个对象。 我最多只能获取此人的 1000 条记录。

在伪代码 - java 中，它可能看起来像这样

    int Total = 1000;
    int maxEachCall = 100;
    int noOfCalls = maxTotal/maxEachCall;
    int startIndex = 0;

    List<MyDto> mailList = new ArrayList();

    for(int i =startIndex; i<noOfCalls ;i+100){
        List<MyDto> list =  webClient.get().uri(baseUri+"?startIndex"+startIndex)
                        .retrieve()
                        .bodyToMono(MyDto.class)                            
                        .retry(3)
                        .block();
        mainList.addAll(list);
        if(startIndex>900 || list.size()<100){
            break;
        }
    }

如何在 spring mvc 中不阻塞而以反应方式编写相同的东西？

这样的？？？我不知道。帮帮我

    int Total = 1000;
    int maxEachCall = 100;
    int noOfCalls = maxTotal/maxEachCall;
      int startIndex = 0;
    Flux.range(1,noOfCalls)
        .flatMap(
            // tried to call api using startIndex but can't use startIndex here or manipulate it
        )
        .doOnError(e->LOGGER.info("Exception occured ",e))
        .blockLast(); ???

Answer 1

你可以做类似的事情：

Flux.range(0, 10)
        .map(start -> start * 100)
        .flatMap(
                start -> webClient.get()
                        .uri(baseUri + "?startIndex=" + start)
                        .retrieve()
                        .bodyToMono(MyDtoCollection.class)
                        .map(c -> splitCollectionIntoIndividualMyDto(c)) //or something to that effect, since you'll get 100 `MyDto` at a time and presumably need to split them.
        )
        .collectList();

...它将为您提供包含所有分页结果的Mono<List<MyDto>>。如果您的堆栈是完全反应式的，那么您将继续在其他地方的反应式链中使用 Mono。如果（尚未）完全反应，并且您只是在此位使用反应器，那么您可以选择在最合理的位置block()。