Spring Boot WebFluxendpoint使用哪个CoroutineScope

Question

在Spring Boot WebFlux应用程序中，我们有许多endpoint（REST和GraphQL)，它们返回某物的mono或flux。这些endpoint调用的代码都是非阻塞的，但是我们不是使用reactor，而是使用Kotlin Coroutines来编写所有这些非阻塞的代码。我们可以使用诸如kotlinx.coroutines.reactor.mono()这样的方法将我们的协程包装在mono（以及用于flux结果的相应flux()方法）中。

然而，为了调用这些方法，我们首先需要一个coroutineScope来包装整个请求（并处理诸如取消主“入口点”coroutine启动的任何子coroutine之类的事情）。这里似乎有几种选择。例如，我们可以构造一个新的coroutineScope并选择一个调度器，例如coroutineScope(dispatchers.default).mono{...。或者我们可以构造自己的类来表示整个HTTP请求，并让它实现coroutineScope，如这里所示的Android活动。

这个问题中隐含的是工作应该在什么线程（或线程池）上执行的选择。我们可以自己创建一个线程池，但是Spring Boot WebFlux已经创建了自己的线程池，用于在非阻塞环境中处理HTTP请求，所以也许尝试留在当前线程中（或者留在那个线程池中）会更好？如果这是最好的方法，那么有没有一种方法可以获得线程池并使coroutine在其上运行呢？

Answer 1

由于在Spring WebFlux中，HTTP交换不是针对特定线程的，globalscope.mono(dispatchers.unincontined)可能是最好的选择。

请注意，dispatchers.uncontined是一个实验性API，以及将受到惰性可迭代流深刻影响的Coroutines通道API。所以我建议您等待Spring官方对任何生产代码的Coroutines的支持。