Spring@Async vs Spring WebFlux

Question

我正在尝试使用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）。

Answer 1

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

@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();
}

您可以使用以下endpoint示例演示此行为。如果您调用endpoint，它将立即停止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();
}