MongoDB副本集相关命令
1 - 配置副本集
-
启动相关mongod进程
配置文件需要添加
replSet=xxx选项。 xxx是副本集的一个名字 -
初始化
现在启动的mongod进程还只是相互独立的，彼此之间不会相互感知。所以，需要创建一个配置文件，列出副本集中的每一个成员。
然后发给一个mongod实例。
var config = { "_id" : "iepac_replset", "members" : [ { "_id": 0, "host": "192.168.35.131:3000"}, { "_id": 1, "host": "192.168.35.131:3001"}, { "_id": 2, "host": "192.168.35.131:3002"} ] }config对象就是副本集的配置. 把这个配置文件发送给一个节点：
$ /data/mongodb-1/bin/mongo 192.168.35.131:3000 > rs.initiate(config);- 使用
rs.initiate(config);初始化。等价于db.adminCommand({"replSetInitiate": config}) - 3000的mongod会解析这个配置对象， 然后给其他成员发送消息，提醒他们使用新的配置
- 所有成员配置完成后，他们会自动选出一个主节点，然后就可以正常处理读写请求了
- 使用
主节点. 这个时候，只有主节点可以处理读写请求。
查看主节点：
iepac_replset:SECONDARY> rs.isMaster();
{
"hosts" : [
"192.168.35.131:3000",
"192.168.35.131:3001",
"192.168.35.131:3002"
],
"setName" : "iepac_replset",
"setVersion" : 1,
"ismaster" : true,
"secondary" : false,
"primary" : "192.168.35.131:3000",
"me" : "192.168.35.131:3000",
"electionId" : ObjectId("7fffffff0000000000000001"),
"maxBsonObjectSize" : 16777216,
"maxMessageSizeBytes" : 48000000,
"maxWriteBatchSize" : 1000,
"localTime" : ISODate("2016-05-25T13:52:19.654Z"),
"maxWireVersion" : 4,
"minWireVersion" : 0,
"ok" : 1
}
在secondary上进行如下操作：
iepac_replset:SECONDARY> use sns;
switched to db sns
iepac_replset:SECONDARY> db.imlog.insert({"sendor":17080032629});
WriteResult({ "writeError" : { "code" : 10107, "errmsg" : "not master" } })
iepac_replset:SECONDARY> db.imlog.find();
Error: error: { "ok" : 0, "errmsg" : "not master and slaveOk=false", "code" : 13435 }
插入数据时，提示不是主节点。查询数据时，提示不是主节点，并且slaveOk是false. 这是因为：
- 备份节点可能落后于主节点, 可能没有写入最新的数据
- 所以，备份节点默认情况下回拒绝读取请求，防止程序拿到过期数据
如果希望从备份节点读取数据，可以把slaveOk设置为true:
- 配置文件修改
或者
bin/mongo --nodb
> conn = new Mongo("192.168.35.131:3001");
> conn.setSlaveOk();
mongo --nodb => 启动一个mongo shell，但是不连接任何mongod.
但是写入操作还是拒绝的：备份节点只能通过复制写入数据，不接受客户端的写入请求.
> conn.getDB("sns").imlog.insert({"sender":17096836213});
WriteResult({ "writeError" : { "code" : 10107, "errmsg" : "not master" } })
插入1w个文档:
> var func = function() {
... var begin = new Date();
... for (var i = 10000; i < 20000; i++) {
... db.imlog.insert({"sender":i});
... }
... var end = new Date();
... print('耗时:' + (end - begin));
... };
> func();
2 - 修改配置
可以随时修改副本集的配置：添加、删除、修改已有的成员。很多常用的操作都有对应的shell函数。
rs.add("host:port")=> 添加一个节点rs.remove("host:port")=> 删除成员rs.config()=> 查看副本集配置rs.reconfig(config)=> 根据config配置对象，重新配置副本集
注意：重新配置副本集时， 主节点会先退化为备份节点, 以便接受新的配置。然后会恢复。这段时间，副本集中可能没有主节点，之后会恢复
