首页 / MONGODB / MongoDB --- 复制集方法

MongoDB --- 复制集方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了MongoDB --- 复制集方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6628字，纯文字阅读大概需要10分钟。

内容图文

此次介绍的方法都是运行在mongo shell 上的。

1、rs.add()

https://docs.mongodb.com/manual/reference/method/rs.add/#mongodb-method-rs.add

添加成员，mongo shell（客户端）必须连接到主节点primary 才能运行此方法

rs.add(host, arbiterOnly)

Parameter	Type	Description
host	string or document	新成员。如果是字符串：主机名:端口号。如果文档：则和复制集配置文档中的成员配置一样
arbiterOnly	boolean	可选，只有 host 是字符串才生效。如果 true ，则新成员是仲裁者

host 文档字段

 {
   _id: <int>,
   host: <string>,        // required
   arbiterOnly: <boolean>,
   buildIndexes: <boolean>,
   hidden: <boolean>,
   priority: <number>,
   tags: <document>,
   slaveDelay: <int>,
   votes: <number>
}

默认 mongod 和 mongos 讲 ip 绑定到本机。所以只接受本机客户端的连接，而不接受远程客户端的连接。
可以在 mongod 配置文件中配置 net.bindIp
也可以直接在启动mongod 时在命令行中设置

#绑定本机 和 My-Example-Associated-Hostname
mongod --bind_ip localhost,My-Example-Associated-Hostname

添加新成员时，新成员的优先级priority比现主节点高，会触发主节点选举，并且断开shell连接，还会返回一个错误。

新成员如果 priority 和 votes 都大于 0 ，那么在其刚刚加入副本集时，可以作为一投票成员，但不能成为一个 primary ，也不能对外提供读取服务，因为数据还未同步。
这可能会导致，投票的大多数成员都在线，但不能确定 primary 。为避免这种情况，新添加的成员设置 priority :0 , votes :0。等该成员的状态state，变为 SECONDARY，再使用 rs.reconfig() 更新 priority 和 votes.

## 向新的复制集添加成员，默认priority: 1, votes: 1
rs.add( { host: "mongodbd4.example.net:27017" } )
#或者
rs.add( "mongodbd4.example.net:27017" )



## 向已存在的复制集添加成员

#添加 priority 和 votes 都为 0
rs.add( { host: "mongodbd4.example.net:27017", priority: 0, votes: 0 } )

# 查看状态，确保新成员已经是 SECONDARY 状态
rs.status()

# 在重新配置
var cfg = rs.conf();
cfg.members[n].priority = 1;  // Substitute the correct array index for the new member
cfg.members[n].votes = 1;     // Substitute the correct array index for the new member
rs.reconfig(cfg)

2. rs.addArb()

https://docs.mongodb.com/manual/reference/method/rs.addArb/

向已存在的复制集中添加仲裁者节点

rs.addArb(host)

host : 字符串，新成员的主机名:端口号

3 rs.conf() rs.config()

https://docs.mongodb.com/manual/reference/method/rs.conf/

返回当前复制集的配置对象

rs.conf() 无参数

rs.config() 是 rs.conf() 的别名

//返回对象
{
  _id: <string>,
  version: <int>,
  term: <int>,
  protocolVersion: <number>,
  writeConcernMajorityJournalDefault: <boolean>,
  configsvr: <boolean>,
  members: [
    {
      _id: <int>,
      host: <string>,
      arbiterOnly: <boolean>,
      buildIndexes: <boolean>,
      hidden: <boolean>,
      priority: <number>,
      tags: <document>,
      slaveDelay: <int>,
      votes: <number>
    },
    ...
  ],
  settings: {
    chainingAllowed : <boolean>,
    heartbeatIntervalMillis : <int>,
    heartbeatTimeoutSecs: <int>,
    electionTimeoutMillis : <int>,
    catchUpTimeoutMillis : <int>,
    getLastErrorModes : <document>,
    getLastErrorDefaults : <document>,
    replicaSetId: <ObjectId>
  }
}

