10.MongoDB 副本集的创建和操作

 

1.副本集-Replica Sets

MongoDB中的副本集(Replica Set)是一组维护相同数据集的mongod服务。 副本集可提供冗余和高可用性,是所有生产部署的基础。

也可以说,副本集类似于有自动故障恢复功能的主从集群。通俗的讲就是用多台机器进行同一数据的异步同步,从而使多台机器拥有同一数据的多个副本,并且当主库当掉时在不需要用户干预的情况下自动切换其他备份服务器做主库。而且还可以利用副本服务器做只读服务器,实现读写分离,提高负载。

(1) 冗余和数据可用性

副本提供冗余并提高数据可用性。 通过在不同数据库服务器上提供多个数据副本,副本可提供一定级别的容错功能,以防止丢失单个数据库服务器。

在某些情况下,副本可以提供增加的读取性能,因为客户端可以将读取操作发送到不同的服务上, 在不同数据中心维护数据副本可以增加分布式应用程序的数据位置和可用性。还可以为专用目的维护其他副本,例如灾难恢复,报告或备份。

(2) MongoDB中的复制

副本集是一组维护相同数据集的mongod实例。 副本集包含多个数据承载节点和可选的一个仲裁节点。在承载数据的节点中,一个且仅一个成员被视为主节点,而其他节点被视为次要(从)节点。

主节点接收所有写操作。 副本集只能有一个主节点能够写入; 虽然在某些情况下,另一个mongod实例可能暂时认为自己也是主要的。主要记录其操作日志中的数据集的所有
更改,即oplog

辅助(副本)节点复制主节点的oplog并将操作应用于其数据集,以使辅助节点的数据集反映主节点的数据集。 如果主节点不在,则将举行选举选出新的主节点。

(3) 主从复制和副本集区别

主从集群和副本集最大的区别就是副本集没有固定的“主节点”;整个集群会选出一个“主节点”,当其shutdown后,又在剩下的从节点中选中其他节点为“主节点”,副本集总有一个活跃点(主、primary)和一个或多个备份节点(从、secondary)。

2.副本集的三个角色

副本集有两种类型和三种角色

两种类型:

  • 主节点(Primary)类型:数据操作的主要连接点,可读写。
  • 次要(辅助、从)节点(Secondaries)类型:数据冗余备份节点,可以读或选举

三种角色:

  • 主要成员(Primary):主要接收所有写操作。就是主节点。
  • 副本成员(Replicate):从主节点通过复制操作以维护相同的数据集,即备份数据,不可写操作,但可以读操作(但需要配置)。是默认的一种从节点类型。
  • 仲裁者(Arbiter):不保留任何数据的副本,只具有投票选举作用。当然也可以将仲裁服务器维护为副本集的一部分,即副本成员同时也可以是仲裁者。也是一种从节点类型

关于仲裁者的额外说明:

您可以将额外的mongod实例添加到副本集作为仲裁者。 仲裁者不维护数据集。 仲裁者的目的是通过响应其他副本集成员的心跳和选举请求来维护副本集中的仲裁。 因为它们不存储数据集,所以仲裁器可以是提供副本集仲裁功能的好方法,其资源成本比具有数据集的全功能副本集成员更便宜

如果副本集具有偶数个成员,请添加仲裁者以获得主要选举中的“大多数”投票。 仲裁者不需要专用硬件

仲裁者将永远是仲裁者,而主节点可能会退出并成为从节点,而从节点可能成为选举期间的主节点

如果你的副本+主节点的个数是偶数,建议加一个仲裁者,形成奇数,容易满足大多数的投票

如果你的副本+主节点的个数是奇数,可以不加仲裁者

3.副本集的创建

仲裁节点和数据节点不能运行在同一台主机上

搭建一个副本集:具有1个主节点,1个从节点,1个仲裁节点

(1) 创建主节点

新建存放数据和日志的目录

1
2
mkdir -p /mongodb/replica_sets/myrs_27017/log
mkdir -p /mongodb/replica_sets/myrs_27017/data/db

新建配置文件 mongod.conf

