首页 > > 网络编程 > 其它 >

MongoDB学习笔记——Replica Set副本集

2018-06-17 19:51:48来源：未知阅读 ()

副本集

可以将MongoDB中的副本集看作一组服务器集群由一个主节点和多个副本节点等组成，相对于之前讲到的主从复制提供了故障自动转移的功能

副本集实现数据同步的方式依赖于local数据库中的oplog数据

oplog是存在与主节点或副本节点上的local数据库中的一个固定集合，记录了每一次主节点的写操作，或副本节点每一次从主节点复制数据的操作
备份节点通过定时从主节点获取oplog数据，并在本机执行这些操作来实现主从复制的功能，同样的每个副本节点也可以作为数据源给其他成员使用
备份节点在本机上执行完从主节点获取到的oplog数据后，会在自己的local数据库中记录这些的操作
如果某个副本节点由于某些原因宕机了，当重启后会从oplog中最后一个操作开始进行同步，由于复制过程是先进行复制再写入本机oplog的，所以副本节点可能会在已经同步过的数据上再次执行复制操作，不过oplog中的统一操作执行多次与执行一次效果是一样的

oplog字段说明

ts:执行某个操作的时间戳
op:操作类型（i-insert;d-delete;u-update）
ns:操作的集合的名称
o:document的内容

副本集中的各种角色

主节点——有且只有一个，默认处理了所有的客户端请求（读和写）
副本节点——可以有多个，保存主节点的副本数据，当主节点出问题时可以通过投票升级为主节点，可以处理客户端的只读请求
仲裁节点——不进行数据复制存储，也不为客户端提供服务，唯一的作用是进行故障转移时的投票，选举出新的主节点仲裁节点一旦被设置则永远不能成为非仲裁节点，反之一样一个副本集集群中最多只能有一个仲裁节点，如果节点总数为基数时就不需要配置仲裁节点了，因为仲裁节点的作用就是在节点总数为偶数时，如果一半投票给A，一半头片给B这时仲裁节点就持有关键性的一票如果有可能尽量使用奇数的集群节点，不要使用仲裁节点
隐藏节点——不为客户端提供服务，永远不会成为主节点但是会参与投票，进行数据的复制存储，一般用作数据备份如果要设置一个节点为隐藏设置其hidden属性为true即可只有优先级priority=0的节点才能被设置为隐藏
延迟同步节点——一般会人为设置一个延迟时间（单位秒）来从主节点同步数据，主要就是用于数据的备份，当数据库发生毁灭性灾难时进行数据恢复延迟同步节点的优先级priority=0并且是隐藏节点，避免读请求被路由到延迟同步节点上通过属性slaveDelay（单位秒）来设置一个节点的延迟同步时间
Secondary-Only——通常将性能不高的节点设置为此类型，防止其成为主节点，优先级priority=0
Non-Voting——没有投票权的副本节点，纯粹用于数据备份，一般只有当节点总数超过12个时才会被使用，通过votes=0设置其为Non-Voting节点

部署副本集

创建主从key文件，用于表示集群私钥的完整路径，如果各个实例的密钥不一致则程序不能正常使用

openssl rand -base64 100 > key

//replica set 0

systemLog:

path: D:\mongodb\replicaSet\rs0\logs\mongodb.log

logAppend: true

destination: file

storage:

dbPath: D:\mongodb\replicaSet\rs0\data

net:

port: 27017

bindIp: 127.0.0.1

security:

keyFile: D:\mongodb\replicaSet\rs0\key

replication:

replSetName: replcaSetTest

secondaryIndexPrefetch: all

//relica set 1

systemLog:

path: D:\mongodb\replicaSet\rs1\logs\mongodb.log

logAppend: true

destination: file

storage:

dbPath: D:\mongodb\replicaSet\rs1\data

net:

port: 27018

bindIp: 127.0.0.1

security:

keyFile: D:\mongodb\replicaSet\rs1\key

replication:

replSetName: replcaSetTest

secondaryIndexPrefetch: all

//relica set 2

systemLog:

path: D:\mongodb\replicaSet\rs2\logs\mongodb.log

logAppend: true

destination: file

storage:

dbPath: D:\mongodb\replicaSet\rs2\data

net:

port: 27019

bindIp: 127.0.0.1

security:

keyFile: D:\mongodb\replicaSet\rs2\key

replication:

replSetName: replcaSetTest

secondaryIndexPrefetch: all

启动以上三个实例

mongod -config D:\mongodb\replicaSet\rs0\mongodb.conf

