通过 SSL 连接到 MongoDB 在 Go 中的实现方法

积累知识，胜过积蓄金银！毕竟在Golang开发的过程中，会遇到各种各样的问题，往往都是一些细节知识点还没有掌握好而导致的，因此基础知识点的积累是很重要的。下面本文《通过 SSL 连接到 MongoDB 在 Go 中的实现方法》，就带大家讲解一下知识点，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

我正在尝试使用 .crt 文件连接到 azure 中托管的 mongo 数据库。

我能够使用命令成功地从我的 linux 机器终端进行连接：

mongo mongodb://username:[email protected]:27017,prod-replicaset-1.com:27017,prod-replicaset-2.com:27017/ --tls --tlscafile rootca.crt --tlsallowinvalidcertificates

我还可以通过设置“使用 ssl 协议”并使用身份验证机制作为“scram-sha-256”从 mongo ui 客户端（如 robo3t）进行连接。 [如果我将身份验证机制设置为任何其他值，则会导致身份验证失败]

但是我无法在 go lang 代码中连接到该数据库。

这是我正在使用的代码示例：

package main

import (
    "crypto/tls"
    "crypto/x509"
    "io/ioutil"
    "log"
    "net"

    "github.com/globalsign/mgo"
)

func initmongo() error {

    rootcerts := x509.newcertpool()
    ca, err := ioutil.readfile("./rootca.crt")
    if err != nil {
        log.fatalf("failed to read file : %s", err.error())
        return err
    }

    success := rootcerts.appendcertsfrompem(ca)
    if !success {
        log.printf("rootcert failed")
    }

    connstr := "mongodb://username:[email protected]:27017,prod-replicaset-1.com:27017,prod-replicaset-2.com:27017/?ssl=true"

    dbdialinfo, err := mgo.parseurl(connstr)
    if err != nil {
        log.fatal("unable to parse url - " + err.error())
    }

    dbdialinfo.dialserver = func(addr *mgo.serveraddr) (net.conn, error) {
        return tls.dial("tcp", addr.string(), &tls.config{
            rootcas:            rootcerts,
            insecureskipverify: true,
        })
    }

    // dbdialinfo.mechanism = "scram-sha-256"

    _session, err := mgo.dialwithinfo(dbdialinfo)
    if err != nil {
        log.fatalf("failed to creating db session : %s", err.error())
        return err
    }

    log.printf("created session - %v", _session)

    return nil
}

当我运行此代码时，出现错误： 无法创建数据库会话：“服务器在 sasl 身份验证步骤上返回错误：身份验证失败。”

如果我在创建会话之前设置 [dbdialinfo.mechanism = "scram-sha-256"]，则会收到错误： 无法创建数据库会话：“构建期间未启用 sasl 支持（-tags sasl）”

请告诉我导致此问题的原因，如何连接到数据库。 目前我正在使用“github.com/globalsign/mgo”，如果需要使用任何其他库，这对我来说完全没问题。 我只想连接到数据库。

rootca.crt 文件看起来像：

-----BEGIN CERTIFICATE-----
MIIGLjCCBBagAwIBAgIUbxINX1qe6W+7kolWGp+MX8NbYj8wDQYJKoZIhvcNAQEL
         
jCZAGGHmbrR3zeIsOY8yKau0IXqRp5Wy6NQ0poOTcma9BfwNUVc4/ixsCkEVYbgW
eMs=
-----END CERTIFICATE-----

谢谢。

正确答案

经过大量研究后，我无法找到使用 globalsign 库使用 .crt 文件连接到 mongodb 的方法。

但是我使用 mongo-driver 库成功地做到了这一点。 这里连接字符串的格式可以是：

mongodb://user:[email protected]:27017,replicaset-1.com:27017,replicaset-2.com:27017/?ssl=true&tlscafile=./ca.crt&tlscertificatekeyfile=./ca.pem&authsource=admin&replicaset=replicaset

示例代码：

import (
    "context"
    "log"
    "os"

    // "github.com/globalsign/mgo"
    mgo "go.mongodb.org/mongo-driver/mongo"

    mongoOptions "go.mongodb.org/mongo-driver/mongo/options"
)
func InitMongo() (error) {
    
    connStr := os.Getenv("MONGODB_CONN_STR")
    dbName := os.Getenv("MONGODB_DATABASE")

    clientOpts := mongoOptions.Client().ApplyURI(connStr)
    if err := clientOpts.Validate(); err != nil {
        log.Print("unable to parse url")
        log.Fatal(err)
    }
    client, err := mgo.Connect(context.TODO(), clientOpts)
    if err != nil {
        log.Print("unable to connect into database")
        log.Fatal(err)
    }
    if err := client.Ping(context.TODO(), nil); err != nil {
        log.Print("database ping failed")
        log.Fatal(err)
    }

    //client.Database(dbName)

    return nil
}

好了，本文到此结束，带大家了解了《通过 SSL 连接到 MongoDB 在 Go 中的实现方法》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！