本文介绍在 go 应用中结合 mongodb 唯一索引实现注册去重的最佳实践：无需前置查询，直接插入并捕获重复键错误，再精准区分用户名或邮箱冲突，兼顾性能、原子性与可维护性。
本文介绍在 go 应用中结合 mongodb 唯一索引实现注册去重的最佳实践：无需前置查询，直接插入并捕获重复键错误，再精准区分用户名或邮箱冲突，兼顾性能、原子性与可维护性。
在高并发用户注册场景下，传统“先查后插”（check-then-act）模式存在竞态风险：两个请求几乎同时通过 find 检查（均未发现重复），随后双双 insert 成功，导致数据不一致。更可靠且高效的做法是依赖数据库层的唯一约束保障数据完整性，将校验逻辑下沉至 MongoDB，并在应用层优雅处理冲突。
✅ 步骤一：创建复合唯一索引
首先，为 users 集合建立两个独立的唯一索引——分别作用于 username 和 email 字段：
// MongoDB Shell 示例
db.users.createIndex({ "username": 1 }, { unique: true, name: "username_unique" })
db.users.createIndex({ "email": 1 }, { unique: true, name: "email_unique" })⚠️ 注意：不要合并为 { username: 1, email: 1 } 复合索引——它仅保证组合值唯一，无法防止单独的用户名或邮箱重复。
在 Go 中（以 mgo 为例，若使用 mongo-go-driver 请参考其 Indexes().CreateOne() 方法），推荐在服务启动时调用 EnsureIndex 确保索引存在：
// 初始化时确保索引就绪（仅首次执行，轻量高效）
index := mgo.Index{
Key: []string{"username"},
Unique: true,
Name: "username_unique",
Background: true,
}
err := collection.EnsureIndex(index)
if err != nil {
log.Fatal("Failed to ensure username index:", err)
}
// 同理为 email 创建索引
emailIndex := mgo.Index{
Key: []string{"email"},
Unique: true,
Name: "email_unique",
Background: true,
}
err = collection.EnsureIndex(emailIndex)
if err != nil {
log.Fatal("Failed to ensure email index:", err)
}EnsureIndex 具有幂等性：索引存在时不会发起额外网络请求，性能开销可忽略。
✅ 步骤二：插入并精准识别冲突字段
执行插入操作后，捕获错误并根据 WriteError 的 Code 与 KeyPattern 判断具体冲突字段：
err := collection.Insert(&user)
if err != nil {
if mgo.IsDup(err) {
// mgo v2+ 可通过 err.Error() 或类型断言解析
if strings.Contains(err.Error(), "username_unique") {
return fmt.Errorf("username already exists")
} else if strings.Contains(err.Error(), "email_unique") {
return fmt.Errorf("email already exists")
} else {
return fmt.Errorf("duplicate key violation (unknown field)")
}
}
return fmt.Errorf("database insert failed: %w", err)
}? 更健壮的方式（推荐）：使用 mongo-go-driver 时可进行类型断言获取 mongo.WriteException，进而检查 WriteError.Code == 11000（重复键错误）及 WriteError.KeyPattern 字段名，实现完全解耦于错误消息文本。
✅ 最佳实践总结
- 永远优先使用唯一索引：它是 MongoDB 提供的原子性、高性能、强一致性的去重机制；
- 避免“查—插”两步操作：消除竞态窗口，简化逻辑，降低数据库负载；
- 错误处理需具象化：不泛泛返回“创建失败”，而应明确提示“用户名已被占用”或“邮箱已注册”，提升用户体验与前端校验友好性；
- 索引命名规范化：如 username_unique，便于后续运维排查与监控；
- 上线前验证索引状态：可通过 db.users.getIndexes() 确认索引已生效。
通过这一设计，你不仅解决了重复注册问题，更构建了符合云原生与高并发要求的数据写入范式——让数据库做它最擅长的事，让应用专注业务逻辑。