复制集配置文档详情：https://docs.mongodb.com/manual/reference/replica-configuration/

4 rs.freeze()

https://docs.mongodb.com/manual/reference/method/rs.freeze/

使当前复制集成员在一段时间内，不能成员 primary

rs.freeze(seconds)

5 rs.help()

返回复制集相关方法的帮助文本

6 rs.initiate()

https://docs.mongodb.com/manual/reference/method/rs.initiate/

初始化复制集

rs.initiate(configuration)

初始化只能在一个mongod实例上运行。

参数

Parameter	Type	Description
configuration	document	可选，复制集配置文档选项

rs.initiate(
   {
      _id: "myReplSet",
      version: 1,
      members: [
         { _id: 0, host : "mongodb0.example.net:27017" },
         { _id: 1, host : "mongodb1.example.net:27017" },
         { _id: 2, host : "mongodb2.example.net:27017" }
      ]
   }
)

7. rs.reconfig()

https://docs.mongodb.com/manual/reference/method/rs.reconfig/#mongodb-method-rs.reconfig

重新配置现有复制集，覆盖现有复制集配置。要运行该方法，必须连接到复制集的主节点。

rs.reconfig( configuration, { options } )

rs.reconfig(
  <configuration>,    // 配置项
  {
    "force" : <boolean>,  // 可选，指定true强制可用的复制集成员接受新配置。默认值为false
    "maxTimeMS" : <int>   //可选， 指定处理rs.reconfig()操作的累积时间限制(以毫秒为单位)。缺省情况下，rs.reconfig()无限期地等待复制配置传播到大多数复制集成员。
  }
)

要重新配置现有的复制集，首先使用rs.conf()得到当前配置，根据需要修改配置文档，然后将修改后的文档传递给rs.reconfig()。

从MongoDB 4.4开始，rs.reconfig()默认允许一次添加或删除不超过1个投票成员。修改一个成员的 votes属性也会是投票成员的增减

原来的配置

