文档中心

文档数据库 MongoDB 版

数据安全

客户端使用 SSL 加密连接 MongoDB

文档数据库 MongoDB 版提供了 SSL（Secure Sockets Layer）加密服务，您可以提前开启 SSL 加密功能，在连接数据库时，通过设置 SSL 加密提高数据链路的安全性。本文介绍多语言客户端通过 SSL 加密连接来访问 MongoDB 数据库的具体方法。

前提条件

MongoDB 实例已开启 SSL 加密功能，详情请参见设置 SSL 加密。

已将安装了客户端的本地服务器或 ECS 实例的 IP 地址加入到 MongoDB 实例的白名单中。详细操作步骤，请参见设置白名单。

注意事项

通过私网访问 MongoDB 实例相对较安全，一般无需对数据链路加密。使用 SSL 加密连接会增加 MongoDB 实例的 CPU 使用率，建议仅在有加密需求（例如通过公网连接数据库）时启用 SSL 加密。

客户端 SSL 连接示例

说明

文档数据库 MongoDB 版支持副本集和分片集群两种实例类型，不同类型的实例提供的连接地址不同。您可以登录 MongoDB 控制台，在连接管理页签下查看并复制所需的连接地址。关于 MongoDB 连接地址的更多说明，请参见连接地址类型。

本文档中示例中均使用了各语言最新版本的客户端。

C ++

Golang

Java

Node.js

.NET Core

PHP

Python

Scala

相关链接：MongoDB C Driver

代码说明

您需要根据如下步骤，在 C 客户端代码中设置如下参数：

在客户端 URI 的末尾增加 ssl=true 参数，表示启用 SSL 加密连接。

您可以通过 mongoc_ssl_opt_t 参数配置 SSL 加密连接。其中：

在 ssl_opts.ca_file 字段中设置 CA 证书的路径。

将 ssl_opts.allow_invalid_hostname 字段设置为 false，表示忽略域名检测。

说明

关于 mongoc_ssl_opt_t 参数的更多说明，请参见 mongoc_ssl_opt_t。

代码示例如下。

mongoc_client_t *client = NULL;

client = mongoc_client_new (
/* 下述代码中以副本集实例私网连接地址为例*/
"mongodb://<user>:<password>@mongoreplicae9d7d321****0.mongodb.ivolces.com:3717,mongoreplicae9d7d321****1.mongodb.ivolces.com:3717/?authSource=admin&replicaSet=rs-mongo-replica-e9d7d321****&retryWrites=true&ssl=true");
const mongoc_ssl_opt_t *ssl_default = mongoc_ssl_opt_get_default ();
mongoc_ssl_opt_t ssl_opts = { 0 };

/* optionally copy in a custom trust directory or file; otherwise the default is used. */
memcpy (&ssl_opts, ssl_default, sizeof ssl_opts);
ssl_opts.ca_file = "/path/to/ca.pem"
ssl_opts.allow_invalid_hostname = false
mongoc_client_set_ssl_opts (client, &ssl_opts);

相关链接：MongoDB Golang Driver、Crypto tls package

代码说明

Golang 驱动程序使用 crypto/tls 包提供的 SSL 底层支持与 MongoDB 服务器进行 SSL 连接。您需要根据如下步骤，在客户端代码中设置 SSL 连接参数：

在客户端 URI 的末尾增加 ssl=true 参数，表示启用 SSL 加密连接。

在 tlsConfig 结构中，设置如下配置：

通过 RootCAs 参数来指定 CA 证书。

将 InsecureSkipVerify 设置为 true，表示忽略域名检测。

代码示例如下。

package main

import (
"context"
"crypto/tls"
"crypto/x509"
"fmt"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
"go.mongodb.org/mongo-driver/mongo/readpref"
"go.mongodb.org/mongo-driver/mongo/writeconcern"
"io/ioutil"
"log"
)

