MongoDB多文档事务步骤详解

在MongoDB中实现多文档事务，核心价值在于将多个写操作打包成一个原子单元：要么全部成功，要么全部回滚，确保数据一致性。这一特性与传统关系数据库的ACID（原子性、一致性、隔离性、持久性）一脉相承，MongoDB从4.0版本开始正式支持。下面逐步介绍如何在Java代码中落地这一事务机制。

前提条件

在开始之前，需要满足两个硬性要求：

1. 复制集环境：事务只能在复制集（Replica Set）或分片集群（Sharded Cluster）中运行。单节点实例不支持事务，请勿尝试。
2. 版本达标：MongoDB版本必须≥4.0。如果仍在用3.x，建议立即升级——事务功能是4.0的一个里程碑更新。

1. 引入Maven依赖

使用Java操作MongoDB，首先在pom.xml中添加依赖：

  org.mongodb  mongodb-driver-sync  4.4.0

该驱动版本稳定，基础事务操作完全够用。

2. Java代码示例

以下是完整代码，注释清晰，便于理解：

import com.mongodb.MongoClientSettings;
import com.mongodb.MongoException;
import com.mongodb.ReadConcern;
import com.mongodb.ReadPreference;
import com.mongodb.TransactionOptions;
import com.mongodb.WriteConcern;
import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;

public class MongoDBTransactionExample {
    public static void main(String[] args) {
        // 创建 MongoClient
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");

        // 获取数据库和集合
        MongoDatabase database = mongoClient.getDatabase("testdb");
        MongoCollection collection1 = database.getCollection("collection1");
        MongoCollection collection2 = database.getCollection("collection2");

        // 插入初始数据
        collection1.insertOne(new Document("account", "Alice").append("balance", 100));
        collection2.insertOne(new Document("account", "Bob").append("balance", 0));

        // 开始会话
        ClientSession session = mongoClient.startSession();

        // 配置事务选项
        TransactionOptions txnOptions = TransactionOptions.builder()
                .readPreference(ReadPreference.primary())
                .readConcern(ReadConcern.LOCAL)
                .writeConcern(WriteConcern.MAJORITY)
                .build();

        try {
            // 开始事务
            session.startTransaction(txnOptions);

            // 执行跨集合的写操作
            Document aliceAccount = collection1.find(session, new Document("account", "Alice")).first();
            if (aliceAccount != null && aliceAccount.getInteger("balance") >= 50) {
                collection1.updateOne(session, new Document("account", "Alice"),
                        new Document("$inc", new Document("balance", -50)));
                collection2.updateOne(session, new Document("account", "Bob"),
                        new Document("$inc", new Document("balance", 50)));
            } else {
                throw new RuntimeException("Insufficient balance!");
            }

            // 提交事务
            session.commitTransaction();
            System.out.println("Transaction committed.");
        } catch (MongoException | RuntimeException e) {
            // 回滚事务
            session.abortTransaction();
            System.err.println("Transaction aborted due to: " + e.getMessage());
        } finally {
            session.close();
        }

        mongoClient.close();
    }
}

该代码演示了一个经典转账场景：从Alice账户扣除50，给Bob账户增加50。如果Alice余额不足，整个操作会回滚，不会出现扣款不到账的情况。

解释代码

上述代码中的每个环节都很关键，下面逐一拆解：

1. 创建 MongoClient：连接MongoDB实例，通常连接到复制集的主节点。

MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");

2. 获取数据库和集合：获取目标数据库和两个集合的引用，事务将跨这两个集合保持一致性。

MongoDatabase database = mongoClient.getDatabase("testdb");
MongoCollection collection1 = database.getCollection("collection1");
MongoCollection collection2 = database.getCollection("collection2");

3. 插入初始数据：向集合中插入两条示例数据，Alice有100，Bob有0。

collection1.insertOne(new Document("account", "Alice").append("balance", 100));
collection2.insertOne(new Document("account", "Bob").append("balance", 0));

4. 开始会话：事务必须依附于一个会话（ClientSession），通过mongoClient.startSession()创建。

ClientSession session = mongoClient.startSession();

5. 配置事务选项：通过TransactionOptions设置读偏好、读关注和写关注。此处使用主节点读取、本地读关注、大多数写关注，兼顾性能与安全性。

TransactionOptions txnOptions = TransactionOptions.builder()
        .readPreference(ReadPreference.primary())
        .readConcern(ReadConcern.LOCAL)
        .writeConcern(WriteConcern.MAJORITY)
        .build();

6. 开始事务：调用session.startTransaction(txnOptions)启动事务。后续所有涉及该会话的操作都在事务边界内。

session.startTransaction(txnOptions);

7. 执行跨集合写操作：先查询Alice账户余额，若≥50则更新两个集合；否则抛出异常触发回滚。这是事务保证原子性的关键。

Document aliceAccount = collection1.find(session, new Document("account", "Alice")).first();
if (aliceAccount != null && aliceAccount.getInteger("balance") >= 50) {
    collection1.updateOne(session, new Document("account", "Alice"),
            new Document("$inc", new Document("balance", -50)));
    collection2.updateOne(session, new Document("account", "Bob"),
            new Document("$inc", new Document("balance", 50)));
} else {
    throw new RuntimeException("Insufficient balance!");
}

8. 提交事务：所有操作成功，调用session.commitTransaction()持久化变更。

session.commitTransaction();
System.out.println("Transaction committed.");

9. 回滚事务：捕获异常（MongoDB异常或业务异常）后，立即调用session.abortTransaction()，所有未提交的改动全部撤销。

catch (MongoException | RuntimeException e) {
    session.abortTransaction();
    System.err.println("Transaction aborted due to: " + e.getMessage());
}

10. 关闭会话和客户端：最后关闭会话和连接，释放资源。

finally {
    session.close();
}
mongoClient.close();

总结

通过以上完整示例可以看出，MongoDB多文档事务在Java中的实现并不复杂——核心流程为“启动会话 → 开启事务 → 执行操作 → 提交或回滚 → 关闭会话”。关键在于根据业务需求配置事务选项，并做好异常处理。合理利用事务机制，可在转账、订单、库存等需要跨集合一致性的场景中避免数据不一致的问题。需要注意，事务是工具而非银弹，正确使用能大幅提升数据可靠性，但在高频写入场景下滥用可能带来性能开销，务必结合业务场景进行权衡。