協程

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

反應式如何轉換為協程？

對於回傳值，從反應式到協程 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 的等效項，適用於熱流或冷流、有限或無限流，具有以下主要差異

閱讀這篇關於 使用 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 的協程公開資料存取的非阻塞特性。協程儲存庫上的方法可以由查詢方法或自訂實作支援。如果自訂方法是可暫停的，則調用自訂實作方法會將協程調用傳播到實際的實作方法，而無需實作方法返回諸如 Mono 或 Flux 之類的反應用類型。

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

  • suspend fun findOne(id: String): User：暫停並同步檢索資料一次。

  • fun findByFirstname(firstname: String): Flow<User>：檢索資料流。Flow 是預先建立的，而資料是在 Flow 交互 (Flow.collect(…)) 時提取的。

  • fun getUser(): User：檢索資料一次，阻塞線程且不進行上下文傳播。應避免這樣做。

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