協程

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

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

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

依賴項

當類路徑中包含 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 如何轉換為協程？

對於返回值，從 Reactive 到協程 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 轉向響應式的部落格文章，瞭解更多詳情，包括如何使用協程併發執行程式碼。

Repository

這裡是一個協程 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 互動時（Flow.collect(…)）獲取。
fun getUser(): User：一次性檢索資料，會阻塞執行緒，且沒有上下文傳播。應該避免這種情況。

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