时间戳

首页 > 解决方案 > Kotlin Coroutines 是否有一个好的库可以异步访问 Mongo？

mongodb - Kotlin Coroutines 是否有一个好的库可以异步访问 Mongo？

问题描述

我正在 JVM 中启动一个具有大量 IO 的新项目。在某些时候，我必须在 Mongo 数据库中保存一些东西。我的想法是对 Kotlin 协程使用非阻塞方法。

我知道 Mongo 有一个官方的响应式流驱动程序，并且支持看起来不错。但在这种情况下，我需要在流和协程之间“创建桥梁”。我的问题是关于这一点：有人知道更好或更简单的方法吗？

标签： mongodbasynchronouskotlinnonblockingkotlin-coroutines

解决方案

看看KMongo 项目。它有协程支持：

import org.litote.kmongo.reactivestreams.*  //NEEDED! import KMongo reactivestreams extensions
import org.litote.kmongo.coroutine.* //NEEDED! import KMongo coroutine extensions

data class Jedi(val name: String, val age: Int)

val client = KMongo.createClient().coroutine //use coroutine extension
val database = client.getDatabase("test") //normal java driver usage
val col = database.getCollection<Jedi>() //KMongo extension method

//async now
runBlocking {
    col.insertOne(Jedi("Luke Skywalker", 19))

    val yoda : Jedi? = col.findOne(Jedi::name eq "Yoda")

    (...)
}

推荐阅读