java - Webflux Mono - 继续运行直至完成

Question

我有一个函数可以做很多事情并最终返回一个Mono。

如果我有这样的处理程序:

fun handleSomething(request: ServerRequest): Mono<ServerResponse> {
  return longRunningMethod().flatMap {
    ServerResponse.ok.build()
  }
}

这可以工作，但在完成长时间运行的方法之前它不会返回响应。

我想做的是启动长时间运行的方法，但立即返回响应，如下所示:

fun handleSomething(request: ServerRequest): Mono<ServerResponse> {
  longRunningMethod()

  return ServerResponse.ok.build()
}

问题在于，一旦发送响应(基本上是立即)，它似乎就中止了 longRunningMethod()。

有没有办法让 longRunningMethod() 保持运行直到它实际完成，即使请求已完成？

Answer 1

很难确定，因为我们在这里缺少很多上下文。

但我认为该任务(似乎正在生成报告)与 Controller 没有严格链接，这可能不属于这里。相反，您可以从 Controller 发送应用程序事件并让事件监听器处理它。

默认情况下，事件在当前线程中处理，因此您必须确保使用该 ApplicationEventMulticaster 配置一个 Executor。最后，从 HTTP 的角度来看，是否生成报告似乎并不重要，因此您可以将它们完全解耦。

理论上，您可以执行longRunningMethod().subscribe()，但在没有检查的情况下从 Controller 运行这种副作用感觉不太正确。而且测试起来也会更加困难。