将传统的java for循环逻辑替换为使用Spring webflow和webClient的反应式编程

Question

我正在将Spring Boot（MVC）应用程序转换为反应式编程（Spring Webflow）

为了进行外部rest调用，我使用WebClient。

List<String> targetUrls = Arrays.asList("one","two","three");

        int iteration = 1;
        for(String target:targetUrls){

            // make a rest call here 
            // if 200 break the loop
            // else  loop continues
        }

这里的rest调用返回一个Mono。

有没有一种方法可以遍历URL列表(在本例中是这里),并根据一些响应打破循环

在Mono上尝试过平面图，并根据响应可以对另一个url进行rest调用——

Answer 1

您可以应用几种模式来实现此逻辑

可以使用 flatMap 同时执行多个查询。默认情况下，flatMap 将处理 Queues.SMALL_BUFFER_SIZE = 256 个正在进行的内部序列。

Flux.fromIterable(targetUrls)
  .flatMap(url -> webClient.get(url)) 
  .map(response -> process(response))

您可以控制并发平面地图（url -

如果您需要响应来决定下一个请求，另一个有用的模式是使用< code>expand操作符。例如，对于分页请求。

webclient.get(url)
        .expand(response -> {
            if (<should stop>) {
                // stop the loop
                return Mono.empty();
            }

            return webclient.get(url);
        });

Answer 2

我不确定你如何从WebClient调用url，但只是假设URL被传递给一个方法WebClient.get（String url），我将继续这个例子。

这些步骤有点像你将首先获得一系列的URL，然后使用< code>flatMap(因为你的响应是单声道的)，然后在这些URL上使用< code>map。

Flux.fromIterable(targetUrls)
  .flatMap(webClient::get)
  .map(response -> doSomethingWith(response))

现在你应该有一系列的回应。如果来自WebClient的错误处理还不够，您还可以在两者之间插入一些东西。

Flux.fromIterable(targetUrls)
  .flatMap(webClient::get)
  .doOnError(errorHandler::handle)
  .map(response -> doSomethingWith(response))