testcontainers 不提供事务回滚能力，需测试代码显式控制且 mongodb 必须以副本集模式启动；默认 standalone 模式不支持事务，须配置 --replset 并确保 rs.initiate() 完成；客户端连接不带 replicaset 参数但需指定副本集名；事务生命周期由测试代码管理，go/java 均需手动开启与回滚；复用容器时须方法级事务隔离并清空集合；副本集初始化有延迟，需自定义健康检查确认 ismaster: true 后再执行测试。
Testcontainers 本身不提供事务回滚能力，它只负责启动真实 MongoDB 容器；事务回滚必须由你的测试代码显式控制，且前提是 MongoDB 实例已正确配置为副本集。
MongoDB 容器必须以副本集模式启动
单节点 MongoDB 不支持多文档事务。Testcontainers 的 MongoDBContainer 默认启动的是独立模式（standalone），直接调用 session.startTransaction() 会报错：Command failed with error 265 (NoSuchTransaction): 'No transaction is in progress' 或更底层的 NotImplemented。
你需要显式启用副本集：
- 使用
.withCommand("--replSet", "rs0")启动容器 - 在容器就绪后，执行
rs.initiate()初始化副本集（Testcontainers 的MongoDBContainerv1.17+ 已自动完成这步） - 连接时不能带
?replicaSet=rs0参数（否则驱动会尝试发现其他节点），但客户端代码中仍需通过MongoClientOptions.builder().applyToClusterSettings(...)或 Spring 的spring.data.mongodb.replica-set配置指定副本集名
Go / Java 中开启并回滚事务的典型写法
事务生命周期完全由测试代码管理，Testcontainers 不介入。常见错误是忘记手动回滚，或在 panic/超时场景下遗漏 defer 处理。
以 Go 为例（使用 mongo-go-driver）：
session, err := client.StartSession()
if err != nil {
t.Fatal(err)
}
defer session.EndSession(ctx) // 必须，否则连接泄漏
err = session.WithTransaction(ctx, func(sessCtx mongo.SessionContext) (interface{}, error) {
collection := client.Database("testdb").Collection("orders")
_, err := collection.InsertOne(sessCtx, bson.M{"status": "pending"})
if err != nil {
return nil, err
}
// 故意触发失败，让事务回滚
return nil, errors.New("force rollback")
})
// err != nil → 事务已回滚；err == nil → 事务已提交
Java（Spring Data MongoDB）需注意：@Transactional 注解对 MongoDB 无效，必须手写 TransactionOperations 或 TransactionalOperator，且要确保 MongoTemplate 使用的是 replica-set-aware 的 MongoClient。
测试类级别复用容器但事务仍需方法级隔离
为加速测试，你可能用 @Container static MongoDBContainer mongo = new MongoDBContainer(...).withReuse(true) 复用一个容器实例。但这不等于数据自动隔离——多个测试方法共用同一数据库，若不回滚事务，彼此会污染。
所以必须坚持：
- 每个测试方法内创建新
session并显式控制事务边界 - 避免在
@BeforeAll中预写共享测试数据；如需，应在每个测试开始前清空集合（collection.deleteMany({}, null)） - 不要依赖容器销毁来“清理”数据，因为
withReuse(true)下容器不会被销毁
最易被忽略的一点：副本集初始化有延迟，即使容器状态为 running，rs.status() 也可能返回 STARTUP2。直接连上去开事务会失败。Testcontainers 的 waitingFor(Wait.forLogMessage(".*waiting for connections.*", 1)) 不够，得加自定义健康检查，比如轮询 rs.isMaster() 返回 ismaster: true 再开始测试。
