版本:3.6

一、以单机模式启动成员节点

有时候出于维护的需要,需要以单机模式启动某个节点而不是一个副本集成员身份。

1).首先查询服务器命令行参数

db.serverCmdLineOpts()

2).关闭当前副本

3).以单机模式启动副本

这里需要指定副本原先的db路径,为了避免可能的其它连接这里可以指定一个新的port启动;也可以直接使用原先的配置文件启动只需要注释掉“replSet”参数即可。

mongod --port 27000 --bind_ip 192.168.137.10,127.0.0.1 --dbpath /mongos27012/data/db4

4).维护完之后再以副本成员身份启动当前服务器。

二、检查写入是否成功

getLastError命令检查写入是否成功

db.runCommand({"getLastError":1,"w":2,"wtimeout":1000});

getLastErrorDefaults默认配置值

conf = rs.config();conf.settings = {"getLastErrorDefaults" : {"w" : 1,"wtimeout" : 0}};rs.reconfig(conf);

wtimeout:等待超时时长,如果超过这个时间MongoDB无法在指定时间内将写入操作复制到“w”个成员,返回超时。

w的多个值:

majority:一直等待保证大多数成员都执行完了写入操作

number(数字):w值包含主节点,如果设置1那么只保证主节点写入成功,如果希望被复制到N个节点,那么应该将“w”设置为N+1

三、自定义复制保证规则,设置成员标签

1.设置成员标签

conf = rs.config();conf.members[0].tags={"dc" : "dc01"};conf.members[1].tags={"dc" : "dc01"};conf.members[2].tags={"dc" : "dc02"};rs.reconfig(conf);

上面操作设置了两个组,分别是dc01和dc02;

注意:

1.tags用来给每一个节点成员设置标签,它是一个集合所以可以像集合一样包含多个值,比如

{"dc": "rack1", disk:"ssd", ssd: "installed"}

2.如果要初始化tags必须先初始化settings.getLastErrorModes

2.配置规则,应用于settings选项

通过配置getLastErrorMode字段实现,每条规则的形式为:"name":{"key":number}.其中name是规则的名字,自己定,key就是上面tags的标识,number表示复制操作至少复制到多少个分组上,每个分组内至少一台机器上.

conf = rs.config();conf.settings.getLastErrorModes={"eachDC":{"dc":2}                                                }rs.reconfig(conf);

初始化getLastErrorModes

conf = rs.config();conf.settings.getLastErrorModes={}rs.reconfig(conf);

3.插入记录并应用规则

db.users.insert( { id: "xyz", status: "A" }, { writeConcern: { w:"eachDC" } } );

注意:如果不想数据复制到某个节点,可以不给这个节点配置标签,这样该成员就是隐藏成员。

conf = rs.config();conf.members[1].tags={};rs.reconfig(conf);

4.注意事项

conf = rs.conf()conf.members[0].tags = { "dc": "east", "production": "node-1" }conf.members[1].tags = { "dc": "east", "production": "node-2" }conf.members[2].tags = { "dc": "east", "production": "node-3" }rs.reconfig(conf)下面的规则可以创建成功,因为标签production拥有三个不同的组conf.settings = {getLastErrorModes: {productionWriteConcern : { "production": 3 }}}下面的规则不能创建成功,因为标签dc只有一个唯一的组conf.settings = {getLastErrorModes: {dcWriteConcern : { "dc": 3 }}}

四、副本集配置

副本集的配置在local.system.replSet集合中。副本集中所有成员的的该文档记录都是相同的。

rs.:副本命令,是replSet是缩写,代表副本集。

db.:数据库命令,比如db.printReplicationInfo(),db.printSlaveReplicationInfo()

rs.status:查看成员的复制状态,可以在任意节点执行。

rs.config():可以得到当前副本的配置,修改配置文件,然后将修改后的配置文件传递给                      reconfig、initiate命令。

rs.reconfig()(replSetReconfig):修改副本集的配置。rs.reconfig(conf,{"force":true})

rs.initiate():会初始化配置,只需要对副本集中的一个成员调用rs.initiate就可以(一般主节点),收到initiate命令的成员会自动将配置文件传递给副本集中的其他成员

1.创建副本集

1).登入

mongo --port 27010

2).切换admin数据库

use admin

3).验证权限

db.auth("dba","dba")

4).初始化复制集,默认会创建当前节点为主节点的副本集

rs.initiate()

5).重启当前节点

db.shutdownServer()

2.修改副本集成员

1).添加新成员,在主节点执行:

rs.add("192.168.137.10:27011")
可以在添加成员的时设定成员配置,也就是rs.conf中member的参数:
rs.add("_id":1,"host":"192.168.137.10:27011", "priority" : 0, "hidden" : true)

2)删除成员

rs.remove("192.168.137.10:27012");

修改副本集成员配置时的限制:

1、不能修改_id;

2、不能将当前执行rs.reconfig命令的成员的优先级设置为 0;

3、不能将仲裁者成员变为非仲裁者成员,反正亦然;

