协程

Kotlin 协程是可挂起计算的实例，允许以命令式方式编写非阻塞代码。在语言层面，suspend 函数为异步操作提供了抽象，而在库层面 kotlinx.coroutines 提供了诸如 async { } 的函数以及诸如 Flow 的类型。

Spring Data 模块在以下范围内提供了对协程的支持

在 Kotlin 扩展中支持 Deferred 和 Flow 返回值

依赖项

当 classpath 中包含 kotlinx-coroutines-core、kotlinx-coroutines-reactive 和 kotlinx-coroutines-reactor 依赖项时，协程支持将被启用

要添加到 Maven pom.xml 的依赖项

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

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

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

支持的版本为 1.3.0 及以上。

响应式如何转换为协程？

对于返回值，从响应式 API 到协程 API 的转换如下

fun handler(): Mono<Void> 变为 suspend fun handler()
fun handler(): Mono<T> 变为 suspend fun handler(): T 或 suspend fun handler(): T?，具体取决于 Mono 是否可以为空（优点是类型更静态化）
fun handler(): Flux<T> 变为 fun handler(): Flow<T>

Flow 是协程世界中的 Flux 等价物，适用于热流或冷流、有限流或无限流，主要区别如下

Flow 是基于推的，而 Flux 是推拉混合的
背压通过挂起函数实现
Flow 只有一个单一的挂起 collect 方法，并且操作符作为扩展实现
由于协程，操作符易于实现
扩展允许向 Flow 添加自定义操作符
Collect 操作是挂起函数
map 操作符支持异步操作（无需 flatMap），因为它接受一个挂起函数参数

阅读这篇关于利用 Spring、协程和 Kotlin Flow 实现响应式编程的博客文章以获取更多详细信息，包括如何使用协程并发地运行代码。

Repositories

下面是一个协程 repository 的示例

interface CoroutineRepository : CoroutineCrudRepository<User, String> {

    suspend fun findOne(id: String): User

    fun findByFirstname(firstname: String): Flow<User>

    suspend fun findAllByFirstname(id: String): List<User>
}

协程 repositories 构建在响应式 repositories 之上，通过 Kotlin 协程暴露数据访问的非阻塞特性。协程 repository 中的方法可以由查询方法或自定义实现支持。调用自定义实现方法会将其协程调用传播到实际的实现方法，前提是自定义方法是可 suspend 的，并且不要求实现方法返回 Mono 或 Flux 等响应式类型。

请注意，协程上下文可能可用也可能不可用，具体取决于方法声明。要保留对上下文的访问，请使用 suspend 声明您的方法，或返回一个支持上下文传播的类型，例如 Flow。

suspend fun findOne(id: String): User: 通过挂起一次性同步检索数据。
fun findByFirstname(firstname: String): Flow<User>: 检索数据流。Flow 会立即创建，而数据则在与 Flow 交互时（Flow.collect(…)）获取。
fun getUser(): User: 一次性检索数据，阻塞线程且不进行上下文传播。应避免这样做。

仅当 repository 扩展了 CoroutineCrudRepository 接口时，才会发现协程 repositories。