本文详解如何在 Labix mgo 驱动中动态覆盖默认 writeConcern 与 consistency 模式，通过 SetMode 实现关键操作的强一致性（如写后立即读取最新数据），避免因 monotonic 模式导致的读取延迟问题。
本文详解如何在 labix mgo 驱动中动态覆盖默认 writeconcern 与 consistency 模式，通过 `setmode` 实现关键操作的强一致性（如写后立即读取最新数据），避免因 monotonic 模式导致的读取延迟问题。
在使用 labix/mgo 构建 MongoDB 应用时，为提升吞吐量，常将会话（session）配置为 monotonic 一致性模式——即默认从 Secondary 节点读取数据（可用时），写操作则始终发往 Primary。该策略虽利于负载分担，但在“写后立即读”（read-your-write）场景下易引发数据不一致：更新成功后立刻查询，却可能命中尚未同步完成的 Secondary，返回旧值。
幸运的是，mgo 并未将一致性策略硬编码于全局连接，而是支持按 session 粒度动态覆盖。核心机制是 (*Session).SetMode(mode, refresh bool) 方法：
- mode：指定一致性模式，常用值包括：
- mgo.Primary：强制所有读写均路由至 Primary（等效于 mgo.Strong，推荐语义化写法）；
- mgo.Secondary / mgo.SecondaryPreferred：显式指定读取副本节点；
- refresh：若设为 true，调用后会主动刷新连接池，确保后续操作基于最新拓扑状态（尤其在副本集成员变更后至关重要）。
以下为生产就绪的实践示例：
// 假设 masterSession 已初始化并设置为 monotonic 模式
session := masterSession.Copy()
defer session.Close() // 确保资源释放
// 关键：切换为强一致性模式 —— 所有读写均发生在 Primary
session.SetMode(mgo.Primary, true)
collection := session.DB("mydb").C("users")
// 写操作（默认仍走 Primary，但 now with stronger guarantee）
err := collection.Update(bson.M{"_id": "u123"}, bson.M{"$set": bson.M{"status": "active"}})
if err != nil {
log.Fatal("update failed:", err)
}
// 读操作必然从 Primary 获取，保证看到刚写入的数据
var user bson.M
err = collection.FindId("u123").One(&user)
if err != nil {
log.Fatal("read failed:", err)
}
// 此时 user.status == "active"，100% 可靠⚠️ 重要注意事项：
- SetMode 仅影响当前 session 实例，不影响 masterSession 或其他已存在的副本，因此无需担心全局副作用；
- 每次需要强一致性时，务必 Copy() 新会话并显式 SetMode，切勿复用长期存活的 session（其内部状态可能过期）；
- mgo.Primary 模式下，即使 Secondary 不可用，操作也不会降级——若 Primary 不可用则直接报错，符合强一致性语义；
- 若需更细粒度控制（如仅对某次写操作要求多数节点确认），可结合 (*Collection).Bulk() 或 (*Session).SetSafe() 设置 write concern（如 &mgo.Safe{W: 2, WTimeout: 1000}），但 SetMode 是解决“读写一致性”最直接、开销最低的方案。
总结而言，SetMode(mgo.Primary, true) 是 mgo 中实现“写后立即读”的黄金实践：它轻量、明确、无侵入性，且完全兼容 replica set 的高可用架构。合理运用该机制，可在性能与一致性之间取得精准平衡。
