MongoDB教程FG064-MongoDB数据一致性保障实战

# 插入数据时指定写入关注
db.fgedu_users.insertOne(
{ name: “Test User”, age: 30, email: “test@fgedu.net.cn” },
{ writeConcern: { w: “majority”, wtimeout: 5000 } }
)

3.2 读取偏好设置

设置读取偏好：

# 连接时指定读取偏好
/mongodb/app/bin/mongosh –host 192.168.1.100 –port 27017 –readPreference primary

# 在操作中指定读取偏好
db.fgedu_users.find().readPref(“primary”)

Part04-生产案例与实战讲解

4.1 写入一致性实战

测试写入关注：

# 连接MongoDB
/mongodb/app/bin/mongosh –host 192.168.1.100 –port 27017 -u fgedu -p fgedu123 –authenticationDatabase admin

# 切换到目标数据库
use fgedudb

# 插入数据并等待 majority 确认
db.fgedu_users.insertOne(
{ name: “User1”, age: 25, email: “user1@fgedu.net.cn” },
{ writeConcern: { w: “majority”, wtimeout: 5000 } }
)

# 输出日志
{ “acknowledged”: true, “insertedId”: ObjectId(“60a7b8c9d0e1f2a3b4c5d6e7”) }

测试复制延迟：

# 查看复制延迟
rs.printSlaveReplicationInfo()

# 输出日志
source: 192.168.1.101:27018
syncedTo: Timestamp(1712544000, 1)
0 secs (0 hrs) behind the primary
source: 192.168.1.102:27019
syncedTo: Timestamp(1712544000, 1)
0 secs (0 hrs) behind the primary

from MongoDB视频:www.itpux.com

4.2 事务一致性实战

使用事务：

# 连接MongoDB
/mongodb/app/bin/mongosh –host 192.168.1.100 –port 27017 -u fgedu -p fgedu123 –authenticationDatabase admin

# 切换到目标数据库
use fgedudb

# 开始事务
const session = db.getMongo().startSession();
const collection = session.getDatabase(“fgedudb”).getCollection(“fgedu_users”);

// 执行事务
session.startTransaction();
try {
// 插入数据
collection.insertOne({ name: “User2”, age: 30, email: “user2@fgedu.net.cn” });
// 更新数据
collection.updateOne({ name: “User1” }, { $set: { age: 26 } });
// 提交事务
session.commitTransaction();
print(“Transaction committed”);
} catch (error) {
// 回滚事务
session.abortTransaction();
print(“Transaction aborted:”, error);
} finally {
// 结束会话
session.endSession();
}

# 输出日志
Transaction committed

验证事务结果：

# 查看数据
db.fgedu_users.find({ $or: [{ name: “User1” }, { name: “User2” }] })

# 输出日志
[
{ _id: ObjectId(“60a7b8c9d0e1f2a3b4c5d6e7”), name: “User1”, age: 26, email: “user1@fgedu.net.cn” },
{ _id: ObjectId(“60a7b8c9d0e1f2a3b4c5d6e8”), name: “User2”, age: 30, email: “user2@fgedu.net.cn” }
]

风哥提示：事务适用于需要原子性操作的场景，但会对性能产生一定影响，应谨慎使用。

Part05-风哥经验总结与分享

5.1 一致性最佳实践

风哥建议的一致性最佳实践：

根据业务需求选择合适的写入关注级别
对于关键数据，使用 “majority” 写入关注
合理设置写入超时时间，避免操作挂起
对于读取操作，根据业务需求选择合适的读取偏好
在需要原子性操作的场景中使用事务

学习交流加群风哥QQ113257174

5.2 性能与一致性平衡

性能与一致性平衡的建议：

在性能要求高的场景中，可以使用较低的一致性级别
使用读写分离，将读操作引导到从节点
监控复制延迟，确保数据同步及时
考虑使用分片集群分散负载
定期优化查询，减少对数据库的压力

更多视频教程www.fgedu.net.cn

注意事项

写入关注级别越高，写入操作的延迟可能越大
事务仅在MongoDB 4.0及以上版本可用，且需要使用复制集
复制延迟可能会影响读取操作的一致性
在网络环境不稳定的情况下，应设置合理的超时时间
定期监控数据库的一致性状态，及时发现和解决问题

本文由风哥教程整理发布,仅用于学习测试使用,转载注明出处:http://www.fgedu.net.cn/10327.html

MongoDB教程FG064-MongoDB数据一致性保障实战

目录大纲

Part01-基础概念与理论知识

1.1 数据一致性概述

1.2 MongoDB一致性模型

Part02-生产环境规划与建议

2.1 一致性级别选择

2.2 架构设计建议

Part03-生产环境项目实施方案

3.1 写入关注配置