我开始在 Kotlin 中开发一个 KMongo 项目,但是当我连接到我的数据库时,KMongo 创建了 2 个连接,而不是一个(看这里的图片)。有人知道为什么吗?
我的班级连接数据库
object Mongo {
lateinit var connectionString: String
lateinit var database: String
private lateinit var mongo: MongoDatabase
fun connect() {
val client = KMongo.createClient(connectionString)
mongo = client.getDatabase(database)
}
fun get(collection: String): CoroutineCollection<Document> {
return this.mongo.getCollection(collection).coroutine
}
}
fun database(database: Mongo.() -> Unit) = Mongo.apply(database)
主要班
fun main() {
Thread {
while (true) {
}
}.start()
database {
connectionString = "mongodb://username:password@host:port/test?w=majority"
database = "Test"
}.also { it.connect() }
}
对于我使用的依赖项
- kmongo 异步
- kmongo协程