Go连MongoDB需显式设置context超时和ClientOptions,用mongo.Connect()配context.WithTimeout及Ping验证;filter须用bson.M而非JSON字符串;InsertOne后取res.InsertedID;并发操作要用独立子context。

Go 连 MongoDB 最容易卡在驱动初始化和上下文超时上,不是代码写错,而是没设对 context 和 ClientOptions。
怎么用官方驱动建立稳定连接
别直接用 mongo.Connect() 传个地址就完事——它默认不设超时,网络抖动时会卡死几秒甚至更久。必须显式传入带超时的 context.Context,并检查返回错误是否为连接失败而非超时中断。
-
context.WithTimeout(context.Background(), 10*time.Second)是安全底线,低于 5 秒容易误判 -
options.Client().ApplyURI("mongodb://localhost:27017")比手动拼options.Client().SetHosts()更少出错 - 连接后务必调用
client.Ping(ctx, readpref.Primary())验证连通性,光看Connect()不报错不等于能用
为什么 collection.Find() 返回空结果但没报错
常见于 filter 构造错误:Go 的 BSON filter 要用 map[string]interface{} 或 bson.M,不是 JSON 字符串,也不是结构体字面量。MongoDB 不认 Go 的 struct tag(如 json:"name"),只认字段名本身。
- 错:
filter := `{"name": "foo"}`—— 字符串不会被解析,查不到也无提示 - 对:
filter := bson.M{"name": "foo"}或filter := map[string]interface{}{"name": "foo"} - 查 ObjectId 要用
bson.ObjectIdHex("..."),直接写字符串或primitive.ObjectID零值会导致匹配失败
InsertOne 后拿不到插入的 ID 怎么办
InsertOne() 返回的是 *mongo.InsertOneResult,它的 InsertedID 字段才是新文档的 _id。很多人误以为要从传入的 document 里读,或者忽略返回值直接用零值。
立即学习“go语言免费学习笔记(深入)”;
- 插入前 document 里的
_id字段如果为空(primitive.ObjectID("")),服务端会自动生成;否则用你给的值 - 正确取法:
res, err := collection.InsertOne(ctx, doc); id := res.InsertedID - 注意
InsertedID类型是interface{},通常断言为primitive.ObjectID再转字符串
并发写入时出现 context canceled 错误
不是 MongoDB 拒绝连接,而是你的 context 被提前取消了。常见于 HTTP handler 里复用 request context 但没做 timeout 分离,或 goroutine 泄漏导致 context 生命周期混乱。
- 数据库操作要用独立的子 context:
dbCtx, cancel := context.WithTimeout(ctx, 3*time.Second); defer cancel() - 别把 handler 的
ctx直接传给长时后台任务,它可能随请求结束而 cancel -
mongo.Client是线程安全的,可全局复用,但每个操作必须带自己的 context
真正麻烦的从来不是连不上,而是连上了、操作也发出去了,结果因为 context 生命周期、filter 类型、ID 生成逻辑这些细节,数据没写进去、查不出来、还看不出错在哪。


















