协程

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

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

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

依赖项

当 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 到 Coroutines 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 是 Coroutines 世界中 Flux 的等效项，适用于热流或冷流、有限流或无限流，主要区别如下

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

阅读这篇关于使用 Spring、Coroutines 和 Kotlin Flow 进行 Reactive 的博文，了解更多信息，包括如何使用 Coroutines 并发运行代码。

仓库

这是一个 Coroutines 仓库的示例

interface CoroutineRepository : CoroutineCrudRepository<User, String> {

    suspend fun findOne(id: String): User

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

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

Coroutines 仓库基于 Reactive 仓库，通过 Kotlin 的 Coroutines 公开数据访问的非阻塞性质。Coroutines 仓库上的方法可以由查询方法或自定义实现支持。调用自定义实现方法会将 Coroutines 调用传播到实际实现方法，如果自定义方法是可挂起的，则无需要求实现方法返回 Reactive 类型，例如 Mono 或 Flux。

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

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

只有当仓库扩展 CoroutineCrudRepository 接口时，才会发现 Coroutines 仓库。