協程

Kotlin 協程是可暫停計算的實例，允許命令式地編寫非阻塞程式碼。在語言方面，suspend 函數為非同步操作提供了一個抽象概念，而在函式庫方面 kotlinx.coroutines 提供了諸如 async { } 的函數以及諸如 Flow 的型別。

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

Deferred 和 Flow 回傳值在 Kotlin 擴充功能中的支援

相依性

當 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 是基於推送的，而 Flux 是推拉混合的
背壓透過暫停函數實現
Flow 只有一個單個暫停 collect 方法，並且運算符被實現為擴充功能
由於協程，運算符很容易實現
擴充功能允許向 Flow 添加自訂運算符
收集操作是暫停函數
map 運算符支援非同步操作（無需 flatMap），因為它接受暫停函數參數

閱讀這篇關於使用 Spring、協程和 Kotlin Flow 實現反應式程式設計的部落格文章以了解更多詳細資訊，包括如何使用協程並行執行程式碼。

Repositories (儲存庫)

這是一個協程儲存庫的範例

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 的，則調用自訂實作方法會將協程調用傳播到實際的實作方法，而無需實作方法傳回諸如 Mono 或 Flux 之類的反應用型別。

請注意，根據方法宣告，協程上下文可能可用也可能不可用。為了保留對上下文的存取權，請使用 suspend 宣告您的方法，或傳回啟用上下文傳播的型別，例如 Flow。

suspend fun findOne(id: String): User：暫停並同步檢索資料一次。
fun findByFirstname(firstname: String): Flow<User>：檢索資料流。 Flow 是急切建立的，而資料是在 Flow 互動 (`Flow.collect(…)`). 時獲取的。
fun getUser(): User：檢索資料一次，**阻塞線程** 且不進行上下文傳播。應避免這樣做。

僅當儲存庫擴展 CoroutineCrudRepository 介面時，才會發現協程儲存庫。