- 当前位置：首页 >数据库 >Web架构之路：MongoDB集群及高可用实践
Web架构之路：MongoDB集群及高可用实践
发布时间：2025-11-05 07:31:26 来源：创站工坊 作者：人工智能
MongoDB集群有副本集及主从复制两种模式，架集群及高不过主从模式在MongoDB 3.6已经彻底废弃，可用今天主要探讨副本集的实践搭建和使用，以及分片。架集群及高
副本集介绍
副本集(Replica Set)即副本的可用集合，在MongoDB中通过先定义一个副本集合，实践然后将多个节点(副本)加入到这个集合中。架集群及高简单来说就是可用集群中包含了多份数据，保证主节点挂掉，实践备节点能够继续提供数据服务，架集群及高实现MongoDB的可用数据备份及高可用。
副本集具有以下特征：
N 个节点的实践集群 任何节点可作为主节点 所有写入操作都在主节点上 自动故障转移 自动恢复副本集搭建
条件有限，我们在单机上，架集群及高通过三个不同的可用MongoD线程来搭副本集。
主节点配置如下：
# 指定数据库路径 dbpath=/usr/local/mongodb/data/db # 使用追加的实践方式写日志 logpath=/usr/local/mongodb/log/mongodb.log # 使用追加的方式写日志 logappend = true # 绑定服务IP bind_ip=127.0.0.1 # 服务器端口 port = 27017 # 以守护进程的方式运行MongoDB，创建服务器进程 fork = true # PID File 的完整路径 pidfilepath=/usr/local/mongodb/var/mongod.pid # 不启用验证 noauth=true # 最大同时连接数,默认2000 maxConns=2000 # 同步复制的日志大小设置，单位MB oplogSize=10 # 副本集名称 replSet=rs0副本节点的配置和主节点的基本一致，需要修改一下数据库/日志/PID路径和端口号，副本集名称需一致：
# 指定数据库路径 dbpath=/usr/local/mongodb/node/2/data/db # 使用追加的方式写日志 logpath=/usr/local/mongodb/node/2/log/mongodb.log # 使用追加的方式写日志 logappend = true # 绑定服务IP bind_ip=127.0.0.1 # 服务器端口 port = 27018 # 以守护进程的源码库方式运行MongoDB，创建服务器进程 fork = true # PID File 的完整路径 pidfilepath=/usr/local/mongodb/var/mongod2.pid # 不启用验证 noauth=true # 最大同时连接数,默认2000 maxConns=2000 # 副本集 replSet=rs0依次启动三个mongod进程：
gitlib@devops:/usr/local/mongodb$ ps -aux | grep mongod root 14293 0.8 2.3 1588812 92700 ? Sl 08:06 0:01 bin/mongod -f mongod.conf root 14652 3.5 2.2 1583180 89364 ? Sl 08:08 0:00 bin/mongod -f mongod2.conf root 14723 6.4 2.2 1583180 89172 ? Sl 08:08 0:00 bin/mongod -f mongod3.conf在主节点中，先使用rs.initiate()方法进行副本集初始化操作，再使用rs.add()方法来添加副本集的成员：
> rs.initiate() { "info2" : "no configuration specified. Using a default configuration for the set", "me" : "127.0.0.1:27017", "ok" : 1, "$clusterTime" : { "clusterTime" : Timestamp(1569457173, 1), "signature" : { "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId" : NumberLong(0) } }, "operationTime" : Timestamp(1569457173, 1) } rs0:OTHER> rs.add(127.0.0.1:27018); { "ok" : 1, "$clusterTime" : { "clusterTime" : Timestamp(1569457214, 2), "signature" : { "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId" : NumberLong(0) } }, "operationTime" : Timestamp(1569457214, 2) } rs0:PRIMARY> rs.add(127.0.0.1:27019); { "ok" : 1, "$clusterTime" : { "clusterTime" : Timestamp(1569457219, 1), "signature" : { "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId" : NumberLong(0) } }, "operationTime" : Timestamp(1569457219, 1) } rs0:PRIMARY>到此，MongoDB副本集部署完成，我们可以通过rs.status()命令查看副本集状态。
gitlib@devops:~$ mongo 127.0.0.1:27018 rs0:SECONDARY> rs.status() { "set" : "rs0", "date" : ISODate("2019-09-26T12:09:48.818Z"), "myState" : 2, "term" : NumberLong(1), "syncingTo" : "127.0.0.1:27017", "syncSourceHost" : "127.0.0.1:27017", "syncSourceId" : 0, "heartbeatIntervalMillis" : NumberLong(2000), "optimes" : { "lastCommittedOpTime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "lastCommittedWallTime" : ISODate("2019-09-26T12:09:46.038Z"), "readConcernMajorityOpTime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "readConcernMajorityWallTime" : ISODate("2019-09-26T12:09:46.038Z"), "appliedOpTime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "durableOpTime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "lastAppliedWallTime" : ISODate("2019-09-26T12:09:46.038Z"), "lastDurableWallTime" : ISODate("2019-09-26T12:09:46.038Z") }, "lastStableRecoveryTimestamp" : Timestamp(1569499726, 1), "lastStableCheckpointTimestamp" : Timestamp(1569499726, 1), "members" : [ { "_id" : 0, "name" : "127.0.0.1:27017", "ip" : "127.0.0.1", "health" : 1, "state" : 1, "stateStr" : "PRIMARY", "uptime" : 42574, "optime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "optimeDurable" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "optimeDate" : ISODate("2019-09-26T12:09:46Z"), "optimeDurableDate" : ISODate("2019-09-26T12:09:46Z"), "lastHeartbeat" : ISODate("2019-09-26T12:09:47.119Z"), "lastHeartbeatRecv" : ISODate("2019-09-26T12:09:47.667Z"), "pingMs" : NumberLong(0), "lastHeartbeatMessage" : "", "syncingTo" : "", "syncSourceHost" : "", "syncSourceId" : -1, "infoMessage" : "", "electionTime" : Timestamp(1569457173, 2), "electionDate" : ISODate("2019-09-26T00:19:33Z"), "configVersion" : 3 }, { "_id" : 1, "name" : "127.0.0.1:27018", "ip" : "127.0.0.1", "health" : 1, "state" : 2, "stateStr" : "SECONDARY", "uptime" : 43284, "optime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "optimeDate" : ISODate("2019-09-26T12:09:46Z"), "syncingTo" : "127.0.0.1:27017", "syncSourceHost" : "127.0.0.1:27017", "syncSourceId" : 0, "infoMessage" : "", "configVersion" : 3, "self" : true, "lastHeartbeatMessage" : "" }, { "_id" : 2, "name" : "127.0.0.1:27019", "ip" : "127.0.0.1", "health" : 1, "state" : 2, "stateStr" : "SECONDARY", "uptime" : 42569, "optime" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "optimeDurable" : { "ts" : Timestamp(1569499786, 1), "t" : NumberLong(1) }, "optimeDate" : ISODate("2019-09-26T12:09:46Z"), "optimeDurableDate" : ISODate("2019-09-26T12:09:46Z"), "lastHeartbeat" : ISODate("2019-09-26T12:09:47.646Z"), "lastHeartbeatRecv" : ISODate("2019-09-26T12:09:47.036Z"), "pingMs" : NumberLong(0), "lastHeartbeatMessage" : "", "syncingTo" : "127.0.0.1:27018", "syncSourceHost" : "127.0.0.1:27018", "syncSourceId" : 1, "infoMessage" : "", "configVersion" : 3 } ], "ok" : 1, "$clusterTime" : { "clusterTime" : Timestamp(1569499786, 1), "signature" : { "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId" : NumberLong(0) } }, "operationTime" : Timestamp(1569499786, 1) }副本集高可用
集群中的各节点还会通过传递心跳信息来检测各自的健康状况。当主节点故障时,多个从节点会触发一次 新的选举操作，并选举其中的一个成为新的主节点(通常谁的优先级更高,谁就是新的主节点)，心跳信息默认每 2 秒传递一次。
客户端连接到副本集后，不关心具体哪一台机器是否挂掉。主服务器负责整个副本集的读写，副本集定期同步数据备份。一旦主节点挂掉，副本节点就会选举一个新的主服务器。这一切对于应用服务器不需要关心。
我们可以通过关闭主节点，测试是否会选举新的服务器托管主节点：
gitlib@devops:~$ ps -aux | grep mongod root 14293 0.6 2.5 1888584 99504 ? Sl 08:06 4:39 bin/mongod -f mongod.conf root 14652 0.6 2.6 1923896 102200 ? Sl 08:08 4:59 bin/mongod -f mongod2.conf root 14723 0.6 2.5 1886124 98984 ? Sl 08:08 4:47 bin/mongod -f mongod3.conf gitlib@devops:~$ sudo kill -9 14293 [sudo] password for zhoufei: zhoufei@devops:~$ ps -aux | grep mongod root 14652 0.6 2.6 1932092 102200 ? Sl 08:08 4:59 bin/mongod -f mongod2.conf root 14723 0.6 2.5 1894320 99064 ? Sl 08:08 4:47 bin/mongod -f mongod3.conf我们直接kill掉主节点，进入节点1，看一下当前节点是否是主节点：
gitlib@devops:~$ mongo 127.0.0.1:27018 rs0:SECONDARY> rs.isMaster() { "hosts" : [ "127.0.0.1:27017", "127.0.0.1:27018", "127.0.0.1:27019" ], "setName" : "rs0", "setVersion" : 3, "ismaster" : false, "secondary" : true, "primary" : "127.0.0.1:27019", "me" : "127.0.0.1:27018", ...可以看到当主节点(127.0.0.1:27017)挂掉之后，主节点自动切换到从节点2(127.0.0.1:27019)上。
副本集选举机制
副本集中的从节点在主节点挂掉后通过心跳机制检测到后，就会在集群内发起主节点的选举机制，自动选举出一位新的主服务器。
副本集包括三种节点：主节点、从节点、仲裁节点。
主节点负责处理客户端请求，读、写数据, 记录在其上所有操作的oplog; 从节点定期轮询主节点获取这些操作，然后对自己的数据副本执行这些操作，从而保证从节点的数据与主节点一致。默认情况下，从节点不支持外部读取，但可以设置，副本集的机制在于主节点出现故障的时候，余下的节点会选举出一个新的主节点，从而保证系统可以正常运行。IT技术网 仲裁节点不复制数据，仅参与投票。由于它没有访问的压力，比较空闲，因此不容易出故障。由于副本集出现故障的时候，存活的节点必须大于副本集节点总数的一半，否则无法选举主节点，或者主节点会自动降级为从节点，整个副本集变为只读。因此，增加一个不容易出故障的仲裁节点，可以增加有效选票，降低整个副本集不可用的风险。仲裁节点可多于一个。也就是说只参与投票，不接收复制的数据，也不能成为活跃节点。官方推荐MongoDB副本节点最少为3台， 建议副本集成员为奇数，最多12个副本节点，最多7个节点参与选举。限制副本节点的数量，主要是因为一个集群中过多的副本节点，增加了复制的成本，反而拖累了集群的整体性能。 太多的副本节点参与选举,也会增加选举的时间。而官方建议奇数的节点，是为了避免脑裂 的发生。
选举过程
副本集的选举过程大致如下:
得到每个服务器节点的最后操作时间戳。每个 mongodb都有oplog机制会记录本机的操作，方便和主服务器进行对比数据是否同步还可以用于错误恢复。
如果集群中大部分服务器down机了，保留活着的节点都为secondary状态并停止，不选举了。
如果集群中选举出来的主节点或者所有从节点最后一次同步时间看起来很旧了，停止选举等待人来操作。
如果上面都没有问题就选择最后操作时间戳最新(保证数据是最新的)的服务器节点作为主节点。
MongoDB 同步延迟问题
在MongoDB中,所有写操作都会产生 oplog，oplog 是每修改一条数据都会生成一条，如果你采用一个批量update命令更新了 N 多条数据，那么oplog 会有很多条，而不是一条。所以同步延迟就是写操作在主节点上执行完后,从节点还没有把 oplog 拿过来再执行一次。而这个写操作的量越大，主节点与从节点的差别也就越大，同步延迟也就越大了。
分片
当MongoDB存储海量的数据时，一台机器可能不足以存储数据，也可能不足以提供可接受的读写吞吐量。这时我们就可以通过在多台机器上分割数据，使得数据库系统能存储和处理更多的数据。
分片集群结构分布:
三个主要组件：
Shard：数据存储位置，以chunk为单位存数据，实际生产环境中一个shard server角色可由几台机器组个一个replica set承担，防止主机单点故障; Config Server：mongod实例，存储了整个ClusterMetadata，其中包括 chunk信息，默认需要配置3个Config Server节点; Query Routers：(Mongos) 前端路由，客户端由此接入，且让整个集群看上去像单一数据库，前端应用可以透明使用。Mongos本身并不持久化数据，Sharded Cluster所有的元数据都会存储到Config Server，而用户的数据会议分散存储到各个shard。Mongos启动后，会从配置服务器加载元数据，开始提供服务，将用户的请求正确路由到对应的碎片。
Mongos的路由功能：
当数据写入时，MongoDB Cluster根据分片键设计写入数据。 当外部语句发起数据查询时，MongoDB根据数据分布自动路由至指定节点返回数据。分片部署
条件有限，我们还是在单机上，用不同MongoDB线程来部署分片。
分片服务器
Shard Server和普通Mongod程序一样，不同的是需要在配置文件中添加shardsvr=true标记为Shard Server，配置参考如下：
# 指定数据库路径 dbpath=/usr/local/mongodb/share/1/data/db # 使用追加的方式写日志 logpath=/usr/local/mongodb/share/1/log/mongodb.log # 使用追加的方式写日志 logappend = true # 绑定服务IP bind_ip=127.0.0.1 # 服务器端口 port = 27020 # 以守护进程的方式运行MongoDB，创建服务器进程 fork = true # PID File 的完整路径 pidfilepath=/usr/local/mongodb/var/mongod27020.pid # 不启用验证 noauth=true # 最大同时连接数,默认2000 maxConns=2000 # 同步复制的日志大小设置，单位MB oplogSize=10 # 设置为shared server shardsvr=true以上配置复制4份，修改一下数据库路径/日志路径/服务器IP和端口/PID路径，启动4个Shard Server:
sudo bin/mongod -f shard1.conf sudo bin/mongod -f shard2.conf sudo bin/mongod -f shard3.conf sudo bin/mongod -f shard4.conf配置服务器
4.0版本的MongoDB中配置服务器(Config Server)需要设置副本集，同时设置configsvr=true，配置参考如下：
# 指定数据库路径 dbpath=/usr/local/mongodb/share/5/data/db # 使用追加的方式写日志 logpath=/usr/local/mongodb/share/5/log/mongodb.log # 使用追加的方式写日志 logappend = true # 绑定服务IP bind_ip=127.0.0.1 # 服务器端口 port = 27100 # 以守护进程的方式运行MongoDB，创建服务器进程 fork = true # PID File 的完整路径 pidfilepath=/usr/local/mongodb/var/mongod27100.pid # 不启用验证 noauth=true # 最大同时连接数,默认2000 maxConns=2000 # 同步复制的日志大小设置，单位MB oplogSize=10 # 配置为config server configsvr=true # 副本集名称 replSet=rs0启动Config Server，并初始化副本集：
sudo bin/mongod -f shard-config.conf mongo 127.0.0.1:27100 > rs.initiaze()新版本MongoDB建议设置多个Config Server，采用副本集形式设置集群，为了搭建方便，这里我们只采用单个Config Server。
路由服务器
Router Server不存放数据，配置参考如下：
# 使用追加的方式写日志 logpath=/usr/local/mongodb/share/6/log/mongodb.log # 使用追加的方式写日志 logappend = true # 绑定服务IP bind_ip=127.0.0.1 # 服务器端口 port = 4000 # 以守护进程的方式运行MongoDB，创建服务器进程 fork = true # PID File 的完整路径 pidfilepath=/usr/local/mongodb/var/mongod4000.pid # 设置监听的config服务器 configdb=rs0/127.0.0.1:27100启动Router Server，路由服务器是由mongos命令启动，与分片服务器及配置服务器不同。
sudo bin/mongos -f shard-router.conf启动后，需要通过sh.addShard()命令添加分片服务器:
sh.addShard(127.0.0.1:27020) sh.addShard(127.0.0.1:27021) sh.addShard(127.0.0.1:27022) sh.addShard(127.0.0.1:27023)配置完成后，可以通过sh.status()命令，查看分片情况：
mongos> sh.status() --- Sharding Status --- sharding version: { "_id" : 1, "minCompatibleVersion" : 5, "currentVersion" : 6, "clusterId" : ObjectId("5d8ddd1d94796dc650e29f67") } shards: { "_id" : "shard0000", "host" : "127.0.0.1:27020", "state" : 1 } { "_id" : "shard0001", "host" : "127.0.0.1:27021", "state" : 1 } { "_id" : "shard0002", "host" : "127.0.0.1:27022", "state" : 1 } { "_id" : "shard0003", "host" : "127.0.0.1:27023", "state" : 1 } active mongoses: "4.2.0" : 1 autosplit: Currently enabled: yes balancer: Currently enabled: yes Currently running: no Failed balancer rounds in last 5 attempts: 0 Migration Results for the last 24 hours: No recent migrations databases: { "_id" : "config", "primary" : "config", "partitioned" : true } config.system.sessions shard key: { "_id" : 1 } unique: false balancing: true chunks: shard0000 1 { "_id" : { "$minKey" : 1 } } -->> { "_id" : { "$max- 用罗技G402玩英雄联盟——打造极致游戏体验（解密G402在英雄联盟中的优势与应用技巧）
- 荣耀9天线信号强劲稳定（优秀信号接收效果带来顺畅通话和高速网络体验）
- 大白菜自制系统教程（简单易学、营养美味，让你成为厨房小能手）
- 以182移动号段怎么样？（分析182移动号段的服务质量、资费及用户体验）
- 用电脑合成人物剪纸，打造独特的手工艺品（电脑合成剪纸教程，手工艺品新潮流）
- 华为832路由的性能与功能分析（解析华为832路由的关键特性和用户体验）
- 绿联移动硬盘盒——高品质存储解决方案（便携性与可靠性的完美结合）
- 英雄钢笔6088的卓越品质和使用体验（高端设计、流畅书写、经久耐用，英雄钢笔6088让您尽享写作乐趣）
- 制作启动盘的完整教程（一步步教你如何制作启动盘）
- 公牛手机数据线的性能与质量评测（揭秘公牛手机数据线的优势和不足）
- PEGOST教程（掌握PEGOST加密算法，保护数据安全）
- 奥其斯照明（领先一步，让未来点亮现在）
- 电脑循环自动修复的解决方法（快速修复电脑循环自动修复问题的有效措施）
- 如何设置电脑启动项为U盘（详解电脑启动项设置及U盘优势）
- 联想电脑开机出现关键错误的解决方案（排除联想电脑开机关键错误的方法及注意事项）
- 成为魔术师装机大师的秘密（揭秘魔术师装机教程，让你成为电脑装机高手）
- 三星手机CPU性能及优势剖析（深入解析三星手机CPU的强大性能和卓越优势）
- 小米电脑笔记本使用教程（轻松上手小米电脑笔记本，让你的工作生活更高效）
- 电脑错误404（深入解析电脑错误404，帮助您解决烦恼）
- 华硕大白菜U盘装系统教程Win7（一步步教你使用华硕大白菜U盘装系统，让你的电脑焕然一新）
随便看看
服务器租用企商汇亿华云IT资讯网源码库益华科技源码下载IT技术网香港云服务器益强科技益强编程舍运维纵横技术快报益华IT技术论坛全栈开发益华科技益华科技亿华智造IT资讯网智能时代创站工坊亿华云益强编程堂益强智未来益强资讯优选亿华智慧云益强数据堂亿华灵动亿华互联益强IT技术网极客编程多维IT资讯思维库码力社益强智囊团亿华科技汇智坊编程之道码上建站益强前沿资讯极客码头云站无忧益强科技科技前瞻
- Copyright © 2025 Powered by Web架构之路：MongoDB集群及高可用实践,创站工坊 滇ICP备2023006006号-44sitemap