我正在使用带有 WebFlux 响应式启动器的 Spring Boot 2 和 Spring 5 开发一些响应式微服务。
我面临以下问题：我想处理通过调用另一个 REST 服务接收到的所有 HTTP 状态，并在收到一些错误的 HTTP 状态时引发异常。例如，当我调用一个端点并且我收到一个 404 HTTP 状态时，我想抛出一个异常并在某个 ExceptionHandler 类中处理该异常，就像它在 Spring 4 中使用@ControllerAdvice 的方式一样。
这样做的正确方法是什么？希望能收到一些好的建议。
【问题讨论】：
标签： java spring-boot exception spring-webflux
这可以通过两个独立的部分来解决。
使用WebClient 时，您可以接收来自远程服务的 HTTP 404 响应。默认情况下，所有4xx 和5xx 客户端响应都将转换为WebClientResponseException。因此，您可以直接在 WebFlux 应用中处理这些异常。
如果您只想将 404 响应转换为自定义异常，您可以执行以下操作：
WebClient webClient = //...
webClient.get().uri("/persons/1")
.retrieve()
.onStatus(httpStatus -> HttpStatus.NOT_FOUND.equals(httpStatus),
clientResponse -> Mono.error(new MyCustomException()))
.bodyToMono(...);
这显然是根据每个客户的调用来完成的。
您可以使用ExchangeFilterFunction 以更可重用的方式实现相同的目的，您可以像这样在WebClient 实例上一劳永逸地设置：
WebClient.builder().filter(myExchangeFilterFunction)...
使用带有注释的 Spring WebFlux，您可以使用带有 @ExceptionHandler 注释的方法处理异常（参见 Spring Framework reference documentation）。
注意：使用WebExceptionHandler 是可能的，但它的级别非常低，因为您在那里没有高级支持：您需要手动编写带有缓冲区的响应，而不支持任何序列化。
【讨论】：
WebClientResponseException？我的理解是 @ExceptionHandler 仅在控制器中受支持。
我认为您正在寻找的是WebFluxResponseStatusExceptionHandler，请查看reference。
在WebHandler API中，可以使用一个WebExceptionHandler来处理 WebFilter 链和目标 WebHandler 的异常。 使用 WebFlux Config 时，注册一个 WebExceptionHandler 就像 就像将它声明为 Spring bean 一样简单，并且可以选择表达 通过 bean 声明上的 @Order 或通过实现优先级 已订购。
This example 可能有帮助，我自己没试过。
@Component
@Order(-2)
class RestWebExceptionHandler implements WebExceptionHandler{
@Override
public Mono<Void> handle(ServerWebExchange exchange, Throwable ex) {
if (ex instanceof PostNotFoundException) {
exchange.getResponse().setStatusCode(HttpStatus.NOT_FOUND);
// marks the response as complete and forbids writing to it
return exchange.getResponse().setComplete();
}
return Mono.error(ex);
}
}
class PostNotFoundException extends RuntimeException {
PostNotFoundException(String id) {
super("Post:" + id + " is not found.");
}
}
【讨论】：