标签：java spring spring-webflux project-reactor

我正在尝试使用WebFlux,我看到的行为我不太明白,我怀疑这是WebFlux或可能是Reactor的错误,但我需要确认.

我试图创建一个最小可重现的案例,它由一个非常简单的HandlerFunction组成,它试图返回200响应,但在创建体时抛出异常,然后尝试使用onErrorResume代替返回404响应.

处理程序如下所示：

public Mono<ServerResponse> reproduce(ServerRequest request){
        return ServerResponse.ok()
        .contentType(APPLICATION_JSON)
        .body(Mono.fromCallable(this::trigger),String.class)
        .onErrorResume(MinimalExampleException.class,e->ServerResponse.notFound().build());
}

我希望在调用关联的端点时我会收到404响应.相反,我所看到的是一个带有日志消息的500响应,表明Spring认为在请求处理期间存在未处理的异常.

当我在onErrorResume内部断点时,我看到两个处理程序正在注册,我在上面的方法中注册了一个处理程序,以及一个由Spring(在RouterFunctions.toHttpHandler内部)注册的ResponseStatusException实例.然后在处理请求期间,我只看到第二个处理程序(由Spring注册的处理程序)被调用,而不是在抛出的异常上匹配,然后进入根级处理程序.

接近我可以说,Spring在路由器级别覆盖了ErrorResume,阻止了我在Handler中注册的那个被调用.这是预期的行为吗？有没有更好的方法来完成我正在尝试的东西？

解决方法:

框架确实有一个“全能”,在随后的任何内容之前调用.可以调用.body(…).这是设计的,我认为很难避免.

我看到3个解决方案：

>转动操作链

像这样：

return Mono.fromCallable(this::trigger)
           .flatMap(s -> ServerResponse.ok()
                        .contentType(MediaType.TEXT_PLAIN)
                        .syncBody(s))
           .onErrorResume(MinimalExampleException.class,
                        e -> ServerResponse.notFound().build());

>使用ResponseStatusException

您可以将onErrorResume放在与fromCallable()(在body调用内)相同的级别,以通过error mono将特定错误转换为ResponseStatusException：

Mono.fromCallable(this::trigger)
    .onErrorResume(MinimalExampleException.class,
        e->Mono.error(new ResponseStatusException(404, "reason message", e)))

>使用异常处理程序

您应该能够使用@ExceptionHandler注释一个方法来处理您的特定异常.

标签：java,spring,spring-webflux,project-reactor
来源： https://codeday.me/bug/20190519/1133314.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。