跳到主要内容

协程

Doubao 中英对照 Coroutines

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

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

依赖​

当 classpath 中存在 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>
xml
备注

支持的版本为 1.7.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 走向响应式的博客文章以了解更多细节，包括如何使用协程并发运行代码。

仓库​

以下是一个协程仓库的示例：

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

协程仓库构建在响应式仓库之上，以通过 Kotlin 的协程展现数据访问的非阻塞特性。协程仓库上的方法既可以由查询方法支撑，也可以由自定义实现支撑。如果自定义方法是可 suspend-able 的，调用自定义实现方法会将协程调用传播到实际的实现方法，而无需实现方法返回诸如 Mono 或 Flux 之类的响应式类型。

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

  • suspend fun findOne(id: String): User：通过挂起一次性、同步地获取数据。

  • fun findByFirstname(firstname: String): Flow<User>：获取数据流。Flow 是立即创建的，而数据在与 Flow 交互（Flow.collect(…)）时才被获取。

  • fun getUser(): User：一次性获取数据，但会阻塞线程且不进行上下文传播。应避免这种写法。

备注

协程仓库只有在仓库扩展了 CoroutineCrudRepository 接口时才会被发现。