協程

Kotlin 協程 是可掛起計算的例項，允許以命令式方式編寫非阻塞程式碼。在語言層面，suspend 函式為非同步操作提供了抽象，而在庫層面，kotlinx.coroutines 提供了諸如 async { } 的函式和諸如 Flow 的型別。

Spring Data 模組在以下範圍提供對協程的支援

  • Deferred 和 Flow 返回值在 Kotlin 擴充套件中的支援

依賴

當 classpath 中包含 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 及更高。

響應式如何轉換為協程？

對於返回值，從響應式到協程 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 是基於推（push-based），而 Flux 是推拉混合（push-pull hybrid）

  • 背壓（Backpressure）透過掛起函式實現

  • Flow 只有一個 掛起 collect 方法，並且運算子是作為 擴充套件 實現的

  • 得益於協程，運算子易於實現

  • 擴充套件允許為 Flow 新增自定義運算子

  • 收集操作（Collect operations）是掛起函式

  • map 運算子 支援非同步操作（無需 flatMap），因為它接受一個掛起函式引數

閱讀這篇關於 使用 Spring、協程和 Kotlin Flow 實現響應式程式設計 的部落格文章，瞭解更多詳情，包括如何使用協程併發執行程式碼。

Repositories

這是一個協程 Repository 的示例

interface CoroutineRepository : CoroutineCrudRepository<User, String> {

    suspend fun findOne(id: String): User

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

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

協程 Repositories 構建於響應式 Repositories 之上，透過 Kotlin 協程暴露資料訪問的非阻塞特性。協程 Repository 中的方法可以由查詢方法或自定義實現支援。如果自定義方法是 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: 一次性獲取資料，阻塞執行緒且不帶上下文傳播。應避免使用此方式。

僅當 Repository 擴充套件 CoroutineCrudRepository 介面時，才能發現協程 Repositories。