如何从 Spring WebClient 获取响应 json

Question

我一直在尝试遵循最简单的教程来了解如何使用 WebClient，据我了解，与 RestTemplate 相比，它是下一个最棒的东西。

例如，https://www.baeldung.com/spring-5-webclient#4-getting-a-response

所以当我尝试对应该返回一些 json 的 https://petstore.swagger.io/v2/pet/findByStatus?status=available 做同样的事情时，

WebClient webClient = WebClient.create();
webClient.get().uri("https://petstore.swagger.io/v2/pet/findByStatus?status=available").exchange().block();

我完全不知道如何从生成的DefaultClientResponse 对象着手。到达物理反应体不应该这么复杂，但我跑题了。

如何使用我提供的代码获取响应正文？

Answer 1

以您目前拥有的形式，并解释行为..

WebClient webClient = WebClient.create();
webClient.get()
         .uri("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
         .exchange()
         .block();

block() 通过内部同步订阅Mono 来启动请求，并返回结果ClientResponse。您也可以通过在exchange() 方法返回的Mono 上调用subscribe() 来异步处理此问题，而不是block()。

在当前的形式中，在block() 之后，您现在拥有ClientResponse 对象中有关响应的所有元数据（即来自响应标头），包括成功状态。这并不意味着响应主体已经完成。如果您不关心响应负载，您可以确认成功并保留它。

如果您还想查看响应正文，则需要将响应正文流转换为某个类。此时您可以决定是否要将所有内容读入单个 Mono 和 bodyToMono 或读入对象流 (Flux) 和 bodyToFlux，例如在响应是 JSON 数组的情况下可以解析成单独的独立 Java 对象。

但是，在您的情况下，您只想按原样查看 JSON。所以转换为String 就足够了。您只需使用bodyToMono，它会返回一个Mono 对象。

WebClient webClient = WebClient.create();
String responseJson = webClient.get()
                               .uri("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
                               .exchange()
                               .block()
                               .bodyToMono(String.class)
                               .block();

在这里，您使用block() 等待响应负载到达并被解析为String，但您也可以将subscribe 发送到Mono 以在响应完成时接收它。

需要注意的一点是retrieve() 可以用来代替exchange() 来缩短ClientResponse。在这种情况下，您让默认行为处理错误响应。使用exchange() 将所有责任放在应用程序上，以响应ClientResponse 上的错误响应。阅读更多in the Javadoc。 retrieve() 版本如下所示。无需block()，因为您只关心响应数据。

WebClient webClient = WebClient.create();
String responseJson = webClient.get()
                               .uri("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
                               .retrieve()
                               .bodyToMono(String.class)
                               .block();

Answer 2

这是您向RestTemplate提出请求的方式

String json = new RestTemplate()
    .getForEntity("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
    .getBody();

这是您向requests提出请求的方式

import requests

json = requests.get("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
    .content

这里是您向WebClient提出请求的方式

String json = WebClient.create()
    .get()
    .uri("https://petstore.swagger.io/v2/pet/findByStatus?status=available")
    .exchange()
    .block()
    .bodyToMono(String.class)
    .block();