在 Go Web 开发中，为每个 HTTP 请求单独建立并关闭 MongoDB 连接（如使用 mgo）不仅低效，还会绕过连接池机制、增加延迟、损害可测试性与可维护性；推荐复用全局会话并按需派生副本，结合 Context 传递数据存储实例。
在 go web 服务中，为每个 http 请求单独建立并关闭 mongodb 连接（如使用 mgo）不仅低效，还会绕过连接池机制、增加延迟、损害可测试性与可维护性；推荐复用全局会话并按需派生副本，结合 context 传递数据存储实例。
在多租户 SaaS 架构中，常见需求是根据请求头（如 Client-Domain）动态路由到对应租户数据库（如 app-com、client-x），同时保证租户间数据隔离。此时，一个直观但危险的想法是：“每个请求 dial 一次，处理完 close 一次”。这在实践中应被明确避免。
❌ 为什么不应每请求新建连接？
-
违背连接池设计初衷：mgo（及现代驱动如
mongo-go-driver）的Session内置连接池，DialWithInfo创建的 session 是线程安全、可复用的“会话工厂”。频繁Dial/Close会导致：- TCP 握手与认证开销重复发生；
- 无法复用空闲连接，连接数激增，易触发数据库连接数上限；
-
mgo.DialWithInfo每次调用都会新建底层 socket 连接池，而session.Copy()才是轻量级、可并发使用的会话副本（参见 mgo session.go#L195）。
-
架构与工程问题：
- 数据库逻辑分散在各 handler 中，难以统一监控、注入 mock（影响单元测试）；
- 无法实现连接超时、重试、指标埋点等横切关注点；
-
defer db.Close()在中间件中不可靠（如 panic 未捕获、goroutine 泄漏、或next()未执行），导致连接泄露。
✅ 推荐方案：全局 Session + 每请求 Copy + Context 传递
核心原则：*全局初始化一次 `mgo.Session，每次请求通过.Copy()获取隔离会话副本，并绑定到context.Context` 生命周期内自动清理**。
// 全局变量（建议封装为包级私有+初始化函数）
var globalDBSession *mgo.Session
func initDB() error {
info := &mgo.DialInfo{
Addrs: []string{"localhost:27017"},
Timeout: 10 * time.Second,
Database: "global_auth", // 仅用于认证的全局库
}
session, err := mgo.DialWithInfo(info)
if err != nil {
return fmt.Errorf("failed to dial MongoDB: %w", err)
}
globalDBSession = session
return nil
}
// 应用退出时关闭全局会话（例如 defer 或 signal handler）
func shutdownDB() {
if globalDBSession != nil {
globalDBSession.Close()
}
}
中间件中派生租户专属会话，并确保其生命周期严格匹配请求：
func TenantDBMiddleware(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
domain := r.Header.Get("Client-Domain")
if domain == "" {
http.Error(w, "Missing Client-Domain header", http.StatusBadRequest)
return
}
// ✅ 安全派生：Copy() 返回新会话，独立于全局 session
tenantSession := globalDBSession.Copy()
defer tenantSession.Close() // ✅ 此处 defer 安全：作用域为当前 handler 函数
// 构建租户数据库实例
db := tenantSession.DB(domain)
// 注入 Context（推荐使用 typed key，而非 string）
ctx := context.WithValue(r.Context(), auth.DataStoreKey, &model.DataStore{DB: db})
next.ServeHTTP(w, r.WithContext(ctx))
})
}
Handler 中直接使用，无需关心连接管理：
func getUsers(w http.ResponseWriter, r *http.Request) {
ds, ok := r.Context().Value(auth.DataStoreKey).(*model.DataStore)
if !ok {
http.Error(w, "Database not available", http.StatusInternalServerError)
return
}
var users []SystemUser
// 自动使用租户数据库下的 collection
err := ds.DB.C("system_users").Find(nil).All(&users)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
json.NewEncoder(w).Encode(users)
}
⚠️ 关键注意事项
-
永远不要在 handler 中
Dial：DialWithInfo是重量级操作，应只在启动时执行一次。 -
.Copy()是廉价的，.Close()必须成对调用：每个Copy()必须有对应的Close()，否则连接泄漏；defer在中间件函数内是安全且推荐的。 - *避免全局 `mgo.Session
直接使用**：它不是并发安全的写操作载体（读操作可共享），所有业务操作必须基于Copy()` 后的会话。 -
升级建议：
mgo已停止维护，生产环境强烈推荐迁移到官方mongo-go-driver，其Client本身即连接池，Database/Collection实例完全无状态，天然支持多租户动态切换：client := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://...")) db := client.Database(domain) // 零成本，纯逻辑切换
总结
每请求新建数据库连接是典型的反模式，牺牲性能、稳定性与可维护性。正确做法是：一次初始化、多次复制、上下文传递、作用域清理。该模式不仅适用于 mgo，也适用于 SQL 数据库（如 sql.DB 本身即连接池）和现代 NoSQL 驱动。它使代码更简洁、测试更可靠、扩展更平滑——尤其在多租户、微服务场景下，是构建高可用 Go 后端的基石实践。
