MongoDB跨集合转账必须使用session启动事务,单节点不支持,需副本集或分片集群;须统一数据库、显式传入session、避免非DB操作,并优先用withTransaction确保自动回滚与重试。

MongoDB 跨集合转账必须用 session 启动事务
不显式创建会话(session)就调用 startTransaction(),事务根本不会生效——所有操作仍为自动提交。MongoDB 的事务只在会话上下文中存在,且必须由支持副本集或分片集群的部署提供(单节点 mongod 不支持事务)。
实操建议:
- 先确认连接的是副本集(
rs.status()可查),且驱动版本 ≥ 4.0(Node.js 驱动需 ≥ 3.6.0) - 用
client.startSession()获取会话对象,再传给collection.withTransaction()或手动session.startTransaction() - 不要复用会话:一次转账一个
session,结束后必须调用session.endSession(),否则可能泄漏资源
withTransaction() 比手动 commitTransaction()/abortTransaction() 更可靠
手动管理事务流程容易漏掉异常分支的回滚,比如网络中断时 commitTransaction() 失败但没触发 abortTransaction(),导致会话卡在「活跃事务」状态,后续操作被阻塞。
实操建议:
- 优先用
session.withTransaction(async (session) => { ... }),它内置重试逻辑和自动中止机制 - 回调函数内所有数据库操作(如
accountCollection.updateOne()、logCollection.insertOne())都必须显式传入该session参数 - 若回调抛出错误(包括未捕获异常、
throw new Error()),withTransaction会自动调用abortTransaction()
跨集合更新必须用同一 session,且集合不能跨数据库
MongoDB 事务不支持跨数据库操作。如果账户表在 bank 库、日志表在 audit 库,即使都在同一集群,事务也会报错:Multi-document transactions do not support operations across multiple databases。
实操建议:
- 把相关集合(如
accounts、transactions、logs)统一放在同一个数据库下 - 所有
updateOne()、insertOne()等调用必须带{ session }选项,例如:db.collection('accounts').updateOne({ _id: fromId }, { $inc: { balance: -100 } }, { session }) - 避免在事务中做非数据库操作(如 HTTP 请求、文件写入),它们无法回滚,会破坏原子性语义
事务超时和长持有会直接拖垮并发性能
MongoDB 默认事务最大运行时间是 60 秒(transactionLifetimeLimitSeconds),超时自动中止。但更危险的是人为长时间 hold 住事务:比如在事务里加了 console.log() 并卡住调试,或等待外部响应,会导致整个会话锁住相关文档,其他写请求排队甚至超时。
实操建议:
- 在
withTransaction()回调里只做必要 DB 操作,把校验、格式化、通知等移出事务外 - 设置显式超时:
session.withTransaction(fn, { maxCommitTimeMS: 5000 }),防止慢查询拖死事务 - 监控
currentOp()中"secs_running" > 2的事务,及时发现异常长事务
session 只是起点,不是银弹。










