当将 Spring WebClient 的 retrieve() 方法与 bodyToMono 结合使用时，将应用默认错误处理（如果响应的状态码为 4xx 或 5xx，则 Mono 将包含 WebClientException）。在错误情况下，生成的 WebClientException 非常有用，因为它包含请求和响应，这对于记录日志非常方便。此外，我可以很好地对错误做出反应。
/*
* Easy to use retrieve() with default error handling:
* By default, if the response has status code 4xx or 5xx, the Mono will contain a WebClientException - AWESOME!
*/
public Optional<MyType> getMyType() {
try {
MyType result = client
.get()
.uri("/myType")
.retrieve().bodyToMono(MyType.class).block();
return Optional.ofNullable(result);
} catch (NotFound e) {
return Optional.empty();
}
}
但是，有时我需要知道响应的确切状态代码才能在进一步处理此响应时对其做出反应。获得状态码的唯一方法是调用 exchange() 方法而不是 retrieve() 方法。不幸的是，在这种情况下，不应用默认错误处理。原因似乎是在 ClientResponse 上调用 bodyToMono() 与在 ResponseSpec 上调用它具有不同的语义。
我不能调用 Spring 中已经实现的方法来“触发”错误处理，因为所有好的方法都被隐藏在 WebClient 中作为私有方法。
即使我尝试“手动”创建 WebClientResponseException 我也无法访问请求以提供给异常。
public String updateMyType() {
ClientResponse response = client
.put()
.uri("/myType")
.header(CONTENT_TYPE, APPLICATION_JSON_VALUE)
.body(fromObject(new MyType()))
.exchange()
.block();
if (response.statusCode().equals(HttpStatus.CREATED)) {
return "OK";
} else if (response.statusCode().equals(HttpStatus.NO_CONTENT)) {
return "updated";
} else {
byte[] bodyBytes = null; // already implemented by Sping but not accessible
Charset charset = null; // already implemented by Sping but not accessible
HttpRequest request = null; // where should I get this from?
throw WebClientResponseException.create(response.statusCode().value(),
response.statusCode().getReasonPhrase(),
response.headers().asHttpHeaders(),
bodyBytes,
charset,
request);
}
}
“模仿”与 retrieve() 方法相同的行为的最佳方法是什么？