文档菜单
文档首页
/
语言
/
Kotlin
/
Kotlin 同步驱动器

连接到 MongoDB

本页面内容

  • 概述
  • 示例应用程序
  • 连接
  • 本地部署
  • Atlas
  • 副本集
  • 传输层安全 (TLS)
  • 启用 TLS
  • 禁用主机名验证
  • 网络压缩
  • 压缩算法
  • zlib 压缩级别
  • 服务器选择
  • 稳定 API

概述

本页面包含代码示例，展示如何使用 Kotlin 同步驱动器通过指定各种设置将应用程序连接到 MongoDB。

提示

连接选项

要了解本页面中关于连接选项的更多信息，请参阅每个部分提供的链接。您还可以查看指定连接选项指南以了解更多信息。

要从本页复制一个连接示例，请将代码示例复制到示例应用程序或您自己的应用程序中。请确保用您MongoDB部署的相关值替换代码示例中的所有占位符，例如<hostname>。

示例应用程序

您可以使用以下示例应用程序来测试本页上的代码示例。要使用示例应用程序，请执行以下步骤

  1. 确保您已经在您的Maven或Gradle项目中安装了Kotlin Sync驱动程序。

  2. 复制以下代码并将其粘贴到一个新的.kt文件中。

  3. 从本页复制一个代码示例并将其粘贴到文件中的指定行。

1import com.mongodb.kotlin.client.MongoClient
2import org.bson.Document
3
4fun main() {
5
6    // Start example code here
7
8    // End example code here
9
10    val database = mongoClient.getDatabase("admin")
11
12    val command = Document("ping", 1)
13    val commandResult = database.runCommand(command)
14    println("Pinged your deployment. You successfully connected to MongoDB!")
15}

连接

以下部分描述了如何连接到不同的目标，例如MongoDB的本地实例或在Atlas上托管的云实例。

本地部署

以下代码显示了连接到MongoDB本地实例的连接字符串

val uri = "mongodb://localhost:27017/"
val mongoClient = MongoClient.create(uri)

Atlas

以下代码显示了连接到Atlas上部署的连接字符串

val uri = "mongodb+srv://<db_username>:<db_password>@<hostname/port>/?<options>"
val mongoClient = MongoClient.create(uri)

副本集

以下代码显示了连接到副本集的连接字符串

val uri = "mongodb://<replica set member>:<port>/?replicaSet=<replica set name>"
val mongoClient = MongoClient.create(uri)

传输层安全（TLS）

以下部分描述了如何在启用TLS协议的情况下连接到MongoDB。有关在Kotlin Sync驱动程序中使用TLS的更多信息，请参阅在连接上启用TLS。

启用TLS

以下选项卡展示了如何在连接上启用TLS

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection string>"))
    .applyToSslSettings { builder ->
        builder.enabled(true)
    }
    .build()
val mongoClient = MongoClient.create(settings)
val uri = "mongodb+srv://<db_username>:<db_password>@<cluster-url>?tls=true"
val mongoClient = MongoClient.create(uri)

要了解更多关于启用TLS的信息，请参阅TLS配置指南中的启用TLS。

禁用主机名验证

以下选项卡展示了如何在使用TLS连接时禁用主机名验证

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection string>"))
    .applyToSslSettings { builder ->
        builder.enabled(true)
        builder.invalidHostNameAllowed(true)
    }
    .build()
val mongoClient = MongoClient.create(settings);
val uri = "mongodb://<db_username>:<db_password>@<hostname>:<port>/?"tls=true&tlsAllowInvalidHostnames=true"
val mongoClient = MongoClient.create(uri)

网络压缩

以下部分描述了如何在指定网络压缩算法的情况下连接到MongoDB。

压缩算法

以下标签展示了如何在连接到MongoDB时指定所有可用的压缩器

val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString("<connection string>"))
    .compressorList(
        listOf(
            MongoCompressor.createSnappyCompressor(),
            MongoCompressor.createZlibCompressor(),
            MongoCompressor.createZstdCompressor())
    )
    .build()
val mongoClient = MongoClient.create(settings)
val uri = ConnectionString("mongodb+srv://<db_username>:<db_password>@<cluster-url>/?compressors=snappy,zlib,zstd")
val mongoClient = MongoClient.create(uri)

zlib 压缩级别

以下标签展示了如何指定 zlib 压缩器的压缩级别

val zlib = MongoCompressor.createZlibCompressor()
val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString(uri))
    .compressorList(listOf(zlib.withProperty(MongoCompressor.LEVEL, <level>)))
    .build()
val mongoClient = MongoClient.create(settings)
val uri = "mongodb://<db_username>:<db_password>@<hostname>:<port>/?" +
          "compressors=zlib" +
          "zlibCompressionLevel=<zlib compression level>"
val mongoClient = MongoClient.create(uri)

服务器选择

以下代码展示了指定服务器选择函数的连接字符串

val client = MongoClient.create("mongodb://<db_username>:<db_password>@<hostname>:<port>",
                             server_selector=<selector function>)

稳定API

以下代码展示了如何在MongoClientSettings实例中指定稳定API设置

val serverApi = ServerApi.builder()
    .version(ServerApiVersion.V1)
    .build()
val uri = "<connection string>"
val settings = MongoClientSettings.builder()
    .applyConnectionString(ConnectionString(uri))
    .serverApi(serverApi)
    .build()
val client = MongoClient.create(settings)

要了解更多关于稳定API的信息，请参阅稳定API。

返回

下一步

下一步

创建 MongoClient