4、不能将buildIndexes由false改为 true;

3.保证主节点不切换

将所有的备份节点的priority和votes都设置为0;这样只有主节点有投票权所以无论备份节点是否存在都不会导致主节点的状态由primary变成other。

conf=rs.config()conf.members[1].priority=0conf.members[1].votes=0rs.reconfig(conf)

4.强制重新配置

如果副本集无法选出新的主节点,这时需要重新配置副本集。可以在备份节点上调用rs.reconfig(conf,{"force":ture})强制重新配置副本集。注意conf必须是正确、有效的配置。而且只允许在备份节点执行强制重新配置。

备份节点收到新的配置文件之后,就会修改自身的配置,并且将新的配置发送给副本集中的其他成员。副本集的其他成员收到新的配置文件之后,会判断配置文件的发送者是否是它们当前配置中的一个成员,如果是,才会用心的配置文件对自己进行重新配置。所以,如果新的配置修改了某些成员的主机名,则应该关闭被修改主机名的节点,并以单机模式启动,手动修改locak.system.replset文档,然后以副本集的方式重新启动。

5.修改成员状态

1).把主节点变为备份节点,在主节点执行

rs.stepDown()

rs.stepDown(60):让主节点退化为备份节点,并维持60秒。如果这段时间内没有新的主节点被选举出来,那么当前节点可以要求重新参与进行选举。

2).阻止选举

如果需要对主节点进行维护操作,但是不希望这段时间内其它成员选举为主节点,可以在每个备份节点上执行freeze命令,以强制它们始终处于备份节点的状态。命令以秒为单位。

rs.freeze(3600):保持1个小时处于备份节点状态。rs.freeze(0):再次在备份节点执行且将时间指定为0就是“释放”备份节点。

注意:如果在退位的备份节点上执行rs.freeze(0),可以让退位的备份节点重新变为主节点。

6.禁用复制链

1).查看复制源

查询节点从哪个节点处复制。在备份节点上运行。

db.adminCommand({"replSetGetStatus":1})['syncingTo'];

也可以运行rs.status(),查看"syncingTo"字段信息。

2.)复制链

MongoDB根据ping时间选择同步源,一个成员向另一个成员发送心跳请求,就知道心跳请求所耗费的时间(rs.status()中的"pingMs"记录了成员到达相关成员的所花费的平均时间)。MongosDB维护着不同成员间请求的平均花费时间。选择同步源时,会选择一个离自己比较近而且数据比自己新的成员。但是同一数据中心的成员可能会从同一数据中心的其他成员处复制,而不是从位于另一个数据中心的主节点处复制(这样可以减少网络流量),所以会出现复制链的情况,复制链越长会导致主节点的操作复制到所有的服务器所花费的时间越长。这对于需要从副本中读取数据的需求这种情况是不希望看到的。

3).修改复制源

db.adminCommand({"replSetSyncFrom":"192.168.137.10:27011"});

4).禁用复制链

conf = rs.conf()
conf.settings.chainingAllowed = false
rs.reconfig(conf)

在主副本中执行

7.计算延迟

1).查看当前副本集oplog状态

rs.printReplicationInfo()

configured oplog size:oplog配置的大小

log length start to end:oplog包含的操作时长。

oplog first event time:oplog第一条操作的时间。

oplog last event time:oplog最后一条操作的时间。

now:当前时间。

注意:oplog中第一条操作与最后一条操作的时间差就是操作日志的长度。

2).查看复制延迟

rs.printSlaveReplicationInfo()

会显示当前所有的备份节点同步时间,和落后主节点的时长。

8.调整oplog大小

1)  如果是主节点,将主节点变成备份节点。

2)  将oplog中的最后一条insert操作保存到其它集合中。

use localvar lastinsert = db.oplog.rs.find({"op":{$in:["i"]}}).sort({"wall":-1}).limit(1).next();db.tempLastOp20180330.save(lastinsert)db.tempLastOp20180330.find()

3)   关闭当前服务器

4)   以单机模式启动

mongod --port 27000 --bind_ip 192.168.137.10,127.0.0.1 --dbpath /mongos27012/data/db

5)   删除当前oplog

db.oplog.rs.drop();

6)   创建新的oplog

db.createCollection("oplog.rs",{"capped":true,"size":1048576})

7)  将最后一条insert记录写回oplog

var tempLastOp=db.tempLastOp20180330.find().next()
db.oplog.rs.insert(tempLastOp)
db.oplog.rs.find()

8)  以副本成员身份启动当前服务器

五、复制集监控

1.复制集状态查询:rs.status()

2.查看当前副本集oplog状态:rs.printReplicationInfo()

3.查看复制延迟:rs.printSlaveReplicationInfo()

4.查看服务状态详情:db.serverStatus()

5.查询副本集配置:rs.conf()

6.主副本查询:db.isMaster()

副本配置:https://docs.mongodb.com/manual/reference/replica-configuration/#rsconf.settings.getLastErrorDefaults

备注:

作者:pursuer.chen

博客:http://www.cnblogs.com/chenmh

