使用webclient使用外部api

Question

我有网址列表。我正在尝试从这些api中使用jsondata。下面是我尝试过的代码，但我得到了Mono.flatMapMany-

如果我使用. block（），我将为这些api获取jsonData，但问题是当我使用. block（）时它变得同步。我希望它是异步的。有人能帮我吗？

提前谢谢。

List<String> urls=getUrls();
Flux<String> k=null;
for(int i=0;i<urls.size();i++){
    k=webClientBuilder.
      build.get().
      uri(urls.get(i)).retrieve().
      bodyToFlux(String.class);
}

Answer 1

您提供的代码片段有一些问题，因此我建议您首先阅读项目Reactor参考留档

下面的代码片段有望实现您想要的功能。尽管如果希望将其作为反应性管道的一部分运行，您将希望从此方法返回通量，而不是订阅。底层框架（本例中为spring boot）将启动订阅。

        List<String> urls = Arrays.asList("https://google.com", "https://yahoo.com");
        WebClient webClient = WebClient.builder().build();

        Flux.fromStream(urls.stream())
                .flatMap(url -> webClient.get()
                        .uri(url)
                        .retrieve()
                        .bodyToMono(String.class))
                .doOnNext(s -> System.out.println("Response: " + s))
                .subscribe();