協程

Kotlin 協程是可掛起計算的例項，允許以命令式方式編寫非阻塞程式碼。在語言層面，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 及更高版本。

響應式如何轉換為協程？

對於返回值，響應式 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 新增自定義運算子
收集操作是掛起函式
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 的協程暴露資料訪問的非阻塞特性。協程倉庫上的方法可以透過查詢方法或自定義實現支援。如果自定義方法是可掛起的 (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 介面時，協程倉庫才會被發現。