SpringBoot WebFlux：解析并行WebClient请求

Question

我正在用spring WebClient对API进行并行rest调用。响应如下所示

{
  "d": {
    "results": [
        {
            "id": "1",
            "name": "Test A"
        },
        {
            "id": "2",
            "name": "Test B",
        }

    ]
  }
}

POJOS：

public class ProductResponse {
    private Products d;
}

public class Products {
    private List<ProductModel> results;
}

public class Product {
    private String id;
    private String name;
}

public Flux<ProductsResponse> getProducts(final List<String> pages) {
    return Flux.fromIterable(pages)
            .flatMap(page -> webClient.get().uri("SOMEURL?page={page}", page)
                    .accept(MediaType.APPLICATION_JSON)                        
                    .retrieve()
                    .bodyToMono(ProductsResponse.class))
            .log()
            .subscribeOn(Schedulers.elastic());
}

获取产品

Flux<ProductsResponse> productList = getProductList(pages);
List<ProductsResponse> productsResponse = productList.collectList().block();
for (ProductsResponse response : productsResponse) {
    for (ProductModel product: response.getD().getResults()) {
        System.out.println(product.getProductId());
    }
}

这也是有效的，但是有没有一种方法可以直接返回flux ，或者返回mono 更好？

（下一步是将产品保存在数据库中）

Answer 1

请按以下方式尝试：

        Flux<Product> productFlux = Flux.fromIterable(pages)
            .flatMap(page -> client.get().uri("SOMEURL?page={page}", page)
                    .accept(MediaType.APPLICATION_JSON)
                    .retrieve()
                    .bodyToMono(ProductResponse.class)
                    .map(productResponse -> productResponse.d.results)
                    .flatMapMany(Flux::fromIterable))
            .log()
            .subscribeOn(Schedulers.elastic());