{
   "_id" : "rs0",
   "version" : 1,
   "protocolVersion" : NumberLong(1),
   "members" : [
      {
         "_id" : 0,
         "host" : "mongodb0.example.net:27017",
         "arbiterOnly" : false,
         "buildIndexes" : true,
         "hidden" : false,
         "priority" : 1,
         "tags" : {

         },
         "slaveDelay" : NumberLong(0),
         "votes" : 1
      },
      {
         "_id" : 1,
         "host" : "mongodb1.example.net:27017",
         "arbiterOnly" : false,
         "buildIndexes" : true,
         "hidden" : false,
         "priority" : 1,
         "tags" : {

         },
         "slaveDelay" : NumberLong(0),
         "votes" : 1
      },
      {
         "_id" : 2,
         "host" : "mongodb2.example.net: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" : 2000,
      "getLastErrorModes" : {

      },
      "getLastErrorDefaults" : {
         "w" : 1,
         "wtimeout" : 0
      },
      "replicaSetId" : ObjectId("58858acc1f5609ed986b641b")
   }
}

重新配置

cfg = rs.conf();
cfg.members[1].priority = 2;
rs.reconfig(cfg);

重新配置后

{
   "_id" : "rs0",
   "version" : 2,
   "protocolVersion" : NumberLong(1),
   "members" : [
      {
         "_id" : 0,
         "host" : "mongodb0.example.net:27017",
         "arbiterOnly" : false,
         "buildIndexes" : true,
         "hidden" : false,
         "priority" : 1,
         "tags" : {

         },
         "slaveDelay" : NumberLong(0),
         "votes" : 1
      },
      {
         "_id" : 1,
         "host" : "mongodb1.example.net:27017",
         "arbiterOnly" : false,
         "buildIndexes" : true,
         "hidden" : false,
         "priority" : 2,
         "tags" : {

         },
         "slaveDelay" : NumberLong(0),
         "votes" : 1
      },
      {
         "_id" : 2,
         "host" : "mongodb2.example.net: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" : 2000,
      "getLastErrorModes" : {

      },
      "getLastErrorDefaults" : {
         "w" : 1,
         "wtimeout" : 0
      },
      "replicaSetId" : ObjectId("58858acc1f5609ed986b641b")
   }
}

7. rs.printReplicationInfo()

https://docs.mongodb.com/manual/reference/method/rs.printReplicationInfo/

从主服务器的角度打印副本集状态的格式化报告。

rs.printReplicationInfo()

返回文本

configured oplog size:   192MB
log length start to end: 65422secs (18.17hrs)
oplog first event time:  Mon Jun 23 2014 17:47:18 GMT-0400 (EDT)
oplog last event time:   Tue Jun 24 2014 11:57:40 GMT-0400 (EDT)
now:                     Thu Jun 26 2014 14:24:39 GMT-0400 (EDT)

内容总结

以上是互联网集市为您收集整理的MongoDB --- 复制集方法全部内容，希望文章能够帮你解决MongoDB --- 复制集方法所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/857878.html

来源：【匿名】

【上一篇】MongoDB修改数据库名【下一篇】在MongoDB上如何进行数据的导入与导出

更多 ►

【MongoDB --- 复制集方法】教程文章相关的互联网学习教程文章

【MongoDB异常】Exception authenticating MongoCredential解决方法

我们通过ideal编辑器编辑 springboot时候，出现这个错误：com.mongodb.MongoSecurityException: Exception authenticating MongoCredential这个问题说明一件事儿，我们连接数据库没有连接上，为什么连接不上呢，比如我们用mongoDB下面的一个database叫做xiaomu，但是我们的用户名密码是一个database叫做admin下的用户，这样就连不上了。因此，我们在database为xiaomu下面建立一个用户，然后用这个用户进行登录即可。1.打开mongoDB数...

Mongodb For C# "Query" 对象常用的方法【代码】

Query.All("name", "a", "b");//通过多个元素来匹配数组Query.In("name", "a", "b");//包括指定的所有值,可以指定不同类型的条件和值Query.And(Query.EQ("name", "a"), Query.EQ("title", "t"));//同时满足多个条件Query.EQ("name", "a");//等于Query.Exists("type", true);//判断键值是否存在Query.GT("value", 2);//大于>Query.GTE("value", 3);//大于等于>=Query.LT("value", 9);//小于<Query.LTE("value", 8);//小于等于<=Quer...

给MongoDB添加用户权限方法分享

使用Mongodb数据库，需要为各个数据库增加用户权限，查了一下发现下面代码：复制代码代码如下: use test2 db.addUser( { user: "test", pwd: "admin", roles: [ "readWrite", "dbAdmin" ] } )执行后发现：复制代码代码如下: $ mongo 192.168.1.111/test2 -u test -p admin MyMongo:PRIMARY>复制代码代码如下: Error: 18 { ok: 0.0, errmsg: "auth failed", code: 18 } at src/mongo/sh...

mongodb replica set 添加/删除节点方法--http://www.ii123.com/jc/bc/bczh/258948.html

replica set多服务器主从，添加，删除节点，肯定会经常遇到的。下面详细说明一下，添加，删除节点的2种方法。　　一，利用rs.reconfig，来添加，删除节点　　1，添加节点代码如下 repmore:PRIMARY> config = {_id:"repmore",members:[{_id:0,host:‘127.0.0.1:27017‘,priority :2},{_id:1,host:‘127.0.0.1:27018‘,priority:1}]}; //添加节点repmore:PRIMARY> rs.reconfig(config); //使配置生效repmore:PRIMARY> rs.status...

MongoDB学习笔记~为IMongoDBRepository接口添加分页取集合的方法【代码】

对于数据分页，我们已经见的太多了，几乎每个列表页面都要用到分页，这已经成了一种定理了，在进行大数据展示时，如果不去分页，而直接把数据加载到内存，这简直是不可以去相向的，呵呵，在很多ORM工具中都对分页有了更好的支持，如LINQ里有大家熟悉的take和skip，而在MongoDB里也有这种概念，它使用limit和skip实现，这在大多数的Mongo客户端上都集成了这个功能，即帮助我们组合命令参数，并带我们把分页取数据的指令发到Mongo服务...

php实现Mongodb自定义方式生成自增ID的方法【代码】

本文实例讲述了php实现Mongodb自定义方式生成自增ID的方法。分享给大家供大家参考。具体分析如下：复制代码代码如下://首先创建一个自动增长id集合 ids >db.ids.save({name:"user", id:0}); //可以查看一下是否成功 > db.ids.find(); { "_id" : ObjectId("4c637dbd900f00000000686c"), "name" : "user", "id" : 0 } //然后每次添加新用户之前自增一下 ids集合获得id >userid = db.ids.findAndModify({update:{$inc:{‘id‘:1}}, ...

MongoDB中insert方法、update方法、save方法简单对比【图】

MongoDB中insert方法、update方法、save方法简单对比1.update方法　　该方法用于更新数据，是对文档中的数据进行更新，改变则更新，没改变则不变。2.insert方法　　该方法用于插入数据到文档中，也就是给文档添加新数据。3.save方法　　该方法同样用于插入数据到文档中，功能是类似于insert方法的。与insert方法不同的是，save方法是遍历文档，逐条将数据插入进去的，而insert方法是将整个文档整体插入进去的。由两个方法的源码可以...

关于mongodb按照字段模糊查询方法

模糊查询：tname包含某个关键字测试‘cd /opt/soft/mongodb/bin./mongo --host 192.168.0.1 --port 17017 testdb.test_info.find({"tname": {$regex: ‘测试‘, $options:‘i‘}}) db.test_info.find({"tname": {$regex:/测试.*/i}}) 原文：http://www.cnblogs.com/liubaihui/p/7814089.html

MongoDB --- 复制集方法【代码】

此次介绍的方法都是运行在mongo shell 上的。1、rs.add()https://docs.mongodb.com/manual/reference/method/rs.add/#mongodb-method-rs.add添加成员，mongo shell（客户端）必须连接到主节点primary 才能运行此方法rs.add(host, arbiterOnly)ParameterTypeDescriptionhoststring or document新成员。如果是字符串：主机名:端口号。如果文档：则和复制集配置文档中的成员配置一样arbiterOnlyboolean可选，只有 host 是字符串才生...

mongodb增量备份方法【代码】

首先应用了别人写的mongobackup的文件包去这个网址下载：http://pan.baidu.com/s/15YsBs把mongobackup的文件下载到你的mongodb的bin目录下输入chmod a+x mongobackup //让系统编译它然后，重启mongodb简介 mongobackup 是用于复制集的增量备份与恢复工具，恢复时，需要结合全量备份与恢复使用。增量备份普通备份mongobackup --backup流模式备份mongobackup --backup --stream都可以指定备份初始时间点mongobackup --b...

MongoDB报Too many open files解决方法【代码】

切记更改完成后要重启服务才能生效。最近用户使用量不断扩大，突然手机app提示网络错误，经过排查发现是MongoDB数据挂了，先启动服务，然后查看日志发现了2019-05-06T09:51:36.626+0800 I NETWORK [initandlisten] Listener: accept() returns -1 errno:24 Too many open files 2019-05-06T09:51:36.626+0800 E NETWORK [initandlisten] Out of file descriptors. Waiting one second before trying to accept more connections...

MongoDB save()方法和insert()方法的区别

MongoDB save()方法和insert()方法的区别首先看官方文档怎么说的Updates an existing document or inserts a new document, depending on its document parametersave方法有更新和插入两种功能，到底是插入还是更新文档取决于save的参数。那么到底是依赖于哪个参数呢？继续看If the document does not contain an _id field, then the save() method calls the insert() method. During the operation, the mongo shell will creat...

MongoDB Query 的几个方法

Query.All("name", "a", "b");//通过多个元素来匹配数组Query.And(Query.EQ("name", "a"), Query.EQ("title", "t"));//同时满足多个条件Query.EQ("name", "a");//等于Query.Exists("type", true);//判断键值是否存在Query.GT("value", 2);//大于>Query.GTE("value", 3);//大于等于>=Query.In("name", "a", "b");//包括指定的所有值,可以指定不同类型的条件和值Query.LT("value", 9);//小于<Query.LTE("value", 8);//小于等于<=Quer...

MongoDB Query 的几个方法

Mac下mongodb connect failed 连接错误解决方法【代码】

这几天一直在折腾mongodb数据库，一直出现如下这个问题MongoDB shell version v3.6.0 connecting to: mongodb://127.0.0.1:27017 2017-12-27T09:54:34.775+0800 W NETWORK [thread1] Failed to connect to 127.0.0.1:27017, in(checking socket for error after poll), reason: Connection refused 2017-12-27T09:54:34.778+0800 E QUERY [thread1] Error: couldn‘t connect to server 127.0.0.1:27017, connection attempt faile...

MONGODB - 技术教程分类

MongoDB 教程 MongoDB 简介 MongoDB 概念解析 MongoDB 连接 MongoDB 创建数据库 MongoDB 删除数据库 MongoDB 创建集合 MongoDB 删除集合 MongoDB 插入文档 MongoDB 更新文档 MongoDB 删除文档 MongoDB 查询文档 MongoDB 条件操作符 MongoDB $type 操作符 MongoDB Limit与Skip方法 MongoDB 排序 MongoDB 索引 MongoDB 聚合 MongoDB 复制(副本集) MongoDB 分片 MongoDB 备份与恢复 MongoDB 监控 MongoDB PHP 扩展 Node.js MongoDB MongoDB 关系 MongoDB 数据库引用 MongoDB 覆盖索引查询 MongoDB 查询分析 MongoDB 原子操作 MongoDB 高级索引 MongoDB 索引限制 MongoDB ObjectId MongoDB Map Reduce MongoDB 全文检索 MongoDB 管理工具 MongoDB GridFS MongoDB 固定集合 MongoDB 自动增长 mongodb 全部

MONGODB - 最热教程

TP5(thinkPHP5)框架mongodb扩展安装及特...MongoDB数据库设置初始化脚本【MongoDB】在windows平台下mongodb的分...MongoDB查询超时异常SocketTimeoutExce...mongodb关于启动权限的问题 mongodb chunk 大小设置 MongoDB分片集群配置 mongodb web管理工具rockmongo MongoDB中insert方法、update方法、sav...mongodb如何对子文档进行分页

首页 / MONGODB / MongoDB --- 复制集方法

MongoDB --- 复制集方法

内容导读

内容图文

1、rs.add()

2. rs.addArb()

3 rs.conf() rs.config()

4 rs.freeze()

5 rs.help()

6 rs.initiate()

7. rs.reconfig()

7. rs.printReplicationInfo()

内容总结

内容备注

内容手机端

【MongoDB --- 复制集方法】教程文章相关的互联网学习教程文章

【MongoDB异常】Exception authenticating MongoCredential解决方法

Mongodb For C# "Query" 对象常用的方法【代码】

给MongoDB添加用户权限方法分享

mongodb replica set 添加/删除节点方法--http://www.ii123.com/jc/bc/bczh/258948.html

MongoDB学习笔记~为IMongoDBRepository接口添加分页取集合的方法【代码】

php实现Mongodb自定义方式生成自增ID的方法【代码】

MongoDB中insert方法、update方法、save方法简单对比【图】

关于mongodb按照字段模糊查询方法

MongoDB --- 复制集方法【代码】

mongodb增量备份方法【代码】

MongoDB报Too many open files解决方法【代码】

MongoDB save()方法和insert()方法的区别

MongoDB Query 的几个方法

MongoDB Query 的几个方法

Mac下mongodb connect failed 连接错误解决方法【代码】

MONGODB - 相关标签

MONGODB - 技术教程分类

MONGODB - 最新教程

MONGODB - 最热教程