java - 在Spring webflux Flux响应中将一个响应对象转换为另一个对象(pojo)而不订阅它

Question

我正在尝试使用一个以 FLUX 形式返回响应的 REST API。我的目标是使用 Rest api 并处理 Flux 响应对象(在 Spring 5 webflux 中将一个响应 object-1 转换为另一个 object-2(pojo) )并返回 object-2 以及对调用者应用程序的响应，而不订阅它。

Answer 1

最好的方法是使用 webclient 作为 Rest 客户端，它允许您获取 Flux 作为响应，然后使用 map 将对象转换为任何其他类型，并再次使用 webclient 提交新响应。例如:

FLux<Foo> response = webClient.get()
            .uri("/foo")
            .retrieve()
            .bodyToFlux(GithubRepo.class);
Flux<Bar> converted = response.map(response -> convertToBar(response));

webClient.post()
            .uri("/bar")
            .body(converted, Bar.class)
            .retrieve();

这里有关于如何使用网络客户端的完整教程。

https://www.baeldung.com/spring-5-webclient