在 Go Web 开发中，为每个 HTTP 请求新建并关闭 MongoDB 连接既低效又违背连接池设计初衷；正确做法是全局复用 mgo.Session（或现代驱动如 mongo-go-driver 的 Client），通过 Copy() 派生请求级会话，并在请求结束时调用 Close() 释放资源。
在 go web 服务中，为每个 http 请求新建并关闭 mongodb 连接既低效又违背连接池设计初衷；正确做法是全局复用 `mgo.session`（或现代驱动如 `mongo-go-driver` 的 `client`），通过 `copy()` 派生请求级会话，并在请求结束时调用 `close()` 释放资源。
在高并发 Web 场景下，频繁建立和销毁数据库连接会显著拖慢性能、耗尽系统资源，并绕过驱动内置的连接池机制。以 mgo 为例，其 Session 本身即是一个线程安全的连接池抽象——底层维护着多个可复用的 socket 连接。若每次请求都调用 mgo.DialWithInfo()，不仅跳过了连接复用，还会引发大量 TCP 握手/挥手开销，导致响应延迟激增。
✅ 正确模式：全局初始化 + 请求级拷贝 + 延迟关闭
启动时一次性建立主 Session，并在中间件中为每个请求派生独立副本：
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 err
}
globalDBSession = session
return nil
}
// 中间件：绑定租户数据库会话到 context
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
}
// ✅ 派生新会话（轻量级，复用底层连接池）
session := globalDBSession.Copy()
defer session.Close() // ⚠️ 必须 defer，确保请求生命周期结束时释放
db := session.DB(domain) // 切换至租户专属数据库
ctx := context.WithValue(r.Context(), "tenantDB", db)
next.ServeHTTP(w, r.WithContext(ctx))
})
}在 Handler 中直接使用上下文中的 *mgo.Database，无需关心连接管理：
func getUsers(w http.ResponseWriter, r *http.Request) {
db, ok := r.Context().Value("tenantDB").(*mgo.Database)
if !ok {
http.Error(w, "Database session not available", http.StatusInternalServerError)
return
}
var users []SystemUser
err := db.C("system_users").Find(nil).All(&users)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
json.NewEncoder(w).Encode(users)
}⚠️ 关键注意事项：
-
绝不全局
Close()主 Session：globalDBSession.Close()应仅在应用优雅退出时调用（如监听os.Interrupt）。 -
Copy()是廉价操作：它不新建网络连接，而是复用连接池中的空闲连接或创建新连接（受池大小限制），并保证会话隔离性（如读写关注、一致性级别）。 -
defer session.Close()是黄金法则：确保无论 Handler 是否 panic 或提前返回，会话资源均被回收。 -
升级建议：
mgo已停止维护，生产环境推荐迁移到官方mongo-go-driver，其mongo.Client同样支持全局复用 +WithContext()派生操作，API 更现代、错误处理更规范。
总结：连接管理的核心不是“每个请求一个连接”，而是“一个连接池，N 个请求级视图”。通过 Copy() + defer Close() 模式，你既能实现多租户数据库隔离，又能压榨出连接池的最大吞吐能力——这也是该方案带来 40% 响应时间下降的根本原因。
