我正在編寫一個使用 mongo-driver 連接到 mongo 副本集的 Go 應用程序。我注意到mongo.Connect實際上并沒有連接到數據庫。即使我關閉了mongod實例，mongo.Connect仍然可以通過。但是，當我進行查詢時，它將連接到mongod實例?，F在我的問題是我對同一mongod實例中的不同數據庫有很多（> 100）并發查詢。驅動程序創建了一大堆連接并且因為連接太多而使mongod我失敗，即使我使用單個.Too many files openedmongo.Client這是 mongo_driver 的正確行為嗎？我該如何處理？MongoDB 是否需要每個數據庫的每個連接？
1 回答
慕妹3146593
TA貢獻1820條經驗 獲得超9個贊
mongo.Connect()創建一個新的mongo.Client并初始化它，但不（必然）創建到數據庫服務器的連接。
要實際創建連接并檢查服務器是否可訪問（不執行查詢），您可以使用該Client.Ping()方法。如果服務器不可訪問，這將返回錯誤。
官方的 mongodb 驅動程序管理一個內部連接池。連接在使用后不會立即關閉，而是將它們放回池中，因此當需要連接來執行操作時，可以立即使用池中的空閑連接。這是預期的行為。您可以通過options.ClientOptions傳遞給mongo.Connect().
見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
- 1 回答
- 0 關注
- 190 瀏覽
添加回答
舉報
0/150
提交
取消