Spring boot WebClient를 사용하여 페이지화된 API 응답을 수집하는 방법은 무엇입니까?

Spring boot WebClient를 사용하여 페이지화된 API 응답을 수집하는 방법은 무엇입니까?

URL에서 페이지로 된 응답이 있습니다. 이전 응답에서 얻은 다음 페이지 URL을 계속 누르고 응답에 "nextPage" URL이 없을 때까지 항목을 계속 수집하고 싶습니다.차단 없이 WebFlux에서 봄 부팅 WebClient를 사용하여 대응적인 방법으로 이를 달성하는 방법은 무엇입니까?

Request1: 

    GET /items
    response: 
    {
        items: [...]
        nextPage: "/items?page=2"
    }


    Request2: 

    GET /items?page=2
    response: 
    {
        items: [...]
        nextPage: "/items?page=3"
    }


    Request3: 

    GET /items?page=3
    response: 
    {
        items: [...]
        nextPage: null
    }

여기서 저는 모의 URL https://karthikdivi.com/apps/paginatedReviews/withNextPageTokens/items https://karthikdivi.com/apps/paginatedReviews/withNextPageTokens/items?page=2 https://karthikdivi.com/apps/paginatedReviews/withNextPageTokens/items?page=3 을 만들었습니다.

차단하지 않고 반응적인 방법으로 위의 응답에서 모든 항목을 추출하려면 어떻게 해야 합니까?

expand를 사용하면 이를 달성할 수 있습니다.당신이 제공한 모의 URL을 기준으로 합니다.

public Mono<List<Item>> getItems() {
    String url = "https://karthikdivi.com/apps/paginatedReviews/withNextPageTokens/items";

    return fetchItems(url).expand(response -> {
        if (response.getNextPage() == null) {
            return Mono.empty();
        }
        return fetchItems(response.getNextPage());
    }).flatMap(response -> Flux.fromIterable(response.getItems())).collectList();
}

private Mono<Response> fetchItems(String url) {

         return client.get().uri(url).retrieve()
                    .bodyToMono(Response.class);
    }

다음을 사용하여 원하는 효과를 얻을 수 있습니다.expand:

@Test
public void usingExpand(){

    Request innerData = new Request(null);
    Request middleData = new Request(innerData);
    Request rootData = new Request(middleData);

    Mono.just(rootData)
            .expand( t -> Mono.justOrEmpty(t.nextPage))
            .flatMap( t -> Flux.fromIterable(t.items))
            .subscribe(System.out::println);

}

public static class Request {
    List<String> items = new ArrayList<>();
    Request nextPage;

    public Request(Request nextPage) {
        this.items.add(UUID.randomUUID().toString());
        this.items.add(UUID.randomUUID().toString());
        this.nextPage = nextPage;
    }
}

위의 코드는 다음과 같은 결과를 생성해야 합니다.

dc78317c-5552-4723-90db-5392c67655be
32ff12bb-5be1-415e-b481-dab85d9157dd
cf1e3f36-a8e2-414d-90a2-7708eeedc5be
91a6bc14-a396-483d-a66a-80bb98dc1968
c95adae3-8e6f-489b-8a9d-4cea3080e150
d6f8fe01-2c50-4574-958c-ec675331bb25

각 데이터 개체의 UUID 2개.

언급URL : https://stackoverflow.com/questions/53274568/how-to-collect-paginated-api-responses-using-spring-boot-webclient