Spring Webclient：当http状态代码为200时，如何使主体处于错误状态

Question

我使用Spring中的webClient从GraphQL WebService中获取数据。此代码位于一个泛型方法中，该方法将响应体解码为不同类型的对象。如果响应是预期的类型，则它运行良好。

webClient()
    .post()
    .bodyValue(graphQLQuery)
    .retrieve()
    .bodyToMono(classType);

现在我想处理来自WebService的错误。因此，我的问题与此非常相似：Spring Webflux：Webclient：Get body on error我发现建议使用onStatus，但我的问题是，即使respons body是错误（请参见下面的示例），http状态代码是200。有没有一种方法可以处理不依赖于http状态代码的错误，比如onStatus？

{
  "errors": [
    {
      "message": "Cannot query field \"something\" on type \"Query\".",
      "locations": [
        {
          "line": 2,
          "column": 3
        }
      ],
      "extensions": {
        "code": "FIELDS_ON_CORRECT_TYPE",
        "codes": [
          "FIELDS_ON_CORRECT_TYPE"
        ],
        "number": "5.3.1"
      }
    }
  ]
}

Answer 1

您可以简单地使用FlatMap并在发现错误时传播错误信号：

return webClient
    .post()
    .bodyValue(graphQLQuery)
    .retrieve()
    .bodyToMono(classType)
    .flatMap(response ->
          response.getErrors() != null && !response.getErrors().isEmpty() ?
              Mono.error(new MyException("Errors found...")) :
              Mono.just(response)
     );