協程

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 的轉換如下

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 實現反應式的部落格文章，以了解更多詳細資訊，包括如何使用協程並行執行程式碼。

儲存庫

以下是協程儲存庫的範例

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` 介面時，才會發現協程儲存庫。