协程
Kotlin 协程 是可挂起计算的实例，允许以命令式方式编写非阻塞代码。在语言层面，`suspend` 函数为异步操作提供了一种抽象，而在库层面，kotlinx.coroutines 提供了诸如 `async { }` 之类的函数和 `Flow` 之类的类型。
Spring Data 模块在以下范围内提供对协程的支持
依赖
当类路径中包含 `kotlinx-coroutines-core`、`kotlinx-coroutines-reactive` 和 `kotlinx-coroutines-reactor` 依赖项时，将启用协程支持。
<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 的转换如下：
-
`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 实现响应式 的博文以了解更多详细信息，包括如何使用协程并发运行代码。
仓库
这是一个协程仓库的示例：
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 的协程公开数据访问的非阻塞特性。协程仓库上的方法可以由查询方法或自定义实现支持。如果自定义方法是可挂起的，则调用自定义实现方法会将协程调用传播到实际的实现方法，而不需要实现方法返回响应式类型，例如 `Mono` 或 `Flux`。
请注意，根据方法声明，协程上下文可能可用也可能不可用。要保留对上下文的访问，请使用 `suspend` 声明你的方法，或返回启用上下文传播的类型，例如 `Flow`。
-
`suspend fun findOne(id: String): User`：通过挂起一次同步地检索数据。
-
`fun findByFirstname(firstname: String): Flow<User>`：检索数据流。`Flow` 是急切创建的，而数据是在 `Flow` 交互时（`Flow.collect(…)`）获取的。
-
`fun getUser(): User`：一次检索数据，**阻塞线程**且不进行上下文传播。应避免这种情况。
| 只有当仓库扩展 `CoroutineCrudRepository` 接口时，才会发现协程仓库。 |
