MongoDB副本集相关命令

MongoDB副本集相关命令

1 - 配置副本集

1. 启动相关mongod进程

   配置文件需要添加 replSet=xxx 选项。 xxx是副本集的一个名字

2. 初始化

   现在启动的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会解析这个配置对象， 然后给其他成员发送消息，提醒他们使用新的配置
   • 所有成员配置完成后，他们会自动选出一个主节点，然后就可以正常处理读写请求了

3. 主节点. 这个时候，只有主节点可以处理读写请求。

查看主节点：

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. 这是因为：

1. 备份节点可能落后于主节点, 可能没有写入最新的数据
2. 所以，备份节点默认情况下回拒绝读取请求，防止程序拿到过期数据

如果希望从备份节点读取数据，可以把slaveOk设置为true:

1. 配置文件修改
   或者

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函数。

1. rs.add("host:port") => 添加一个节点

2. rs.remove("host:port") => 删除成员

3. rs.config() => 查看副本集配置

4. rs.reconfig(config) => 根据config配置对象，重新配置副本集

注意：重新配置副本集时， 主节点会先退化为备份节点, 以便接受新的配置。然后会恢复。这段时间，副本集中可能没有主节点，之后会恢复