协程

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

Spring Data 模块为以下范围内的协程提供支持：spring-doc.cn

Kotlin 扩展中的 Deferred 和 Flow 返回值支持spring-doc.cn

依赖

当和 dependencies 位于 classpath 中时，将启用协程支持：kotlinx-coroutines-corekotlinx-coroutines-reactivekotlinx-coroutines-reactorspring-doc.cn

要在 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 如何转换为 Coroutines？

对于返回值，从 Reactive API 到 Coroutines API 的转换如下：spring-doc.cn

fun handler(): Mono<Void>成为suspend fun handler()spring-doc.cn
fun handler(): Mono<T>变为或取决于是否可以为空（具有更静态类型的优势）suspend fun handler(): Tsuspend fun handler(): T?Monospring-doc.cn
fun handler(): Flux<T>成为fun handler(): Flow<T>spring-doc.cn

Flow 在 Coroutines 世界中是等效的，适用于热流或冷流、有限流或无限流，主要区别如下：Fluxspring-doc.cn

Flow是基于推拉的，而是推拉混合的Fluxspring-doc.cn
背压通过挂起功能实现spring-doc.cn
Flow只有一个 suspending collect 方法，并且运算符作为扩展实现spring-doc.cn
借助协程，运算符易于实现 spring-doc.cn
扩展允许将自定义运算符添加到Flowspring-doc.cn
收集操作正在挂起函数spring-doc.cn
map 运算符支持异步操作（不需要），因为它需要一个 suspending 函数参数flatMapspring-doc.cn

有关更多详细信息，包括如何与协程并发运行代码，请参阅这篇关于使用 Spring、Coroutines 和 Kotlin Flow 实现反应式的博文。spring-doc.cn

存储库

以下是 Coroutines 存储库的示例：spring-doc.cn

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 的协程访问数据的非阻塞性质。 Coroutines 存储库中的方法可以由查询方法或自定义实现提供支持。如果自定义方法是 -able，则调用自定义实现方法会将协程调用传播到实际的实现方法，而无需实现方法返回反应式类型，例如 or 。suspendMonoFluxspring-doc.cn

请注意，根据方法声明，协程上下文可能可用，也可能不可用。要保留对上下文的访问，请使用 USING 声明方法，或返回启用上下文传播的类型，例如 .suspendFlowspring-doc.cn

suspend fun findOne(id: String): User：一次检索数据，并通过暂停同步检索数据。spring-doc.cn
fun findByFirstname(firstname: String): Flow<User>：检索数据流。在交互时获取数据时，会急切地创建（）。FlowFlowFlow.collect(…)spring-doc.cn
fun getUser(): User：在阻塞线程后检索数据，无需上下文传播。应避免这种情况。spring-doc.cn

仅当存储库扩展接口时，才会发现协程存储库。CoroutineCrudRepository

协程

依赖

Reactive 如何转换为 Coroutines？

存储 库

存储库