如何使用React（Spring WebClient）模拟for循环

Question

我是相当新的Reactor（Spring5 WebClient），虽然我已经想出了如何做简单的请求和处理它的输出与地图或平面图，我现在需要做一个有点困难的任务：

我有一个无法改变的终点。

这个endpoint调用的基本签名是Get{host}/{endpointName}？系统={1到3之间的整数}

我需要反复调用它，并处理这对的输出：

{1, 1},
{1, 2},
{1, 3},
{1, 4},
...
{3, 2},
{3, 4},
{3, 5}

对于一个请求，例如：

WebClient.create().get()
  .uri(uri -> uri.scheme("http")
    .host(myHost)
    .path(myPath)
    .queryParam("System", 1)
    .queryParam("Form", 1)
    .build())
  .exchange()
  .flatMap(response -> {
   //process response and produce desired output
   });

我想做的是：1。提出多个请求（基本上是在包含上述所有对的映射上迭代）2。处理每个请求结果（处理后的结果被添加到WebClient之前创建的json数组中）3。当发出所有请求时，给出“组合输出”。

示例：如果组合1,1的请求给出

[
{
"Name":"John",
"Surname":"Doe"
}
]

第三对，第五对给出

[
{
"Name":"Jane",
"Surname":"Dean"
}
]

此WebClient调用的结果应为

[
{
"Name": "John",
"Surname: "Doe"
},
....
{
"Name": "Jane",
"Surname": "Dean"
}
]

我知道Mono的重试和重复机制，只是不知道如何使用“不同请求参数进行多个调用”部分。

这有可能吗？




Answer 1

匿名用户

使用Flux。范围与平面地图结合使用：

Flux.range(1, 5)
    .flatMap(i -> Flux.range(1, 5).map(j -> Tuples.of(i, j)))
    .flatMap(t ->
        WebClient.create().get()
            .uri(uri -> uri.scheme("http")
                .host(myHost)
                .path(myPath)
                .queryParam("System", t.getT1())
                .queryParam("Form", t.getT2())
                .build())
            .exchange()
    )
    .flatMap(response -> /* Handle the response... */)

如果我在上面的例子中计算的元组存储在映射中

Flux.fromIterable(intIntMap.entrySet())
    .flatMap(entry ->
        WebClient.create().get()
            .uri(uri -> uri.scheme("http")
                .host(myHost)
                .path(myPath)
                .queryParam("System", entry.getKey())
                .queryParam("Form", entry.getValue())
                .build())
            .exchange()
    )
    .flatMap(response -> /* Handle the response... */)

使用这些方法，您将永远不会离开函数世界，从而得到更干净、更简洁的代码。