使用 mongo.Connect 时连接未打开，而当我执行查询时连接未打开

在使用 mongo-driver 编写 Go 应用程序时，mongo.Connect 实际上不会连接到数据库，即使关闭 mongod 实例也不会报错。然而，在执行查询时，它会连接到 mongod 实例。如果同一 mongod 实例中存在大量并发查询，驱动程序会创建大量连接，导致 mongod 因打开文件过多而失败。这种行为是预期的，官方 mongodb 驱动程序管理内部连接池，连接在使用后会被放回池中，以备下次使用。

我正在使用 mongo-driver 编写一个 Go 应用程序来连接到 mongo 副本集。

我注意到 mongo.Connect 实际上并未连接到数据库。

即使我关闭了 mongod 实例，mongo.Connect 仍然能够通过。

但是，当我执行查询时，它将连接到 mongod 实例。

现在我的问题是我对同一 mongod 实例中的不同数据库有很多（>100）并发查询。

驱动程序创建了一大堆连接，而 mongod 让我失败了 打开了太多文件 因为连接太多，即使我使用单个 mongo.Client。

这是 mongo_driver 的正确行为吗？我该如何处理？

MongoDB 是否需要每个数据库的每个连接？

正确答案

mongo.Connect() 创建一个新的 mongo.Client 并对其进行初始化，但不会（必然）创建与数据库服务器的连接。

要实际创建连接并检查服务器是否可访问（不执行查询），您可以使用 Client.Ping() 方法。如果无法访问服务器，这将返回错误。

官方 mongodb 驱动程序管理内部连接池。连接在使用后不会立即关闭，而是被放回池中，因此当需要连接执行操作时，可以立即使用池中的空闲连接。这是预期的行为。您可以通过传递给 mongo.connect() 的 options.ClientOptions 配置其大小。

参见ClientOptions.SetMaxPoolSize()：

setmaxpoolsize 指定驱动程序连接池中允许到每个服务器的最大连接数。如果达到此最大值，对服务器的请求将被阻止。也可以通过“maxpoolsize”uri 选项（例如“maxpoolsize=100”）进行设置。默认值为 100。如果为 0，则将设置为 math.maxint64。

设置具有有限连接的客户端并对其执行 ping 操作的示例：

ctx := context.Background()

opts := options.Client().
    ApplyURI("mongodb://localhost").
    SetMaxPoolSize(20) // Allow no more than 20 connections per server

client, err := mongo.Connect(ctx, opts)
if err != nil {
    log.Printf("mongo.Connect() failed: %v", err)
    return
}
defer client.Disconnect(ctx)

if err := client.Ping(ctx, nil); err != nil {
    log.Printf("Can't connect to db: %v", err)
    return
}

// Use client

查看相关：goroutine create multiple mongodb connection

好了，本文到此结束，带大家了解了《使用 mongo.Connect 时连接未打开，而当我执行查询时连接未打开》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！