在Spring webflux响应中将一个响应对象转换为另一个对象(Pojo)，而无需订阅它

Question

我正在尝试使用一个rest api，它在流动中返回响应。我的目标是使用rest api并处理flux response object (在Spring 5 webflux中将一个response object-1转换为另一个object-2(pojo) )，并在不订阅的情况下将object-2与response一起返回给调用者应用程序。

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();

这里有一个关于如何使用webclient的完整教程。

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