java - Spring MVC 异步方法 (RXJava)

Question

编辑:我的答案如下

我有一个特定的场景，我可以使用一些指导。我有一个 POST 端点，我想调用一些异步方法(我不关心其结果，因此它们是无效的)，并立即返回给用户。例如:

@RequestMapping(value = "/", method = RequestMethod.POST)
public ResponseEntity subscribe(@RequestBody SomePayload payload) {
    CompletableFuture.runAsync(() -> someService.longRunningVoidMethod(payload));
    return new ResponseEntity(HttpStatus.OK);
}

有没有办法使用 RXJava 来做到这一点(我正在开发的 API 使用 RXJava，所以我想遵循与其余部分相同的模式)？比如，一个不发射任何东西的 Observable？我对 RXJava 非常陌生，因此我正在寻求一些更具体的建议，而我自己正在努力阅读这些建议。

谢谢!

Answer 1

明白了...

@RequestMapping(value = "/", method = RequestMethod.POST)
public ResponseEntity subscribe(@RequestBody SomePayload payload) {
    Completable.fromAction(() -> someService.longRunningVoidMethod(payload))
           .subscribeOn(Schedulers.io())
           .subscribe();
    return new ResponseEntity(HttpStatus.OK);
}

我猜 .subscribeOn(Schedulers.io()) 使函数在后台任务上执行，而不是等待它完成后再继续。