func main() {
var filename = "ca.pem"
rootPEM, err := ioutil.ReadFile(filename)
roots := x509.NewCertPool()
if ok := roots.AppendCertsFromPEM([]byte(rootPEM)); !ok {
fmt.Printf("get certs from %s fail!\n", filename)
return
}
tlsConfig := &tls.Config{
RootCAs: roots,
InsecureSkipVerify: true,
}

// Create a Client to a MongoDB server and use Ping to verify that the server is running.
// 下述代码中以副本集实例私网连接地址为例
clientOpts := options.Client().ApplyURI("mongodb://<user>:<password>@mongoreplicae9d7d321****0.mongodb.ivolces.com:3717,mongoreplicae9d7d321****1.mongodb.ivolces.com:3717/?authSource=admin&replicaSet=rs-mongo-replica-e9d7d321****&retryWrites=true&ssl=true")
clientOpts.SetReadPreference(readpref.Secondary())
clientOpts.SetWriteConcern(writeconcern.New(writeconcern.WMajority(), writeconcern.J(true), writeconcern.WTimeout(1000)))
clientOpts.SetTLSConfig(tlsConfig)
client, err := mongo.Connect(context.TODO(), clientOpts)
if err != nil {
fmt.Println("connect failed!")
log.Fatal(err)
return
}
fmt.Println("connect successful!")

defer func() {
if err = client.Disconnect(context.TODO()); err != nil {
fmt.Println("disconnect failed!")
log.Fatal(err)
}
fmt.Println("disconnect successful!")
}()

// Call Ping to verify that the deployment is up and the Client was configured successfully.
// As mentioned in the Ping documentation, this reduces application resiliency as the server may be temporarily unavailable when Ping is called.
if err = client.Ping(context.TODO(), nil); err != nil {
fmt.Println("ping failed!")
log.Fatal(err)
return
}
fmt.Println("ping successful!")

collection := client.Database("baz").Collection("qux")
res, err := collection.InsertOne(context.Background(), bson.M{"hello": "world"})
if err != nil {
fmt.Println("insert result failed!")
log.Fatal(err)
return
}
id := res.InsertedID
fmt.Println("Id: ", id)
fmt.Printf("insert result: %v\n", res)

result := bson.M{}
filter := bson.D{{"_id", res.InsertedID}}
if err := collection.FindOne(context.Background(), filter).Decode(&result); err != nil {
fmt.Println("find failed!")
log.Fatal(err)
return
}

fmt.Printf("result: %v\n", result)
}

您可以参考如下步骤，通过 .NET Core 驱动程序使用 SSL 加密连接来访问 MongoDB 数据库：

安装 .NET。安装方法，请参见 Download .NET。

执行如下命令创建一个项目（本文示例中项目名录名称为 MongoDB）。

dotnet new console -o MongoDB

cd MongoDB

使用如下命令安装 MongoDB 的 .NET Core 驱动包。

dotnet add package mongocsharpdriver --version 2.11.5

在客户端代码中设置 SSL 连接参数。

代码示例如下。

using System;
using System.Collections.Generic;
using System.Security.Cryptography.X509Certificates;
using MongoDB.Bson;
using MongoDB.Driver;namespace dotnetCase
{
class Program
{
static void Main(string[] args)
{
//MongoDB 实例信息。
const string host1 = "mongoreplicae9d7d321****0.mongodb.ivolces.com";
const int port1 = 3717;
const string host2 = "mongoreplicae9d7d321****1.mongodb.ivolces.com";
const int port2 = 3717;
const string replicaSetName = "rs-mongo-replica-e9d7d321****"; // 分片集群实例连接地址无需设置该参数
const string admin = "admin";
const string userName = "root";
const string passwd = "********";
try
{
// 设置连接 host 信息。
MongoClientSettings settings = new MongoClientSettings();
List<MongoServerAddress> servers = new List<MongoServerAddress>();
servers.Add(new MongoServerAddress(host1, port1));
servers.Add(new MongoServerAddress(host2, port2));
settings.Servers = servers;
// 设置副本集名称（分片集群实例无需设置该参数）。
settings.ReplicaSetName = replicaSetName;
// 设置超时时间为 3 秒。
settings.ConnectTimeout = new TimeSpan(0, 0, 0, 3, 0);
// 设置登录用户名和密码。
MongoCredential credentials = MongoCredential.CreateCredential(admin, userName, passwd);
settings.Credential = credentials;
// 设置 SSL 信息。
SslSettings sslSettings = new SslSettings{
ClientCertificates = new[] {new X509Certificate("ca.pem")},
};
settings.UseTls = true;
settings.AllowInsecureTls = true;
settings.SslSettings = sslSettings;
// 初始化客户端。
MongoClient client = new MongoClient(settings);
}
catch (Exception e)
{
Console.WriteLine("连接异常:"+e.Message);
}
}
}
}

最近更新时间：2026.09.14 16:01:33

这个页面对您有帮助吗？

有用

无用