我们如何使用@ExceptionHandler与Springweb通量？

Question

在Spring Web中，我们可以使用注释@ExceptionHandler来处理控制器的服务器和客户端错误。

我曾尝试在web flux controller中使用此注释，但它仍然对我有效，但经过一些调查后，我在这里发现了这一点

Spring Web Reactive的情况更复杂。因为响应流是由不同的线程计算的，而不是执行控制器方法的线程，异常不会自动传播到控制器线程。这意味着@ExceptionHandler方法仅适用于直接处理请求的线程中引发的异常。如果我们想使用@ExceptionHandler功能，流中引发的异常必须传播回线程。这似乎有点令人失望，但在撰写本文时，Spring 5仍未发布，因此错误处理可能会更好。

所以我的问题是如何将异常传播回线程。有没有关于使用@ExceptionHandler和SpringWebFlux的好例子或文章？

更新：从Spring开始。io看起来它得到了支持，但仍然缺乏普遍的理解

谢谢

Answer 1

这并不是对原始问题的确切答案，但是将异常映射到http响应状态的一种快速方法是抛出org。springframework。网状物服务器ResponseStatusException/或创建自己的子类。。。

对http响应状态的完全控制spring将添加一个响应主体，该主体带有添加原因的选项。

{
    "timestamp": 1529138182607,
    "path": "/api/notes/f7b.491bc-5c86-4fe6-9ad7-111",
    "status": 400,
    "error": "Bad Request",
    "message": "For input string: \"f7b.491bc\""
}

Answer 2

现在可以在Spring WebFlux中使用@ExceptionHandler，以及@RestControlller建议，甚至@Controlller建议。

例：

>

添加webflux依赖项

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

创建类ExceptionHandler

@RestControllerAdvice
public class ExceptionHandlers {

    private static final Logger LOGGER = LoggerFactory.getLogger(ExceptionHandlers.class);

    @ExceptionHandler(Exception.class)
    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
    public String serverExceptionHandler(Exception ex) {
        LOGGER.error(ex.getMessage(), ex);
        return ex.getMessage();
    }
}

创建一个控制器

@GetMapping(value = "/error", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public Mono<String> exceptionReturn() {
    return Mono.error(new RuntimeException("test error"));
}

此处摘录的示例：

https://ddcode.net/2019/06/21/spring-5-webflux-exception-handling/

Answer 3

您可以使用@ExceptionHandler带注释的方法来处理WebFlux处理程序执行过程中发生的错误（例如，您的控制器方法）。使用MVC，您确实可以处理映射阶段发生的错误，但WebFlux的情况并非如此。

回到你的异常传播问题，你分享的文章并不准确。

在反应式应用程序中，请求处理确实可以在任何时候从一个线程跳到另一个线程，所以你不能再依赖“每个请求一个线程”模型了（想想：Threadlocal）。

实际上，您不必考虑异常传播或线程的管理方式。例如，以下样品应等效：

@GetMapping("/test")
public Mono<User> showUser() {
  throw new IllegalStateException("error message!");
}


@GetMapping("/test")
public Mono<User> showUser() {
  return Mono.error(new IllegalStateException("error message!"));
}

Reactor将按照反应流合同中的预期，将这些异常作为错误信号发送（有关更多信息，请参阅“错误处理”文档部分）。