協程

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

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

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

依賴

當 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 及以上。

響應式 (Reactive) 如何轉換為協程 (Coroutines)？

對於返回值，從響應式 (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 是協程世界中 Flux 的等價物，適用於熱流或冷流、有限流或無限流，主要區別如下

Flow 是基於推送的，而 Flux 是推拉混合模式
背壓 (Backpressure) 透過掛起函式實現
Flow 只有一個掛起方法 collect，運算子則實現為擴充套件函式
得益於協程，運算子易於實現
擴充套件函式允許為 Flow 新增自定義運算子
collect 操作是掛起函式
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>
}

協程 Repository 是基於響應式 Repository 構建的，透過 Kotlin 協程暴露資料訪問的非阻塞特性。協程 Repository 中的方法可以由查詢方法或自定義實現支援。如果自定義方法是可 suspend 的，呼叫自定義實現方法會將協程呼叫傳播到實際的實現方法，而無需實現方法返回響應式型別，如 Mono 或 Flux。

請注意，根據方法的宣告方式，協程上下文可能可用或不可用。要保留對上下文的訪問，請使用 suspend 宣告方法，或返回支援上下文傳播的型別，例如 Flow。

suspend fun findOne(id: String): User: 透過掛起同步地一次性檢索資料。
fun findByFirstname(firstname: String): Flow<User>: 檢索資料流。Flow 在互動（Flow.collect(…)）時急切地建立，並在需要時獲取資料。
fun getUser(): User: 一次性檢索資料，但會阻塞執行緒且不傳播上下文。應避免使用此方式。

只有當 Repository 擴充套件 CoroutineCrudRepository 介面時，才會發現協程 Repository。