mongod -config D:\mongodb\replicaSet\rs1\mongodb.conf

mongod -config D:\mongodb\replicaSet\rs2\mongodb.conf

配置及初始化副本集

rsConfig = {

_id: "replcaSetTest",

members: [{ _id: 0, host: "127.0.0.1:27017" },

{ _id: 1, host: "127.0.0.1:27018" },

{ _id: 2, host: "127.0.0.1:27019" }

]

};

rs.initiate(rsConfig);

_id就是启动MongoDB实例时设置的副本集名称，一定要保障两处副本集名称一致 members副本集成员数组,一个唯一的数值类型的_id,一个主机名 rs.initiate()函数用来初始化副本集

输入rs.config()查询配置修改是否成功，竟然提示没有权限

rs.config()

2016-11-23T17:18:00.689+0800 E QUERY [thread1] Error: Could not retrieve replica set config: {

"ok" : 0,

"errmsg" : "not authorized on admin to execute command { replSetGetConfig: 1.0 }",

"code" : 13

}

执行以下名称创建创建管理员账户，并授予权限，创建成功后执行db.auth()?命令进行登录授权

db.createUser({

user: 'admin',

pwd: 'mongodb_123',

roles: [{ "role": "clusterAdmin", "db": "admin" },

{ "role": "userAdminAnyDatabase", "db": "admin" },

{ "role": "dbAdminAnyDatabase", "db": "admin" },

{ role: "root", db: "admin" }

]

})

db.auth("admin","mongodb_123")

再次执行rs.config()得到以下信息

rs.config()

{

"_id" : "replcaSetTest",

"version" : 1,

"protocolVersion" : NumberLong(1),

"members" : [

{

"_id" : 0,

"host" : "127.0.0.1:27017",

"arbiterOnly" : false,

"buildIndexes" : true,

"hidden" : false,

"priority" : 1,

"tags" : {

"slaveDelay" : NumberLong(0),

"votes" : 1

{

"_id" : 1,

"host" : "127.0.0.1:27018",

"arbiterOnly" : false,

"buildIndexes" : true,

"hidden" : false,

"priority" : 1,

"tags" : {

"slaveDelay" : NumberLong(0),

"votes" : 1

{

"_id" : 2,

"host" : "127.0.0.1:27019",

"arbiterOnly" : false,

"buildIndexes" : true,

"hidden" : false,

"priority" : 1,

"tags" : {

"slaveDelay" : NumberLong(0),

"votes" : 1

}

"settings" : {

"chainingAllowed" : true,

"heartbeatIntervalMillis" : 2000,

"heartbeatTimeoutSecs" : 10,

"electionTimeoutMillis" : 10000,

"getLastErrorModes" : {

"getLastErrorDefaults" : {

"w" : 1,

"wtimeout" : 0

"replicaSetId" : ObjectId("5835597e61b9c2f7c562b9b0")

}

version 在每次修改副本集配置时都会递增，初始值为1?rs.starus()或rs.isMaster()?指令可以查询当前副本集的状态

local数据库中不仅有oplog日志集合，还有一个用于记录主从配置信息的集——system.replset 通过这个集合可以查看副本集的配置信息当然在每个实例上执行rs.config()或rs.conf()也能达到同样的效果

db.system.replset.find()

在主节点上创建测试数据

use myReplSetTest

for (i = 5000; i < 100000; i++) {

db.users.insert({

"i": i,

"userName": "user" + i,

"age": Math.floor(Math.random() * 120),

"created": new Date(),

total: Math.floor(Math.random() * 100) * i

})

}

db.users.find()

在主节点上执行查询OK，但是当在副本节点进行执行是则报错,提示不是主节点并且slaveOk=false不能执行查询操作

QUERY [thread1] Error: listCollections failed: { "ok" : 0, "errmsg" : "not master and slaveOk=false", "code" : 13435 }

在副本节点中执行名称db.setSlaveOk()让副本节点可以读取数据，分单主库压力达到读写分离的效果，再次执行db.users.find()就正常了

副本集管理

rs.add()可以添加节点添加节点的方式有两种： 1.通过oplog直接添加，这种方式添加节点过程中不需要过多的人工干预就可以完成，但是如果频繁的插入修改等操作会导致oplog数据较大，在进行复制时会使源节点的压力较大并且oplog是固定集合，因为他的特性可能会导致复制的数据不一致 2.通过数据库快照（--fastsync）获取某一个副本节点的物理文件来做初始化数据，剩余的部分通过oplog日志进行追加可以解决上述的问题，