kotlin余式与反应Spring数据的应用

Question

我正在尝试将一些项目从Spring Reactor迁移到kotlin Coroutines。我有一些基于spring webflux的控制器：

@RestController
class Controller(val productRepository: ProductsRepository) {

    @GetMapping("/product")
    fun find(@RequestParam id: String): Mono<Product> {
        return productRepository.findById(id)
    }
}

此控制器使用reactive spring数据存储库：

@Repository
interface ProductsRepository : ReactiveMongoRepository<Product, String>

根据这份官方文档--https://docs.spring.io/spring/docs/5.2.0.m1/spring-framework-reference/languages.html#how-reactive-translates-to-coroutines，controller中的函数find应该被翻译成suspend fun，并且这个函数应该返回Product类的实例，而不是Product的reactive单包装器。大概是这样的：

@RestController
class Controller(val productRepository: ProductsRepository) {

    @GetMapping("/product")
    suspend fun find(@RequestParam id: String): Product {
        return productRepository.findById(id)
    }
}

但我的productRepository处理的是Mono和Flux，而不是挂起的函数。在那种情况下，我应该如何正确地使用spring数据抽象呢？

Answer 1

这可以通过有用的Kotlinx-Coroutines-Reactor帮助库来实现，该库为项目反应堆Publisher提供了有用的扩展方法，以帮助将Mono或Flux转换为kotlin Coroutines。

首先添加一个依赖项

 <dependency>
     <groupId>org.jetbrains.kotlinx</groupId>
     <artifactId>kotlinx-coroutines-reactor</artifactId>
 </dependency>

（如果您使用spring-boot，您不必指定一个版本，因为它可以为您管理它）

@RestController
class Controller(val productRepository: ProductsRepository) {

    @GetMapping("/product")
    suspend fun find(@RequestParam id: String): Product? {
        return productRepository.findById(id).awaitFirstOrNull()
    }
}