说起 NoSQL，hen多人第一反应是「放宽了 ACID」的束缚。但自从 MongoDB 在 4.x 系列里打开了「跨集合、跨分片」的大门后大家又开始重新审视它在事务方面的潜力。本文将用通俗的语言把这背后的技术细节拆开聊聊，并配上实战代码，帮助你在真实项目中把握住这枚“金钥”。

想象一下一个电商平台的订单流程： ① 扣减用户账户余额； ② 往订单表写入新记录； ③ 同时geng新商品库存。 Ru果这三步只靠单独的写操作来完成，一旦中间某一步挂掉，就会出现“钱扣了、单据没生成”之类的数据不一致。传统关系库通过一次提交搞定所有步骤，而在早期的 MongoDB 中，这种“一刀切”只Neng在单文档内部实现。

于是“跨集合原子化”成为了迫切需求——这正是分布式事务要解决的问题。

复制集从 4.0 起即可使用多文档事务。

分片集群4.2 之后才加入对跨分片事务的支持。

单节点实例不提供真正意义上的事务功Neng，只Neng依赖单文档原子性。

换句话说Ru果你的业务Yi经跑在一个包含若干 shard 的集群里请务必确认版本 ≥ 4.2，否则即使写出代码，也只Neng在同一 shard 内部生效。

部署前Ke以用以下命令快速检查当前版本：

mongo --eval "db.version"

MongoDB 为了让多个 shard 协同完成一次提交，引入了经典的两阶段提交协议：

准备阶段每个参与节点把本地写操作写入自己的预提交日志，但不对外可见。

提交阶段协调者收到所有节点dou成功准备完毕的响应后向每个节点发送 commit 命令，正式让这些操作生效；若有任意节点返回错误，则进入回滚流程。

整个过程由 MongoDB 内部的 “transaction coordinator” 完成，对外表现为一次普通的 .commitTransaction 调用。开发者只需要关注会话的开启与关闭即可。

// 连接到目标库
const conn = new Mongo;
const db = conn.getDatabase;
// 创建会话并启动事务
const session = db.getMongo.startSession;
session.startTransaction;
try {
    const accounts = session.getDatabase.getCollection;
    const orders   = session.getDatabase.getCollection;
    // 扣减余额
    accounts.updateOne(
        { _id: ObjectId },
        { $inc: { balance: -100 } }
    );
    // 写入订单
    orders.insertOne({
        userId: ObjectId,
        amount: 100,
        status: 'pending',
        createdAt: new Date
    });
    // 提交
    session.commitTransaction;
    print;
} catch  {
    // 出错则回滚
    print;
    session.abortTransaction;
} finally {
    session.endSession;
}

注意：在实际生产环境里你应该捕获特定错误码并进行重试，否则高并发时容易被“撞车”。

const mongoose = require;
async function run {
  await mongoose.connect('mongodb://localhost:27017/shop', {
      useNewUrlParser: true,
      useUnifiedTopology: true
  });
  const Account   = mongoose.model);
  const Order     = mongoose.model);
  const session = await mongoose.startSession;
  session.startTransaction;
  try {
      await Account.updateOne(
          {_id: '64a1c9f5e6b7c90f9d123456'},
          {$inc:{balance:-100}},
          {session}
      );
      await Order.create(, {session});
      await session.commitTransaction;
      console.log;
  } catch  {
      console.error;
      await session.abortTransaction;
  } finally {
      session.endSession;
      await mongoose.disconnect;
  }
}
run.catch;

这里用了 Mongoose 的会话对象，把每一次读写dou绑定到同一个 transaction 上。别忘了把连接选项里的 useUnifiedTopology:true 打开，它Neng让驱动geng好地处理心跳与故障转移。

A quick note for Java 开发者：Spring Data Yi经帮我们封装好了 TransactionManager，只要在入口类上加上 @EnableTransactionManagement 并配置好 MongoTemplate, 就Ke以像使用关系型数据库一样使用 @Transactional 注解。

@SpringBootApplication
@EnableTransactionManagement
public class ShopApplication {
    public static void main {
        SpringApplication.run;
    }
}
@Service
public class OrderService {
    @Autowired private MongoTemplate mongoTemplate;
    @Transactional
    public void placeOrder {
        Query q = Query.query.is);
        Update u = new Update.inc;
        mongoTemplate.updateFirst;
        Document order = new Document
                .append
                .append
                .append
                .append);
        mongoTemplate.insert;
        // 若此处抛异常，前面的扣款也会回滚
}
}

在生产环境下务必把 的超时时间调大一点，否则默认几秒就可Neng被系统强制终止。

🌱 为每一次 transaction 加上唯一标识，方便日志追踪和故障排查；

🚀 将所有涉及金钱或库存变化的业务统一放进同一个 transaction，避免“半路出错”；

💡 使用聚合管道 时记得先测试，因为它本质上也是一次写操作，同样受限于事务大小。

Mongodb 的发展史像是一部《变形金刚》——从Zui初的「文档存储」逐渐进化为「企业级 ACID 引擎」。Ru果你的系统面临以下情况，请大胆打开它的大门：

订单、支付等核心业务必须保证“一次成功，两边必达”。

数据模型天然是多集合、多文档交叉引用，而不是简单键值映射。

Yi有副本集或分片集群，并且版本Yi升级到>= 4.2。

相反，Ru果你的场景只是缓存层或者日志收集，那么保持无状态、直接依赖幂等写入往往geng省心。在技术选型上，没有所谓绝对正确，只有适配度Zui高的一套组合。