在 Go 应用中，为每个数据库操作新建 MongoDB 会话既低效又易引发资源泄漏；推荐复用连接池（如 mgo.Session 或现代 mongo-go-driver 的 Client），并通过依赖注入或服务生命周期统一管理，而非按请求或方法粒度频繁拨号。
在 go 应用中，为每个数据库操作新建 mongodb 会话既低效又易引发资源泄漏；推荐复用连接池（如 `mgo.session` 或现代 `mongo-go-driver` 的 `client`），并通过依赖注入或服务生命周期统一管理，而非按请求或方法粒度频繁拨号。
在构建基于 MongoDB 的 Go 后端服务（如 UserService）时，是否将数据库会话（mgo.Session）作为结构体字段长期持有，是一个典型的性能与可维护性权衡问题。简短回答是：*不建议在 struct 中直接持有 mgo.Session 并手动管理其生命周期，而应升级至官方 mongo-go-driver，并采用 `mongo.Client` 单例 + 连接池模式**——这是当前 MongoDB 官方推荐且生产就绪的最佳实践。
✅ 推荐方案：使用 mongo-go-driver + 全局 Client 实例
mgo 已于 2019 年停止维护，其 Session 设计（需显式 Copy()/Close()）易导致连接泄漏或并发竞争。现代替代方案是官方驱动 go.mongodb.org/mongo-driver/mongo：
import (
"context"
"time"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
// 全局 Client（线程安全，可复用）
var mongoClient *mongo.Client
func initMongo() error {
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
client, err := mongo.Connect(ctx, options.Client().ApplyURI("mongodb://localhost:27017"))
if err != nil {
return err
}
// 可选：验证连接
err = client.Ping(ctx, nil)
if err != nil {
return err
}
mongoClient = client
return nil
}
// UserService 不再持有 session，仅依赖注入 client
type UserService struct {
callingUserID id.ID
collection *mongo.Collection // 按需获取，非持久持有
}
func NewUserService(userID id.ID) *UserService {
return &UserService{
callingUserID: userID,
collection: mongoClient.Database("myapp").Collection("users"),
}
}
func (us *UserService) GetByID(ctx context.Context, usrID id.ID) (*users.User, error) {
var user users.User
err := us.collection.FindOne(ctx, bson.M{"_id": usrID}).Decode(&user)
return &user, err
}
? 关键优势：
- *mongo.Client 是线程安全的、内置连接池（默认最大100连接），自动复用与回收；
- Collection 实例轻量无状态，可安全缓存或按需创建；
- 所有操作通过 context.Context 控制超时与取消，避免阻塞；
- 无需手动 Close() 每个 session，只需在应用退出时调用 mongoClient.Disconnect(ctx)。
⚠️ 若仍需使用 mgo（不推荐，仅作兼容参考）
若因历史原因必须使用 mgo，请避免在每个 UserService 实例中保存 mgo.Session。原因如下：
- mgo.Session 非线程安全，多个 goroutine 并发调用 session.Copy() 或 session.Close() 易出错；
- mgo.Dial() 返回的是一个“主会话”，应仅用于 Copy() 派生短期会话，而非直接执行查询；
- 每次 Copy() 后必须显式 Close()，遗漏即造成连接泄漏。
正确用法示例（不推荐，仅说明原理）：
var globalSession *mgo.Session // 初始化一次，全局复用
func init() {
s, _ := mgo.Dial("mongodb://localhost:27017")
globalSession = s
}
func (us *UserService) GetById(usrId id.ID) *users.User {
session := globalSession.Copy() // 派生新会话
defer session.Close() // 确保释放
coll := session.DB("myapp").C("users")
var user users.User
coll.FindId(usrId).One(&user)
return &user
}
✅ 总结：三原则
- 连接即资源，初始化一次，复用到底 —— 使用 *mongo.Client 单例，而非 per-request Dial；
- 会话（Session）是临时上下文，不是持久状态 —— mgo.Session.Copy() 或 mongo.Client 的 WithContext() 均应短生命周期；
- 解耦依赖，面向接口设计 —— UserService 应接收 *mongo.Collection 或抽象的 UserRepo 接口，便于测试与替换。
遵循此模式，你的服务将具备高并发稳定性、清晰的资源边界和可持续演进的数据访问层。
