协程

Kotlin 的协程是轻量级的线程，允许以命令式的方式编写非阻塞代码。在语言方面，suspend 函数为异步操作提供了抽象，而在库方面，kotlinx.coroutines 提供了诸如 async { } 之类的函数和诸如 Flow 之类的类型。

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

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

依赖项

当类路径中存在 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 及更高版本。

Reactive 如何转换为协程？

对于返回值，从 Reactive 到协程 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
收集操作是挂起函数
map 运算符支持异步操作（不需要 flatMap），因为它接受一个挂起函数参数

阅读这篇关于使用 Spring、协程和 Kotlin Flow 进行 Reactive 的博文，以获取更多详细信息，包括如何使用协程并发运行代码。

仓库

这是一个协程仓库的示例。

interface CoroutineRepository : CoroutineCrudRepository<User, String> {

    suspend fun findOne(id: String): User

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

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

协程仓库建立在响应式仓库的基础上，通过 Kotlin 的协程暴露数据访问的非阻塞特性。协程仓库上的方法可以由查询方法或自定义实现支持。调用自定义实现方法会将协程调用传播到实际的实现方法，如果自定义方法是可 `suspend` 的，则无需要求实现方法返回响应式类型，例如 `Mono` 或 `Flux`。

请注意，根据方法声明，协程上下文可能可用也可能不可用。要保留对上下文的访问，请使用 `suspend` 声明您的方法，或者返回一个允许上下文传播的类型，例如 `Flow`。

suspend fun findOne(id: String): User：通过挂起一次同步地检索数据。
fun findByFirstname(firstname: String): Flow<User>：检索数据流。`Flow` 在 `Flow` 交互（`Flow.collect(…)`）时被急切地创建，同时数据被获取。
fun getUser(): User：一次性检索数据，**阻塞线程**，并且没有上下文传播。应该避免这种方式。

只有当仓库扩展了 `CoroutineCrudRepository` 接口时，才会发现协程仓库。