使用SpringWebClient同时进行分页API调用

Question

我必须使用WebClient进行分页API调用，并最终组合所有结果。例如：个人最新1000交易详情。在一次调用中，我将在json响应（List）中获得最大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;
        }
    }

如何在SpringMVC中以反应式方式编写相同的内容而不阻塞？

像这样的东西？？？我不知道。帮助我

    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