使用WebFlux处理调用Restful服务的错误示例

Question

Mono<ResponseObject> mono = webClient.post()
   .uri(url.toString())
   .header("Authorization", authToken)
   .body(Mono.just(contract), contract.getClass())
   .retrieve()
   .bodyToMono(ResponseObject.class);

"success" : true,
"httpStatus": 200,
"messages" : [
   "Informational message or, if not 200, then error messages"
],
result: {
   "data": {}
}

这似乎是我想做的：Spring Webflux：Webclient：让body出现错误，但仍然不能让它工作。不确定exchange（）是什么

Answer 1

正确的处理方法是通过.onerrorResume，当出现任何错误时，它允许您使用函数订阅回退发布服务器。您可以查看生成的异常并返回自定义回退响应。

您可以这样做：

Mono<ResponseObject> mono = webClient.post()
   .uri(url.toString())
   .header("Authorization", authToken)
   .bodyValue(contract)
   .exchangeToMono(response -> {
      if (response.statusCode().equals(HttpStatus.OK)) {
          return response.bodyToMono(ResponseObject.class);
      }
      else if (response.statusCode().is4xxClientError()) {
          return response.bodyToMono(ResponseObject.class);
      }
      else {
          Mono<WebClientResponseException> wcre = response.createException();
          // examine wcre and create custom ResponseObject

          ResponseObject customRO = new ResponseObject();
          customRO.setSuccess(false);
          customRO.setHttpStatus(response.rawStatusCode());
          // you can set more default properties in response here
          return Mono.just( customRO );
      }
   });

此外，您不应该在Java代码中的任何地方使用.block()。只需确保从REST控制器返回一个单字 即可。如果希望在返回客户端之前检查响应，可以在管道末尾的.map()处理程序中这样做（就在.onerrorResume处理程序之后）

   .map(response -> {
      // examine content of response

      // in the end just return it
      return response;
   });