本站点所有随笔都是原创,欢迎大家转载;但转载时必须注明文章来源,且在文章开头明显处给明链接,否则保留追究责任的权利。

《欢迎交流讨论》

MongoDB 副本集管理相关推荐

  1. mongodb副本集_设置MongoDB副本集分为4个步骤

    mongodb副本集 介绍 在详细介绍配置MongoDB副本集之前,让我简要介绍一下它们: 副本集是Mongodb数据库提供的功能,可实现高可用性和自动故障转移. 它是一种传统的主从配置,但具有自动故 ...

  2. 设置MongoDB副本集分为4个步骤

    介绍 在详细介绍配置MongoDB副本集之前,让我简要介绍一下它们: 副本集是Mongodb数据库提供的功能,可实现高可用性和自动故障转移. 它是一种传统的主从配置,但具有自动故障转移功能. 基本上, ...

  3. MongoDB副本集权限重置

    背景:某公司线上的一套MongoDB副本集,只知道一个应用库以及该库下对应的一个用户.除此以外,对这套集群一无所知,他们的需求是要拥有超级用户权限,方便以后管理. 我虽是一个小渣渣,但以前单位一个很照 ...

  4. MongoDB副本集详解与搭建

    1. 简介 MongoDB中的副本集(Replica Set)是一组维护相同数据集的mongod服务. 副本集可提供冗余和高可用性,是所有生产部署的基础.也可以说,副本集类似于有自动故障恢复功能的主从 ...

  5. MongoDB副本集搭建及在springboot中使用

    MongoDB副本集搭建及在springboot中使用 一.mongoDB副本集的搭建 原则就是一台master(主),一台salve(从),一台arbiter(仲裁) 1.下载mongoDB htt ...

  6. DockerCompose MongoDB 副本集(集群) (客户端验证密码 - 集群内部使用mongodbKeyfile验证 ) 部署

    本部署MongoDB副本集是没有用其他的配置什么的(例如: mongodb-compass).是最简单的一个 我是为了mongodb的事务才配置的这个副本集,要使用mongodb的事务必须要副本集. ...

  7. Docker下,实战mongodb副本集(Replication)

    在<Docker下,极速体验mongodb>一文中我们体验了单机版的mongodb,实际生产环境中,一般都会通过集群的方式来避免单点故障,今天我们就在Docker下实战mongodb副本集 ...

  8. 总结—什么妖引起的MongoDB副本集初始化失败?

    前言: 在之前搭建MongoDB集群中,遇到过一些小问题作妖引起的初始化副本集失败,初学至今踩过来的坑,在此做个小结. 1.IP错误引起MongoDB副本集初始化失败 这个错误在另一篇文章已经描述过, ...

  9. Mongodb 副本集+分片集群搭建

    环境需求: 在三台机器上搭建副本集,在副本集上做分片 服务器IP: 192.168.1.232/192.168.1.238/192.168.1.241 安装Mongodb all nodes: tar ...

最新文章

  1. mysql里条件语句和循环语句_MySQL与Oracle 差异比较之四条件循环语句
  2. 如果有一个类是 myClass , 关于下面代码正确描述的是?
  3. 高德地图轨迹PHP,轨迹回放-点标记-示例中心-JS API 示例 | 高德地图API
  4. 监控程序崩溃重启_Bug 10 重启和正常输入的抉择记录
  5. 前端学习(1420):ajax的post请求
  6. Eclipse安装Rust插件 (Ubuntu)
  7. 腾讯云与阿里云竞争激烈:销售团队积极争取每一笔交易
  8. 基于JAVA+SpringBoot+Mybatis+MYSQL的旅游网站系统
  9. Linux 重启php
  10. python动力学建模与仿真_PyMC3中的简单动力学模型
  11. C#:System.Data.SQLite数据库介绍
  12. 国家统计局:政府统计应用大数据的主要障碍
  13. ModuleNotFoundError: No module named ‘keras.api‘解决
  14. 阿里巴巴分布式消息系统的实践之路
  15. Python简单99例-训练每天
  16. M480 EMAC驱动02-IP101G测试
  17. ES8都有哪些新特性,你还在用ES6吗?
  18. 微端是什么意思?微端对服务器性能配置要求
  19. 【kindle资源】一本不得不读的投资经典《唐朝-手把手教你读财报》
  20. 网页的基本信息及组成HTML文件的基本结构

热门文章

  1. 不等号属于不等式吗_初中数学:关于解不等式应用题的难点突破策略,用了就能拿高分...
  2. Elementui input不能再循环数据中每次自动聚焦的问题
  3. 如何防止WordPress博客内容被恶意复制的教程
  4. Spring Cloud微服务再谈微服务架构(七)
  5. Swift中文教程(二十) 扩展
  6. Shell入门教程:命令替换 $() 和 ``
  7. magento 获取产品的属性值
  8. WampServer的配置
  9. 小顶堆数据结构C/C++代码实现
  10. 目标检测论文阅读:Cascade R-CNN: Delving into High Quality Object Detection(CVPR2018)