1
vim /mongodb/replica_sets/myrs_27017/mongod.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
systemLog:
#MongoDB发送所有日志输出的目标指定为文件
destination: file
#mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
path: "/mongodb/replica_sets/myrs_27017/log/mongod.log"
#当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
logAppend: true
storage:
#mongod实例存储其数据的目录。storage.dbPath设置仅适用于mongod。
dbPath: "/mongodb/replica_sets/myrs_27017/data/db"
journal:
#启用或禁用持久性日志以确保数据文件保持有效和可恢复。
enabled: true
processManagement:
#启用在后台运行mongos或mongod进程的守护进程模式。
fork: true
#指定用于保存mongos或mongod进程的进程ID的文件位置,其中mongos或mongod将写入其PID
pidFilePath: "/mongodb/replica_sets/myrs_27017/log/mongod.pid"
net:
#服务实例绑定所有IP,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
#bindIpAll: true
#服务实例绑定的IP
bindIp: localhost,192.168.76.128
#bindIp
#绑定的端口
port: 27017
replication:
#副本集的名称
replSetName: myrs

启动节点服务:

1
./mongod -f /mongodb/replica_sets/myrs_27017/mongod.conf

(2) 创建副本节点

新建存放数据和日志的目录

1
2
mkdir -p /mongodb/replica_sets/myrs_27018/log
mkdir -p /mongodb/replica_sets/myrs_27018/data/db

新建配置文件 mongod.conf

1
vim /mongodb/replica_sets/myrs_27018/mongod.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
systemLog:
#MongoDB发送所有日志输出的目标指定为文件
destination: file
#mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
path: "/mongodb/replica_sets/myrs_27018/log/mongod.log"
#当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
logAppend: true
storage:
#mongod实例存储其数据的目录。storage.dbPath设置仅适用于mongod。
dbPath: "/mongodb/replica_sets/myrs_27018/data/db"
journal:
#启用或禁用持久性日志以确保数据文件保持有效和可恢复。
enabled: true
processManagement:
#启用在后台运行mongos或mongod进程的守护进程模式。
fork: true
#指定用于保存mongos或mongod进程的进程ID的文件位置,其中mongos或mongod将写入其PID
pidFilePath: "/mongodb/replica_sets/myrs_27018/log/mongod.pid"
net:
#服务实例绑定所有IP,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
#bindIpAll: true
#服务实例绑定的IP
bindIp: localhost,192.168.76.128
#bindIp
#绑定的端口
port: 27018
replication:
#副本集的名称
replSetName: myrs

启动节点服务:

1
./mongod -f /mongodb/replica_sets/myrs_27018/mongod.conf

(3) 创建仲裁节点

新建存放数据和日志的目录

1
2
mkdir -p /mongodb/replica_sets/myrs_27019/log
mkdir -p /mongodb/replica_sets/myrs_27019/data/db

新建配置文件 mongod.conf

1
vim /mongodb/replica_sets/myrs_27019/mongod.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
systemLog:
#MongoDB发送所有日志输出的目标指定为文件
destination: file
#mongod或mongos应向其发送所有诊断日志记录信息的日志文件的路径
path: "/mongodb/replica_sets/myrs_27019/log/mongod.log"
#当mongos或mongod实例重新启动时,mongos或mongod会将新条目附加到现有日志文件的末尾。
logAppend: true
storage:
#mongod实例存储其数据的目录。storage.dbPath设置仅适用于mongod。
dbPath: "/mongodb/replica_sets/myrs_27019/data/db"
journal:
#启用或禁用持久性日志以确保数据文件保持有效和可恢复。
enabled: true
processManagement:
#启用在后台运行mongos或mongod进程的守护进程模式。
fork: true
#指定用于保存mongos或mongod进程的进程ID的文件位置,其中mongos或mongod将写入其PID
pidFilePath: "/mongodb/replica_sets/myrs_27019/log/mongod.pid"
net:
#服务实例绑定所有IP,有副作用,副本集初始化的时候,节点名字会自动设置为本地域名,而不是ip
#bindIpAll: true
#服务实例绑定的IP
bindIp: localhost,192.168.76.132
#bindIp
#绑定的端口
port: 27019
replication:
#副本集的名称
replSetName: myrs

