使用Kotlin Coroutines的Spring Boot Rest服务

Question

我在Kotlin写一个Spring引导Rest服务。我想使用coroutines作为Webflux的替代方案来实现非阻塞异步行为。我正在使用Spring Boot2.1，并且知道我无法实现真正的非阻塞行为，因为我正在controller处阻塞。然而，在Spring Boot2.2普遍可用之前，我现在对此没有意见。

我的应用是三层ie控制器->服务->存储库。在repository中，我正在调用其他服务（即网络调用），并已将该方法标记为Suspend。

我想确保这是正确的方法，另外，调用在resourceService中挂起fun是否会阻塞调用方线程？

此外，在阅读了Roman Elizarov的https://medium.com/@Elizarov/blocking-threads-suspending-coroutines-d33e11bf4761之后，我不确定是否应该使用withcontext以及所有的挂起函数？

package my.springbootapp

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.asCoroutineDispatcher
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.withContext
import mu.KotlinLogging
import org.springframework.boot.SpringApplication
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.stereotype.Repository
import org.springframework.stereotype.Service
import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.PathVariable
import org.springframework.web.bind.annotation.RestController
import java.util.concurrent.Executors

val logger = KotlinLogging.logger { }

@SpringBootApplication
class App

fun main(args: Array<String>) {
    SpringApplication.run(App::class.java, *args)
}

@RestController
class Controller(private val resourceService: ResourceService) {
    private val dispatcher = Executors.newFixedThreadPool(5).asCoroutineDispatcher()

    @GetMapping("/resource/{id}")
    fun getResource(@PathVariable("id") id: String) = runBlocking(dispatcher) {
        resourceService.get(id).also { logger.info { Thread.currentThread().name + "Returning $it" } }
    }
}

@Service
class ResourceService(private val networkResourceRepository: NetworkResourceRepository) {

    suspend fun get(id: String): Resource {
        logger.info { Thread.currentThread().name + "Getting resource" }
        return networkResourceRepository.get(id)
    }
}

@Repository
class NetworkResourceRepository {
    suspend fun get(id: String): Resource = withContext(Dispatchers.IO) {
        logger.info { Thread.currentThread().name + "Getting resource from n/w" }
        //IO operation
        Resource("resource data")
    }
}

data class Resource(val data: String)

Answer 1

我认为你应该使用coroutines与WebFlux但不是代替WebFlux。要将WebFlux与coroutines一起使用，必须添加WebFlux包装器，使WebFlux可挂起。webflux+coroutine示例本身coroutines不会使您的代码不阻塞，coroutines的目标是它们可以只是挂起。这个包装器只是调用webclient上的一些areyoufinished方法（例如），如果它还没有完成，那么coroutine将挂起，并且它将在将来尝试调用相同的方法（通过在将来的执行中传递未到达的代码）。