Spring @Async 与 Spring WebFlux

如何解决Spring @Async 与 Spring WebFlux

我正在尝试使用 WebFlux 转换以下方法以避免在同一方法上使用 @Async。

@Async
@Override
public void notifyCallback(NotifyCallbackRequest request,String id) {

        startProcess(id);

}

控制器类：

@ResponseStatus(HttpStatus.OK)
@PostMapping("/notify-status/{id}")
public void notifyCallback(@PathVariable("id") String id,@RequestBody NotifyCallbackRequest request) {
    identityService.notifyCallback(request,id);
}

startProcess(id) 是一种通过 webflux 进行 api 调用并返回 Mono 类型的方法。 我感兴趣的是，不管接下来发生什么，调用者都会立即收到 ResponseStatus (HttpStatus.OK)。

解决方法

您可以独立于主反应链订阅“异步”任务，以便在端点被调用后立即开始使其在后台运行。

@Override
public void notifyCallback(NotifyCallbackRequest request,String id) {
        startProcess(id).subscribe();
}

@ResponseStatus(HttpStatus.OK)
@PostMapping("/notify-status/{id}")
public Mono<Void> notifyCallback(@PathVariable("id") String id,@RequestBody NotifyCallbackRequest request) {
    identityService.notifyCallback(request,id);
    return Mono.empty();
}

您可以使用以下端点示例演示此行为。如果您调用端点，它将立即 200 并且 10 秒后它将登录到您的控制台

@RequestMapping(path = "/async",method = RequestMethod.GET)
public Mono<Void> start() {
    Mono.delay(Duration.ofSeconds(10))
            .doOnNext(i -> LOGGER.info("we have waited 10 seconds"))
            .subscribe();

    return Mono.empty();
}