使用 web 客户端 spring boot 按顺序调用 2 url

Question

这个问题与 webflux spring boot 相关。我有 2 个 Web 客户端，一个调用 url 以获取帐户，然后我将这些帐户发送到对象映射器以映射到 POJO。然后我使用第二个 Web 客户端使用这些帐户调用第二个 url。谁能告诉我如何让它们按顺序执行？

在当前情况下，当我从第一个 Web 客户端收到响应并将响应发送到对象映射器时，第二个 Web 客户端启动并且请求正文中的帐户变为 null。

我们将不胜感激。

谢谢。

Answer 1

默认情况下，webclient 是非阻塞 I/O。考虑到您正在使用 ObjectMapper 转换第一次调用的响应。您可以使用 block() 方法使其阻塞调用。

Example:
webClient.get().uri("http:/sdfsdf.com/sdsd").retrieve().bodyToMono(String.class).block();

Answer 2

将WebClient 输出转换为Mono<YouPojo> 并使用flatMap 调用您想要的下一个服务。

    WebClient client1 = null;
    WebClient client2 = null;

    Mono<String> finalResult = client1.get()
            .uri("https://example.com/service-1")
            .retrieve()
            .bodyToMono(String.class)
            .flatMap(result -> client2.post()
                    .uri("https://example.com/service-2")
                    .body(BodyInserters.fromFormData("result", result))
                    .retrieve()
                    .bodyToMono(String.class));

正如您在上面看到的，我们有两个客户端client1 和client2，我们使用它们来调用相应的服务。您可以将Monos 的结果与map 或flatMap 操作结合起来。