【MongoDB实战】7.2 事务实战：转账场景数据一致性保证（完整实操代码）-平芜编程栈

文章目录

《MongoDB实战入门》7.2 事务实战：转账场景数据一致性保证（完整实操代码）
- 一、前置说明：MongoDB事务的核心前提
- 二、核心业务场景定义
- 三、Node.js版本实战代码（基于mongodb驱动5.x）
- - 1. 安装依赖
  - 2. 完整实操代码
  - 3. 运行结果说明
- 四、Python版本实战代码（基于pymongo 4.x）
- - 1. 安装依赖
  - 2. 完整实操代码
- 五、事务核心流程拆解（通用）
- 六、关键注意事项
- 七、扩展场景：批量转账事务

《MongoDB实战入门》7.2 事务实战：转账场景数据一致性保证（完整实操代码）

一、前置说明：MongoDB事务的核心前提

MongoDB 4.0+ 支持多文档事务，但仅在副本集环境下生效（单节点MongoDB不支持事务），因此实战前需满足：

1. 部署MongoDB副本集（本地测试可参考MongoDB官方文档搭建单节点副本集）；
1. 安装对应编程语言的MongoDB驱动（本文提供Node.js/Python双版本代码，覆盖主流场景）；
1. 核心逻辑：转账的“扣款”和“到账”必须在同一个事务中执行，确保原子性（要么全成功，要么全失败）。

二、核心业务场景定义

模拟两个账户（账户A：_id=1，账户B：_id=2）的转账操作：

账户A向账户B转账100元；
要求：若扣款失败（如A余额不足）、到账失败或网络异常，整个操作回滚，数据恢复到初始状态；
数据模型：accounts集合存储账户信息，结构为{_id: Number, balance: Number}。

三、Node.js版本实战代码（基于mongodb驱动5.x）

1. 安装依赖

npminstallmongodb

数据初始化

// 删除现有集合db.accounts.drop();// 插入初始数据db.accounts.insertMany([{_id:1,balance:500,name:"Alice",is_vip:true},{_id:2,balance:200,name:"Bob",is_vip:false}]);// 创建必要的索引db.accounts.createIndex({name:1});db.accounts.createIndex({is_vip:1,balance:1});// 显示结果print("数据库初始化完成");print("账户数量: "+db.accounts.countDocuments());print("索引:");db.accounts.getIndexes().forEach(idx=>print(" - "+idx.name));

2. 完整实操代码

集群启动bat（ start_all.bat ）代码

".MongoDB\Server\8.2\bin\mongod"--port27017--dbpath .\mongodb\rs0-27017\data --logpath .\mongodb\rs0-27017\log\rs0-27017.log --replSet rs0 --bind_ip0.0.0.0 --logappend".MongoDB\Server\8.2\bin\mongod"--port27018--dbpath .\mongodb\rs0-27018\data --logpath .\mongodb\rs0-27018\log\rs0-27018.log --replSet rs0 --bind_ip0.0.0.0 --logappend".MongoDB\Server\8.2\bin\mongod"--port27019--dbpath .\mongodb\rs0-27019\data --logpath .\mongodb\rs0-27019\log\rs0-27019.log --replSet rs0 --bind_ip0.0.0.0 --logappend

@echo off title MongoDB 三节点副本集启动脚本 color 0Aecho========================================echoMongoDB 三节点副本集启动器echo========================================REM 停止所有已运行的 MongoDB 实例echo[1/5]停止现有 MongoDB 进程... taskkill /F /IM mongod.exe2>nulecho✅ 已停止所有 MongoDB 进程 REM 创建必要的目录echo[2/5]创建目录结构...ifnot exist"D:\mongodb\rs0-27017\data"mkdir"D:\mongodb\rs0-27017\data"ifnot exist"D:\mongodb\rs0-27017\log"mkdir"D:\mongodb\rs0-27017\log"ifnot exist"D:\mongodb\rs0-27018\data"mkdir"D:\mongodb\rs0-27018\data"ifnot exist"D:\mongodb\rs0-27018\log"mkdir"D:\mongodb\rs0-27018\log"ifnot exist"D:\mongodb\rs0-27019\data"mkdir"D:\mongodb\rs0-27019\data"ifnot exist"D:\mongodb\rs0-27019\log"mkdir"D:\mongodb\rs0-27019\log"echo✅ 目录创建完成 REM 启动三个 MongoDB 实例echo[3/5]启动三个 MongoDB 实例...echo启动节点1(端口:27017)... start"MongoDB-27017"cmd /k""C:\Program Files\MongoDB\Server\8.2\bin\mongod" --port 27017 --dbpath D:\mongodb\rs0-27017\data --logpath D:\mongodb\rs0-27017\log\rs0-27017.log --replSet rs0 --bind_ip 0.0.0.0 --logappend"echo启动节点2(端口:27018)... start"MongoDB-27018"cmd /k""C:\Program Files\MongoDB\Server\8.2\bin\mongod" --port 27018 --dbpath D:\mongodb\rs0-27018\data --logpath D:\mongodb\rs0-27018\log\rs0-27018.log --replSet rs0 --bind_ip 0.0.0.0 --logappend"echo启动节点3(端口:27019)... start"MongoDB-27019"cmd /k""C:\Program Files\MongoDB\Server\8.2\bin\mongod" --port 27019 --dbpath D:\mongodb\rs0-27019\data --logpath D:\mongodb\rs0-27019\log\rs0-27019.log --replSet rs0 --bind_ip 0.0.0.0 --logappend"echo✅ 所有实例已启动echo等待实例启动完成...timeout/t10/nobreak>nul REM[4/5]初始化副本集echo[4/5]初始化副本集...echo请按照以下步骤手动初始化副本集： echo.echo1. 打开一个新的命令提示符窗口echo2. 执行以下命令连接到 MongoDB：echo"C:\Program Files\MongoDB\Server\8.2\bin\mongod"目录下应该有 mongo.exeecho如果没有，请从旧版 MongoDB 安装中复制 mongo.exe 到此目录 echo.echo3. 如果找到 mongo.exe，执行：echo"C:\Program Files\MongoDB\Server\8.2\bin\mongo"--port27017echo.echo4. 在 mongo shell 中执行：echors.initiate({echo_id:"rs0",echomembers:[echo{_id:0, host:"localhost:27017", priority:1},echo{_id:1, host:"localhost:27018", priority:0.5},echo{_id:2, host:"localhost:27019", priority:0.5}echo]echo})echo.echo5. 然后检查状态：echors.status()echo. pause REM[5/5]显示状态echo[5/5]显示副本集状态...echo按任意键测试连接... pause>nul REM 测试连接echo测试连接..."C:\Program Files\MongoDB\Server\8.2\bin\mongod"--version echo.echo========================================echo副本集启动完成（需要手动初始化）！echo主节点连接: mongodb://localhost:27017/?replicaSet=rs0echo所有节点连接: mongodb://localhost:27017,localhost:27018,localhost:27019/?replicaSet=rs0echo========================================echo.echo注意: 需要手动初始化副本集（见上面的步骤） pause

const{MongoClient}=require('mongodb');// 1. 配置MongoDB副本集连接字符串constMONGODB_URI='mongodb://localhost:27017,localhost:27018,localhost:27019/?replicaSet=rs0';constDB_NAME='bank';constCOLLECTION_NAME='accounts';// 重试配置constRETRY_MAX=3;constRETRY_DELAY=100;// 工具函数：事务重试async functionwithRetry(fn,maxRetries=RETRY_MAX,delay=RETRY_DELAY){let retries=0;while(retries<maxRetries){try{returnawaitfn();}catch(error)