启动节点服务:

1
./mongod -f /mongodb/replica_sets/myrs_27019/mongod.conf

(4) 初始化配置副本集和主节点

连接主节点

1
./mongo --host=192.168.76.128 --port=27017

执行 rs.initiate()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
> rs.initiate()
{
"info2" : "no configuration specified. Using a default configuration for the set",
"me" : "192.168.76.128:27017",
"ok" : 1,
"operationTime" : Timestamp(1679578804, 1),
"$clusterTime" : {
"clusterTime" : Timestamp(1679578804, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}
myrs:SECONDARY>
myrs:PRIMARY>

提示:

  1. "ok" 的值为1,说明创建成功。
  2. 命令行提示符发生变化,变成了一个从节点角色,此时默认不能读写。稍等片刻,回车,变成主节点。

(5) 查看副本集的配置内容

1
rs.conf()

1
rs.config()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
myrs:PRIMARY> rs.conf()
{
"_id" : "myrs",
"version" : 1,
"protocolVersion" : NumberLong(1),
"writeConcernMajorityJournalDefault" : true,
"members" : [
{
"_id" : 0,
"host" : "192.168.76.128:27017",
"arbiterOnly" : false,
"buildIndexes" : true,
"hidden" : false,
"priority" : 1,
"tags" : {

},
"slaveDelay" : NumberLong(0),
"votes" : 1
}
],
"settings" : {
"chainingAllowed" : true,
"heartbeatIntervalMillis" : 2000,
"heartbeatTimeoutSecs" : 10,
"electionTimeoutMillis" : 10000,
"catchUpTimeoutMillis" : -1,
"catchUpTakeoverDelayMillis" : 30000,
"getLastErrorModes" : {

},
"getLastErrorDefaults" : {
"w" : 1,
"wtimeout" : 0
},
"replicaSetId" : ObjectId("641c56b4e9c70f2cb79cc559")
}
}

说明:

  1. “_id” : “myrs” :副本集的配置数据存储的主键值,默认就是副本集的名字
  2. “members” :副本集成员数组,此时只有一个: “host” : “192.168.76.128:27017” ,该成员不是仲裁节点: “arbiterOnly” : false ,优先级(权重值): “priority” : 1,
  3. “settings” :副本集的参数配置

提示:副本集配置的查看命令,本质是查询的是 system.replset 的表中的数据:

1
2
3
4
5
6
7
8
9
10
11
12
13
myrs:PRIMARY> use local
switched to db local
myrs:PRIMARY> show collections
oplog.rs
replset.election
replset.minvalid
replset.oplogTruncateAfterPoint
startup_log
system.replset
system.rollback.id
myrs:PRIMARY> db.system.replset.find()
{ "_id" : "myrs", "version" : 1, "protocolVersion" : NumberLong(1), "writeConcernMajorityJournalDefault" : true, "members" : [ { "_id" : 0, "host" : "192.168.76.128:27017", "arbiterOnly" : false, "buildIndexes" : true, "hidden" : false, "priority" : 1, "tags" : { }, "slaveDelay" : NumberLong(0), "votes" : 1 } ], "settings" : { "chainingAllowed" : true, "heartbeatIntervalMillis" : 2000, "heartbeatTimeoutSecs" : 10, "electionTimeoutMillis" : 10000, "catchUpTimeoutMillis" : -1, "catchUpTakeoverDelayMillis" : 30000, "getLastErrorModes" : { }, "getLastErrorDefaults" : { "w" : 1, "wtimeout" : 0 }, "replicaSetId" : ObjectId("641c56b4e9c70f2cb79cc559") } }
myrs:PRIMARY>

(6) 查看副本集状态

检查副本集状态

返回包含状态信息的文档。此输出使用从副本集的其他成员发送的心跳包中获得的数据反映副本集的当前状态。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
myrs:PRIMARY> rs.status()
{
"set" : "myrs",
"date" : ISODate("2023-03-23T13:51:19.189Z"),
"myState" : 1,
"term" : NumberLong(1),
"syncingTo" : "",
"syncSourceHost" : "",
"syncSourceId" : -1,
"heartbeatIntervalMillis" : NumberLong(2000),
"optimes" : {
"lastCommittedOpTime" : {
"ts" : Timestamp(1679579476, 1),
"t" : NumberLong(1)
},
"readConcernMajorityOpTime" : {
"ts" : Timestamp(1679579476, 1),
"t" : NumberLong(1)
},
"appliedOpTime" : {
"ts" : Timestamp(1679579476, 1),
"t" : NumberLong(1)
},
"durableOpTime" : {
"ts" : Timestamp(1679579476, 1),
"t" : NumberLong(1)
}
},
"lastStableCheckpointTimestamp" : Timestamp(1679579456, 1),
"members" : [
{
"_id" : 0,
"name" : "192.168.76.128:27017",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
"uptime" : 1826,
"optime" : {
"ts" : Timestamp(1679579476, 1),
"t" : NumberLong(1)
},
"optimeDate" : ISODate("2023-03-23T13:51:16Z"),
"syncingTo" : "",
"syncSourceHost" : "",
"syncSourceId" : -1,
"infoMessage" : "",
"electionTime" : Timestamp(1679578804, 2),
"electionDate" : ISODate("2023-03-23T13:40:04Z"),
"configVersion" : 1,
"self" : true,
"lastHeartbeatMessage" : ""
}
],
"ok" : 1,
"operationTime" : Timestamp(1679579476, 1),
"$clusterTime" : {
"clusterTime" : Timestamp(1679579476, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}

说明:
1) “set” : “myrs” :副本集的名字
2) “myState” : 1:说明状态正常
3) “members” :副本集成员数组,此时只有一个: “name” : “192.168.76.128:27017” ,该成员的角色是 “stateStr” : “PRIMARY”, 该节点是健康的: “health” : 1 。

(7) 添加副本从节点

1
2
3
4
5
6
7
8
9
10
11
12
myrs:PRIMARY> rs.add("192.168.76.128:27018")
{
"ok" : 1,
"operationTime" : Timestamp(1679579807, 1),
"$clusterTime" : {
"clusterTime" : Timestamp(1679579807, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}

查看副本集状态:

1
myrs:PRIMARY> rs.status()

"name" : "192.168.76.128:27018" 是第二个节点的名字,其角色是 "stateStr" :"SECONDARY"

(8) 添加仲裁从节点

1
2
3
4
5
6
7
8
9
10
11
12
myrs:PRIMARY> rs.addArb("192.168.76.132:27019")
{
"ok" : 1,
"operationTime" : Timestamp(1679579928, 1),
"$clusterTime" : {
"clusterTime" : Timestamp(1679579928, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}

查看副本集状态:

1
myrs:PRIMARY> rs.status()

“name” : “192.168.76.132:27019” 是第三个节点的名字,其角色是 “stateStr” : “ARBITER”

4.副本集的数据读写操作

(1) 在主节点27017,写入和读取数据:

1
./mongo --host=192.168.76.128 --port=27017
1
2
3
4
5
6
7
8
9
10
11
12
myrs:PRIMARY> show databases
admin 0.000GB
config 0.000GB
local 0.000GB
myrs:PRIMARY> use articledb
switched to db articledb
myrs:PRIMARY> db
articledb
myrs:PRIMARY> db.comment.insert({"articleid":"100000","content":"今天天气真好,阳光明媚","userid":"1001","nickname":"Rose","createdatetime":new Date()})
WriteResult({ "nInserted" : 1 })
myrs:PRIMARY> db.comment.find()
{ "_id" : ObjectId("641cc67ab8fd97e6b05dd3bd"), "articleid" : "100000", "content" : "今天天气真好,阳光明媚", "userid" : "1001", "nickname" : "Rose", "createdatetime" : ISODate("2023-03-23T21:36:58.736Z") }

(2) 登录从节点

1
./mongo --host=192.168.76.128 --port=27018
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
myrs:SECONDARY> show databases
2023-03-24T05:37:43.201+0800 E QUERY [js] Error: listDatabases failed:{
"operationTime" : Timestamp(1679607458, 1),
"ok" : 0,
"errmsg" : "not master and slaveOk=false",
"code" : 13435,
"codeName" : "NotMasterNoSlaveOk",
"$clusterTime" : {
"clusterTime" : Timestamp(1679607458, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:139:1
shellHelper.show@src/mongo/shell/utils.js:882:13
shellHelper@src/mongo/shell/utils.js:766:15
@(shellhelp2):1:1

发现从节点不能读取集合的数据。当前从节点只是一个备份,不是 slave 节点,无法读取数据,写当然更不行。因为默认情况下,从节点是没有读写权限的,可以增加读的权限,但需要进行设置。

(3) 将从节点设置为 slave 节点

1
rs.slaveOk()

1
rs.slaveOk(true)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
myrs:SECONDARY> rs.slaveOk()
myrs:SECONDARY>
myrs:SECONDARY> show dbs
admin 0.000GB
articledb 0.000GB
config 0.000GB
local 0.000GB
myrs:SECONDARY> use articledb
switched to db articledb
myrs:SECONDARY> db
articledb
myrs:SECONDARY> show collections
comment
myrs:SECONDARY> db.comment.find()
{ "_id" : ObjectId("641cc67ab8fd97e6b05dd3bd"), "articleid" : "100000", "content" : "今天天气真好,阳光明媚", "userid" : "1001", "nickname" : "Rose", "createdatetime" : ISODate("2023-03-23T21:36:58.736Z") }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
myrs:SECONDARY> db.comment.insert({"_id":"1","articleid":"100001","content":"abc","userid":"1002","nickname":"n","createdatetime":new Date("2019-08-05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"})
WriteCommandError({
"operationTime" : Timestamp(1679611178, 1),
"ok" : 0,
"errmsg" : "not master",
"code" : 10107,
"codeName" : "NotMaster",
"$clusterTime" : {
"clusterTime" : Timestamp(1679611178, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
})

slave 节点可以读取数据,但是不能写入数据

实现了读写分离,让主节点插入数据,让从节点来读取数据

(4) 取消 slave 节点的读权限

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
myrs:SECONDARY> rs.slaveOk(false)
myrs:SECONDARY> db.comment.find()
Error: error: {
"operationTime" : Timestamp(1679611318, 1),
"ok" : 0,
"errmsg" : "not master and slaveOk=false",
"code" : 13435,
"codeName" : "NotMasterNoSlaveOk",
"$clusterTime" : {
"clusterTime" : Timestamp(1679611318, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}

(5) 仲裁者节点,不存放任何业务数据的

1
./mongo --host=192.168.76.132 --port=27019
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
myrs:ARBITER> show dbs
2023-03-24T23:30:45.841+0800 E QUERY [js] Error: listDatabases failed:{
"ok" : 0,
"errmsg" : "not master and slaveOk=false",
"code" : 13435,
"codeName" : "NotMasterNoSlaveOk"
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:139:1
shellHelper.show@src/mongo/shell/utils.js:882:13
shellHelper@src/mongo/shell/utils.js:766:15
@(shellhelp2):1:1
myrs:ARBITER> rs.slaveOk(true)
myrs:ARBITER> show dbs
local 0.000GB
myrs:ARBITER> use local
switched to db local
myrs:ARBITER> show collections
replset.election
replset.minvalid
replset.oplogTruncateAfterPoint
startup_log
system.replset
system.rollback.id

仲裁者节点只存放副本集配置等数据

5.主节点的选举原则

MongoDB在副本集中,会自动进行主节点的选举,主节点选举的触发条件:

  1. 主节点故障
  2. 主节点网络不可达(默认心跳信息为10秒)
  3. 人工干预(rs.stepDown(600))

一旦触发选举,就要根据一定规则来选主节点

选举规则是根据票数来决定谁获胜:

  • 票数最高,且获得了“大多数”成员的投票支持的节点获胜。“大多数”的定义为:假设复制集内投票成员数量为N,则大多数为 N/2 + 1。例如:3个投票成员,则大多数的值是2。当复制集内存活成员数量不足大多数时,整个复制集将无法选举出Primary,复制集将无法提供写服务,处于只读状态。

  • 若票数相同,且都获得了“大多数”成员的投票支持的,数据新的节点获胜。数据的新旧是通过操作日志oplog来对比的

在获得票数的时候,优先级(priority)参数影响重大

可以通过设置优先级(priority)来设置额外票数。优先级即权重,取值为0-1000,相当于可额外增加0-1000的票数,优先级的值越大,就越可能获得多数成员的投票(votes)数。指定较高的值可使成员更有资格成为主要成员,更低的值可使成员更不符合条件

默认情况下,优先级的值是1

(1) 查看节点的优先级配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
myrs:PRIMARY> rs.conf()
{
"_id" : "myrs",
"version" : 3,
"protocolVersion" : NumberLong(1),
"writeConcernMajorityJournalDefault" : true,
"members" : [
{
"_id" : 0,
"host" : "192.168.76.128:27017",
"arbiterOnly" : false,
"buildIndexes" : true,
"hidden" : false,
"priority" : 1,
"tags" : {

},
"slaveDelay" : NumberLong(0),
"votes" : 1
},
{
"_id" : 1,
"host" : "192.168.76.128:27018",
"arbiterOnly" : false,
"buildIndexes" : true,
"hidden" : false,
"priority" : 1,
"tags" : {

},
"slaveDelay" : NumberLong(0),
"votes" : 1
},
{
"_id" : 2,
"host" : "192.168.76.132:27019",
"arbiterOnly" : true,
"buildIndexes" : true,
"hidden" : false,
"priority" : 0,
"tags" : {

},
"slaveDelay" : NumberLong(0),
"votes" : 1
}
],
"settings" : {
"chainingAllowed" : true,
"heartbeatIntervalMillis" : 2000,
"heartbeatTimeoutSecs" : 10,
"electionTimeoutMillis" : 10000,
"catchUpTimeoutMillis" : -1,
"catchUpTakeoverDelayMillis" : 30000,
"getLastErrorModes" : {

},
"getLastErrorDefaults" : {
"w" : 1,
"wtimeout" : 0
},
"replicaSetId" : ObjectId("641c56b4e9c70f2cb79cc559")
}
}

可以看出,主节点和副本节点的优先级各为1,即,默认可以认为都已经有了一票。但仲裁节点,优先级是0,仲裁节点的优先级必须是0,不能是别的值。即不具备选举权,但具有投票权

(2) 修改节点的优先级

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
myrs:PRIMARY> cfg = rs.conf()
myrs:PRIMARY> cfg.members[0].priority=20
20
myrs:PRIMARY> rs.reconfig(cfg)
{
"ok" : 1,
"operationTime" : Timestamp(1679665821, 1),
"$clusterTime" : {
"clusterTime" : Timestamp(1679665821, 1),
"signature" : {
"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
"keyId" : NumberLong(0)
}
}
}

稍等片刻会重新开始选举

6.故障测试

(1) 从节点故障测试

从节点失效不会影响主节点,主节点可以正常读取和写入数据

当从节点重启之后,会自动从主节点同步数据

(2) 主节点故障测试

关闭主节点后,从节点和仲裁节点对主节点的心跳失败,当失败超过10秒,此时因为没有主节点了,会自动发起投票。

而从节点只有一个,因此,候选人只有一个

开始投票,仲裁节点向从节点投了一票,从节点本身自带一票,因此共两票,超过了“大多数”

仲裁节点没有选举权,从节点不向其投票,其票数是0.

最终结果,原从节点成为新主节点。具备读写功能,可以正常读写数据

再启动原主节点,原主节点变为从节点,自动从新主节点同步数据,新主节点保持不变

(3) 仲裁节点和主节点故障

关闭仲裁节点和主节点后,从节点保持是从节点,整个副本集为只读状态,无法写入数据

因为在选举中,从节点只有本身的1票,没有达到大多数选票

如果要触发选择,再加入一个节点即可

若加入原仲裁节点,则从节点成为新的主节点

若加入原主节点,则数据较新的节点成为主节点

(4) 仲裁节点和从节点故障

关闭仲裁节点和从节点后,主节点降级为从节点,整个副本集变为只读状态