如何使用 mongodb 3.6 中的新 URL 从 golang 进行连接

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《如何使用 mongodb 3.6 中的新 URL 从 golang 进行连接》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

我尝试使用 golang 驱动程序连接到 mongodb atlas。

tlsconfig := &tls.config{}

var mongouri = "mongodb+srv://admin:[email protected]:27017/dbname"
dialinfo, err := mgo.parseurl(mongouri)
if err != nil {
    panic(err)
}
dialinfo.dialserver = func(addr *mgo.serveraddr) (net.conn, error) {
    conn, err := tls.dial("tcp", addr.string(), tlsconfig)
    return conn, err
}

session, err := mgo.dialwithinfo(dialinfo)
if err != nil {
    println("error")
    log.fatal(err)
}
_ = session
c := session.db("token").c("_users")
user := &user{firstname: "username"}
err = c.insert(user)
if err != nil {
    println("error again")
}

我没有收到未连接的错误消息。 我想知道可能是什么原因。 如有任何帮助，我们将不胜感激。

我尝试使用下面的代码创建 dialinfo

dialInfo := &mgo.DialInfo{
    Addrs:     []string{"prefix.mongodb.net:27017"},
    Database:  "dbname",
    Mechanism: "SCRAM",
    Timeout:   10 * time.Second,
    Username:  "admin",
    Password:  "passwrd",
}

现在我无法访问服务器

解决方案

正如您所了解的，这是因为默认情况下 DialInfo 的超时时间为零。该调用将永远阻塞，等待建立连接。您还可以使用以下方式指定超时：

dialinfo.timeout = time.duration(30)
session, err := mgo.dialwithinfo(dialinfo)

这是因为 globalsign/mgo 目前尚不支持 srv connection string URI。见issues 112。 您可以使用非srv连接uri格式（mongodb v3.4），参见相关问题StackOverflow: 41173720。

如果您想使用 srv 连接 uri 进行连接，则可以使用 mongo-go-driver，例如：

mongoURI := "mongodb+srv://admin:[email protected]/dbname?ssl=true&retryWrites=true"

client, err := mongo.NewClient(options.Client().ApplyURI(mongoURI))
if err != nil {
    log.Fatal(err)
}
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
err = client.Connect(ctx)
defer client.Disconnect(ctx)

if err != nil {
    log.Fatal(err)
}
database := client.Database("go")
collection := database.Collection("atlas")

以上示例兼容当前版本v1.0.0

今天关于《如何使用 mongodb 3.6 中的新 URL 从 golang 进行连接》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！