MongoDB学习笔记(一)

  • MongoDB是一个开源、高性能、无模式的文档型数据库,是NoSQL产品中的一种。
  • MongoDB中记录的是一个文档,所谓文档就是一种类似于JSON的格式叫BSON,它是一种由字段和值对组成的数据结构。字段的数据类型是字符型,它的值除了使用基本的一些类型外,还可包括其他文档、普通数组和文档数组。
  • 应用场景:MongoDB可应对“三高”(高并发高性能高可用)需求。如:

①社交场景:用于存储用户个人信息;用户发表的朋友圈信息;通过地理位置索引实现附近的人、地点等功能。
②游戏场景:用于存储游戏用户信息,用户的装备、积分等直接以内嵌文档的形式存储,方便查询、高效率存储和访问。
③物流场景:用于存储订单信息,订单状态在运送过程中会不断更新,以内嵌数组的形式来存储,一次查询就能将该订单所有的变更读取出来。
④物联网场景:用于存储所有接入的智能设备信息,设备汇报的日志信息,并对这些信息进行多维度的分析。
⑤视频直播:用于存储用户信息、点赞互动信息等。

  • 以上这些应用场景中,数据操作方面的共同特点是:①数据量大;②读写操作都很频繁;③数据价值较低,对事务性要求不高。
SQL术语 MongoDB术语 解释
database database 数据库
table collection 数据库表/集合
row document 数据记录行/文档
column field 数据字段/域
index index 索引
table joins - 表连接/MongoDB不支持
- 嵌入式文档 MongoDB通过嵌入式文档来替代多表连接
primary key primary key 主键/MongoDB自动将_id字段设置为主键
  • MongoDB的最小存储单位是文档(document)对象,对应关系型数据库的行(row)。数据在MongoDB中以BSON(Binary-JSON)文档的格式存储在磁盘上。
  • BSON和JSON一样,支持内嵌的文档对象和数组对象,但是BSON有JSON没有的一些数据类型,如DateBinData类型。
  • BSON采用了类似于 C 语言结构体的名称、对表示方法,支持内嵌的文档对象和数组对象,具有轻量性、可遍历性、高效性的三个特点,可以有效描述非结构化数据和结构化数据。这种格式的优点是灵活性高,但它的缺点是空间利用率不高
  • BSON中,除了基本的JSON类型:stringintegerbooleandoublenullarrayobject,MongoDB还使用了特殊的数据类型:dateobject idbinary dataregular expressioncode
  • BSON数据类型参考列表:
数据类型 描述 举例
字符串 UTF-8字符串都可表示为字符串类型的数据 {"x" : "foobar"}
对象id 文档的12字节唯一ID,类似UUID {"X" :ObjectId() }
布尔值 真或假:true或false {"x": true}
数组 值的集合或列表可以表示成数组 {"x" : ["a", "b", "c"]}
32位整数 类型不可用。JavaScript仅支持64位浮点数,所以32位整数会被自动转换 shell是不支持该类型的,shell中默认会转换成64位浮点数
64位整数 不支持这个类型。shell会使用一个特殊的内嵌文档来显示64位整数 shell是不支持该类型的,shell中默认会转换成64位浮点数
64位浮点数 shell中的数字就是这一种类型 {"x": 3.14159,"y": 3}
null 表示空值或未定义的对象 {"x": null}
undefined 文档中可以使用未定义类型 {"x": undefined}
符号 shell不支持,shell会将数据库中带符号类型的数据自动转换成字符串 -
正则表达式 文档中可以包含正则表达式,采用JavaScript的正则表达式语法 {"x" :/foobar/i}
代码 文档中还可以包含JavaScript代码 {"x" : function() { /* …… */ }}
二进制数据 二进制数据可以由任意字节的数字串组成,不过在shell中无法使用 -
最大值/最小值 BSON包括一个特殊类型,表示可能的最大值/最小值。shell中没有这个类型。 -
  • 选择和创建数据库:use 数据库名称(有则进入,无则创建)
  • 查看(有权限查看)的所有数据库:show dbsshow databases
  • 查看当前正在使用的数据库:db
  • 删除当前正在使用的数据库:db.dropDatabase()
  • MongoDB 中默认的数据库为test,若没有选择数据库,则集合存放在 test 数据库中。
  • 数据库名可以是满足以下条件的任意UTF-8字符串:

1、不能是空字符串("");
2、不得含有' '(空格)、.$/\\0 (空字符);
3、应该全部小写;
4、最多为64个字节。

  • 有一些数据库名是保留的,可以直接访问这些有特殊作用的数据库:

1、admin:从权限的角度来看,这是root数据库。要是将一个用户添加到这个数据库,这个用户自动继承所有数据库的权限。一些特定的服务器端命令也只能从这个数据库运行,比如列出所有的数据库或者关闭服务器。
2、local:此数据永远不会被复制,可以用来存储限于本地单台服务器的任意集合。
3、config:当Mongo用于分片设置时,config数据库在内部使用,用于保存分片的相关信息。

  • 显示创建集合:db.createCollection(name),创建成功则返回{ "ok" : 1 }
  • 查看当前数据库的所有集合(表): show collectionsshow tables
  • 删除当前数据库的某个集合:db.集合名.drop(),删除成功则返回true,否则返回false。
  • 集合的命名规范:

1、集合名不能是空字符串""
2、集合名不能含有 \0字符(空字符),这个字符表示集合名的结尾。
3、集合名不能以system.开头,这是为系统集合保留的前缀。
4、用户创建的集合名字不能含有保留字符,有些驱动程序的确支持在集合名里面包含,这是因为某些系统生成的集合中包含该字符。除非你要访问这种系统创建的集合,否则千万不要在名字里出现$

  • 使用insert()save()方法向集合中插入一个或多个文档,语法如下:
#单条插入
db.collection.insert(
 <document or array of documents>,
 {
  writeConcern: <document>,
  ordered: <boolean>
 }
)
#批量插入
db.collection.insertMany(
 [<document 1>, <document 2>, ...],
 {
   writeConcern: <document>,
   ordered: <boolean>
 }
)
参数 类型 描述
document document or array 要插入到集合中的文档或文档数组(json格式)
writeConcern document Optional. A document expressing the write concern. Omit to use the default write concern. See Write Concern. Do not explicitly set the write concern for the operation if run in a transaction. To use write concern with transactions, see Transactions and Write Concern
ordered boolean 可选。如果为真,则按顺序插入数组中的文档,如果其中一个文档出现错误,MongoDB将返回而不处理数组中的其余文档。如果为假,则执行无序插入,如果其中一个文档出现错误,则继续处理数组中的主文档。在版本2.6+中默认为true
  • 如向comment的集合(表)中插入一条测试数据,执行后,若返回此结果:WriteResult({ "nInserted" : 1 }),则表示插入成功。
db.comment.insert({"articleid":"100000","content":"今天天气真好,阳光明媚","userid":"1001","nickname":"Rose","createdatetime":new Date(),"likenum":NumberInt(10),"state":null})
  • comment的集合(表)中批量插入多条测试数据:
db.comment.insertMany([
 {"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上,健康很重要,一杯温水幸福你我他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"},
 {"_id":"2","articleid":"100001","content":"我夏天空腹喝凉开水,冬天喝温开水","userid":"1005","nickname":"伊人憔悴","createdatetime":new Date("2019-08-05T23:58:51.485Z"),"likenum":NumberInt(888),"state":"1"},
 {"_id":"3","articleid":"100001","content":"我一直喝凉开水,冬天夏天都喝。","userid":"1004","nickname":"杰克船长","createdatetime":new Date("2019-08-06T01:05:06.321Z"),"likenum":NumberInt(666),"state":"1"},
 {"_id":"4","articleid":"100001","content":"专家说不能空腹吃饭,影响健康。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-06T08:18:35.288Z"),"likenum":NumberInt(2000),"state":"1"},
 {"_id":"5","articleid":"100001","content":"研究表明,刚烧开的水千万不能喝,因为烫嘴。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-06T11:01:02.521Z"),"likenum":NumberInt(3000),"state":"1"}
]);
  • 上述语句执行后,若返回以下结果,则表示插入成功。
{
        "acknowledged" : true,
        "insertedIds" : [
                "1",
                "2",
                "3",
                "4",
                "5"
        ]
}

1、若comment集合不存在,则会隐式创建。
2、mongo中的数字,默认情况下是double类型,若要存储整型数据,必须使用函数NumberInt(整型数字),否则取值时就会出错。
3、插入当前日期用new Date()
4、若插入的数据没有指定_id,则会自动生成主键值,否则主键就是该指定的值。
5、若某字段没值,则可以赋值为null,或不写该字段。
6、文档中的键/值对是有序的。
7、文档中的值不仅可以是在双引号里面的字符串,还可以是其它几种数据类型(甚至可以是整个嵌入的文档)。
8、MongoDB区分类型和大小写。
9、MongoDB的文档不能有重复的键。
10、文档的键是字符串,除了少数例外情况,键可以使用任意UTF-8字符。

  • 文档键的命名规范:

1、键不能含有\0(空字符),这个字符用来表示键的结尾。
2、.$有特别的意义,只有在特定环境下才能使用。
3、以下划线_开头的键是保留的(不是严格要求的)。

  • 在批量插入文档时,若某个文档插入失败,则将会终止插入操作,但已插入成功的数据不会回滚掉,可使用try-catch语句来处理异常,测试时可不用处理:
try {
db.comment.insertMany([
 {"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上,健康很重要,一杯温水幸福你我他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"},
 {"_id":"2","articleid":"100001","content":"我夏天空腹喝凉开水,冬天喝温开水","userid":"1005","nickname":"伊人憔悴","createdatetime":new Date("2019-08-05T23:58:51.485Z"),"likenum":NumberInt(888),"state":"1"},
 {"_id":"3","articleid":"100001","content":"我一直喝凉开水,冬天夏天都喝。","userid":"1004","nickname":"杰克船长","createdatetime":new Date("2019-08-06T01:05:06.321Z"),"likenum":NumberInt(666),"state":"1"},
 {"_id":"4","articleid":"100001","content":"专家说不能空腹吃饭,影响健康。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-06T08:18:35.288Z"),"likenum":NumberInt(2000),"state":"1"},
 {"_id":"5","articleid":"100001","content":"研究表明,刚烧开的水千万不能喝,因为烫嘴。","userid":"1003","nickname":"凯撒","createdatetime":new Date("2019-08-06T11:01:02.521Z"),"likenum":NumberInt(3000),"state":"1"}
]);
} catch (e) {
 print (e);
}
  • 查询文档的语法:db.集合名.find(<query>, [projection])
参数 类型 描述
query document 可选。使用查询运算符指定选择筛选器。若要返回集合中的所有文档,请省略此参数或传递空文档{}
projection document 可选。指定要在与查询筛选器匹配的文档中返回的字段(投影)。若要返回匹配文档中的所有字段,则省略此参数。
  • 查询comment集合的所有文档:db.comment.find()db.comment.find({})
  • 查询userid为1003的文档:db.comment.find({userid: '1003'})db.comment.findOne({userid: '1003'}),其中findOne()方法返回多个文档中的第一个文档。
  • 若要查询结果返回部分字段,则需要使用投影查询(不显示所有字段,只显示指定的字段)。如:
db.comment.find({userid:"1003"},{userid:1,nickname:1}) #默认显示主键_id
db.comment.find({userid:"1003"},{userid:1,nickname:1,_id:0}) #不显示主键_id
  • 更新文档的语法:
db.collection.update(
 <query>,
 <update>,
 {
  upsert: <boolean>,
  multi: <boolean>,
  writeConcern: <document>,
  collation: <document>,
  arrayFilters: [ <filterdocument1>, ... ],
  hint:  <document|string> 
 }
)
参数 类型 描述
query document update的查询条件
update document or pipeline update的对象和一些更新的操作等
upsert boolean 可选。若不存在update的记录,是否插入objNew -> true为插入,默认是false不插入
multi boolean 可选。默认值为false,即只更新找到的第一个文档。若这个参数值为true,则把按条件查出来多个文档全部更新
writeConcern document 可选。表示写问题的文档。抛出异常的级别。
collation document 可选。指定要用于操作的校对规则。
arrayFilters array 可选。一个筛选文档数组,用于确定要为数组字段上的更新操作修改哪些数组元素。
hint document or string 可选。指定用于支持查询谓词索引的文档或字符串。
  • 覆盖修改文档:修改_id=1的文档为点赞量为1001,执行后会发现这条文档除了 likenum字段其它字段都不见了。
> db.comment.update({_id:"1"},{likenum:NumberInt(1001)})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
  • 局部修改文档,使用修改器$set来实现,如修改_id=2的文档中浏览量为889。
> db.comment.update({_id:"2"},{$set:{likenum:NumberInt(889)}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
  • 批量修改文档:更新所有用户为1003 的用户的昵称为 凯撒大帝 。
#默认只更新符合条件的第一条记录
> db.comment.update({userid:"1003"},{$set:{nickname:"凯撒2"}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
#修改所有符合条件的数据
> db.comment.update({userid:"1003"},{$set:{nickname:"凯撒大帝"}},{multi:true})
WriteResult({ "nMatched" : 2, "nUpserted" : 0, "nModified" : 2 })
  • 列值增长地修改文档:使用$inc运算符来实现,如每次对_id=3的文档中点赞数加1。
> db.comment.update({_id:"3"},{$inc:{likenum:NumberInt(1)}})
WriteResult({ "nMatched" : 1, "nUpserted" : 0, "nModified" : 1 })
  • 删除文档的语法:db.集合名.remove(条件),如删除_id=1的文档,或者删除comment集合中的全部文档:
> db.comment.remove({_id:"1"})
WriteResult({ "nRemoved" : 1 })
> db.comment.remove({})
WriteResult({ "nRemoved" : 4 })
  • 统计集合中文档数量的语法:db.collection.count(query, options)
参数 类型 描述
query document 查询选择条件
options document 可选。用于修改计数的额外选项
  • 统计集合中的文档数量:db.comment.count()
  • 统计userid为1003的文档个数:db.comment.count({userid:"1003"})
  • 分页查询文档的语法:db.COLLECTION_NAME.find().limit(NUMBER).skip(NUMBER),其中limit()方法用来读取指定数量的文档,skip()方法用来跳过指定数量的文档。
  • 返回comment集合中前4个文档:db.comment.find().limit(4)
  • 返回comment集合中第3和第4个文档:db.comment.find().skip(2).limit(2)
  • 排序查询文档:用sort()方法对文档进行排序,通过参数指定排序的字段,使用 1 和 -1 来指定排序的方式,其中 1 为升序排列,而 -1 是用于降序排列。语法为:db.集合名.find().sort(排序方式),如对userid降序排列,并对访问量进行升序排列:
db.comment.find({},{userid:1}).sort({userid:-1,likenum:1})
  • 注意:skip()limilt()sort()三个方法放在一起执行时,执行的顺序是先 sort(),然后是skip(),最后是limit(),和命令编写顺序无关。
  • MongoDB的模糊查询是通过正则表达式的方式来实现的。格式为:db.集合名.find({字段:/正则表达式/})
  • 查询评论内容中包含“开水”的所有文档:db.comment.find({content:/开水/})
  • 查询评论内容中以 “专家”开头的所有文档:db.comment.find({content:/^专家/})
  • 比较查询文档:

1、db.集合名.find({ "field" : { $gt: value }}) // 大于: field > value
2、db.集合名.find({ "field" : { $lt: value }}) // 小于: field < value
3、db.集合名.find({ "field" : { $gte: value }}) // 大于等于: field >= value
4、db.集合名.find({ "field" : { $lte: value }}) // 小于等于: field <= value
5、db.集合名.find({ "field" : { $ne: value }}) // 不等于: field != value

  • 查询评论点赞数量大于 700的所有文档:db.comment.find({likenum:{$gt:NumberInt(700)}})
  • 包含使用$in操作符来查询文档,如查询评论的集合中userid字段值为1003或1004的所有文档:db.comment.find({userid:{$in:["1003","1004"]}})
  • 不包含使用$nin操作符来查询文档,如:查询评论集合中userid字段值不为1003和1004的所有文档:db.comment.find({userid:{$nin:["1003","1004"]}})
  • 条件连接查询文档:①若要查询同时满足两个以上条件,则需使用$and操作符将条件进行关联,语法为:$and:[{ },{ },{}]。如查询评论集合中 likenum大于等于700 且小于2000的所有文档:db.comment.find({$and:[{likenum:{$gte:NumberInt(700)}},{likenum:{$lt:NumberInt(2000)}}]})
  • 若两个以上条件之间是或者的关系,则使用$or操作符进行关联,语法为:$or:[{ },{ },{}]。如查询评论集合中 userid为1003,或者点赞数小于1000的所有文档:db.comment.find({$or:[ {userid:"1003"}, {likenum:{$lt:1000} }]})
  • MongoDB的索引使用B-Tree,而MySQL的索引使用的是B+Tree这种数据结构。
  • MongoDB支持在文档的单个字段上创建用户定义的升序/降序索引,称为单字段索引(Single Field Index)。
  • MongoDB还支持多个字段的用户定义索引,即复合索引(Compound Index)。复合索引中列出的字段顺序具有重要意义:若复合索引由{ userid: 1, score: -1 } 组成,则索引首先按userid正序排序,然后在相同userid的文档中,再在按score倒序排序。
  • 地理空间索引(Geospatial Index):为了支持对地理空间坐标数据的有效查询,MongoDB提供了两种特殊的索引:返回结果时使用平面几何的二维索引和返回结果时使用球面几何的二维球面索引。
  • 文本索引(Text Indexes):MongoDB支持在集合中搜索字符串内容,这些文本索引不存储特定于语言的停止词(例如“the”、“a”、“or”),而将集合中的词作为词干,只存储根词。
  • 哈希索引(Hashed Indexes):为了支持基于散列的分片,MongoDB提供了散列索引类型,它对字段值的散列进行索引。这些索引在其范围内的值分布更加随机,但只支持相等匹配,不支持基于范围的查询。
  • 返回一个集合中的所有索引的数组:db.集合名.getIndexes()
> db.comment.getIndexes()
[
        {
                "v" : 2,
                "key" : {
                        "_id" : 1
                },
                "name" : "_id_",
                "ns" : "articledb.comment"
        }
]
  • 默认_id索引:MongoDB在创建集合的过程中,在_id字段上创建一个唯一的索引,默认名字为_id_,该索引可防止客户端插入两个具有相同值的文档,不能在_id字段上删除此索引。注意:该索引是唯一索引,因此值不能重复,即_id值不能重复。在分片集群中,通常使用_id作为片键。
  • 在集合上创建索引的语法:db.集合名.createIndex(keys, options)
参数 类型 描述
keys document 包含字段和值对的文档,其中字段是索引键,值描述该字段的索引类型。对于字段上的升序索引,请指定值为1;对于降序索引,请指定值为-1。如:{ 字段:1或-1}
options document 可选。包含一组控制索引创建的选项的文档。有关详细信息,请参见选项详情列表。
  • options列表:
参数 类型 描述
background Boolean 建索引过程会阻塞其它数据库操作,background可指定以后台方式创建索引,即增加"background" 可选参数。 "background" 默认值为false。
unique Boolean 建立的索引是否唯一,指定为true时创建唯一索引。默认值为false。
name string 若未指定索引的名称,则通过连接索引的字段名和排序顺序值生成一个索引名称。
dropDups Boolean 3.0+版本已废弃。在建立唯一索引时是否删除重复记录,指定为true时创建唯一索引。默认值为false。
sparse Boolean 对文档中不存在的字段数据不启用索引。注意:若将其设置为true,则在索引字段中不会查询出不包含对应字段的文档。默认值为 false.
expireAfterSeconds integer 设定集合的生存时间(单位:秒/s)。
v index version 索引的版本号。默认的索引版本号取决于mongod创建索引时运行的版本号。
weights document 索引权重值,数值在 1 到 99999 之间,表示该索引相对于其它索引字段的得分权重。
default_language string 对于文本索引,该参数决定了停用词及词干和词器的规则的列表。 默认为英语。
language_override string 对于文本索引,该参数指定了包含在文档中的字段名,语言覆盖默认的language,默认值为language。
  • 单字段索引示例:对 userid 字段的值按升序建立索引:
> db.comment.createIndex({userid:1})
{
        "createdCollectionAutomatically" : false,
        "numIndexesBefore" : 1,
        "numIndexesAfter" : 2,
        "ok" : 1
}
  • 复合索引:对 userid 和 nickname 同时建立复合(Compound)索引:
> db.comment.createIndex({userid:1,nickname:-1})
{
        "createdCollectionAutomatically" : false,
        "numIndexesBefore" : 2,
        "numIndexesAfter" : 3,
        "ok" : 1
}
> db.comment.getIndexes()
[
        {
                "v" : 2,
                "key" : {
                        "_id" : 1
                },
                "name" : "_id_",
                "ns" : "articledb.comment"
        },
        {
                "v" : 2,
                "key" : {
                        "userid" : 1
                },
                "name" : "userid_1",
                "ns" : "articledb.comment"
        },
        {
                "v" : 2,
                "key" : {
                        "userid" : 1,
                        "nickname" : -1
                },
                "name" : "userid_1_nickname_-1",
                "ns" : "articledb.comment"
        }
]
  • 移除集合中指定的索引,语法为:db.集合名.dropIndex(索引名称)
  • 删除comment集合中 userid 字段上的升序索引:
> db.comment.dropIndex({userid:1})
{ "nIndexesWas" : 3, "ok" : 1 }
  • 移除集合中所有的索引,语法为:db.集合名.dropIndexes()。注意:只能删除非_id字段的索引。如:删除comment集合中所有的索引:
> db.comment.dropIndexes()
{
        "nIndexesWas" : 2,
        "msg" : "non-_id indexes dropped for collection",
        "ok" : 1
}
> db.comment.getIndexes()
[
        {
                "v" : 2,
                "key" : {
                        "_id" : 1
                },
                "name" : "_id_",
                "ns" : "articledb.comment"
        }
]
  • 查看执行计划,语法为:db.集合名.find(query, options).explain(options),如:查看根据userid查询数据的情况:
> db.comment.find({userid:"1003"}).explain()
{
        "queryPlanner" : {
                "plannerVersion" : 1,
                "namespace" : "articledb.comment",
                "indexFilterSet" : false,
                "parsedQuery" : {
                        "userid" : {
                                "$eq" : "1003"
                        }
                },
                "queryHash" : "37A12FC3",
                "planCacheKey" : "7FDF74EC",
                "winningPlan" : {
                        "stage" : "FETCH",
                        "inputStage" : {
                                "stage" : "IXSCAN",
                                "keyPattern" : {
                                        "userid" : 1
                                },
                                "indexName" : "userid_1",
                                "isMultiKey" : false,
                                "multiKeyPaths" : {
                                        "userid" : [ ]
                                },
                                "isUnique" : false,
                                "isSparse" : false,
                                "isPartial" : false,
                                "indexVersion" : 2,
                                "direction" : "forward",
                                "indexBounds" : {
                                        "userid" : [
                                                "[\"1003\", \"1003\"]"
                                        ]
                                }
                        }
                },
                "rejectedPlans" : [ ]
        },
        "serverInfo" : {
                "host" : "DESKTOP-NIFA5F0",
                "port" : 27017,
                "version" : "4.2.8-54-g9bffa93",
                "gitVersion" : "9bffa938ea7e8a18ba0e5508f126f6e723d063a9"
        },
        "ok" : 1
}
  • 关键点看:"stage" : "COLLSCAN",表示全集合扫描; "stage" : "IXSCAN",基于索引进行扫描。
  • 覆盖查询:当查询条件和查询的投影仅包含索引字段时,MongoDB直接从索引返回结果,而不扫描任何文档或将文档带入内存。
  • MongoDB中的副本集(Replica Set)是一组维护相同数据集的mongod服务。 副本集可提供冗余和高可用性,是所有生产部署的基础。副本集类似于有自动故障恢复功能的主从集群。
  • 冗余和数据可用性:复制提供冗余并提高数据可用性。通过在不同数据库服务器上提供多个数据副本,复制可提供一定级别的容错功能,以防止单个数据库服务器丢失数据。
  • MongoDB中的复制:副本集是一组维护相同数据集的mongod实例。 副本集包含多个数据承载节点和可选的一个仲裁节点。在承载数据的节点中,有且仅有一个成员被视为主节点,其余被视为从节点。主节点接收所有的写操作,即记录操作日志中的数据集的所有更改:oplog
  • 从节点复制主节点的oplog并将操作应用于其数据集,以使从节点的数据集反映主节点的数据集。
  • 主从复制和副本集区别:副本集没有固定的"主节点",整个集群会选出一个"主节点",当其挂掉后,又在剩余的从节点中选举某个节点作为"主节点",副本集总有一个活跃点(主、primary)和一个或多个备份节点(从、secondary)。
  • 副本集有两种类型三种角色:
    • 两种类型:
      • 主节点(Primary)类型:数据操作的主要连接点,可读写。
      • 从节点(Secondaries)类型:数据冗余备份节点,可以读或选举。
    • 三种角色:
      • 主节点(Primary):主要接收所有写操作。
      • 从节点(Replicate):从主节点中通过复制操作以维护相同的数据集,即备份数据,不可进行写操作,但可以读操作(需要配置)。
      • 仲裁者(Arbiter):不保留任何数据的副本,只具有投票选举作用。可以将仲裁服务器维护为副本集的一部分,即副本成员同时也可以是仲裁者,也是一种从节点类型。
  • 关于仲裁者的额外说明:

1、可以将额外的mongod实例添加到副本集作为仲裁者。仲裁者不维护数据集,仲裁者的目的是通过响应其它副本集成员的心跳和选举请求来维护副本集中的仲裁。因为它们不存储数据集,所以仲裁器可以是提供副本集仲裁功能的好方法,其资源成本比具有数据集的全功能副本集成员更便宜。
2、若副本集中有偶数个成员,则需添加仲裁者以获得主要选举中的"大多数"投票。 仲裁者不需要专用硬件。仲裁者将永远是仲裁者,而主要人员可能会退出并成为次要人员,而次要人员可能成为选举期间的主要人员。
3、若副本+主节点的个数是偶数,建议加一个仲裁者,形成奇数个,容易满足大多数的投票。
4、若副本+主节点的个数是奇数,可以不加仲裁者。

  • 副本集架构目标:一主一副本一仲裁。

副本集的创建

创建主节点

  • 建立存放数据和日志的目录:
mkdir -p /opt/mongodb/replica_sets/myrs_27017/logs \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27017/data/db \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27017/conf
  • 新建配置文件:vim /opt/mongodb/replica_sets/myrs_27017/conf/mongod.conf。注意空格!
 systemLog:
    destination: file
    path: /opt/mongodb/replica_sets/myrs_27017/logs/mongod.log
    logAppend: true
 storage:
    dbPath: /opt/mongodb/replica_sets/myrs_27017/data/db
    journal:
        enabled: true
 processManagement:
    fork: true
    pidFilePath: /opt/mongodb/replica_sets/myrs_27017/logs/mongod.pid
 net:
    bindIp: localhost,192.168.0.128
    port: 27017
 replication:
    replSetName: myrs
  • 启动主节点服务:
[root@dev mongodb]# /opt/mongodb/bin/mongod -f /opt/mongodb/replica_sets/myrs_27017/conf/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 22336
child process started successfully, parent exiting

创建副本节点

  • 建立存放数据和日志的目录:
mkdir -p /opt/mongodb/replica_sets/myrs_27018/logs \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27018/data/db \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27018/conf
  • 新建配置文件:vim /opt/mongodb/replica_sets/myrs_27018/conf/mongod.conf。注意空格!
 systemLog:
    destination: file
    path: /opt/mongodb/replica_sets/myrs_27018/logs/mongod.log
    logAppend: true
 storage:
    dbPath: /opt/mongodb/replica_sets/myrs_27018/data/db
    journal:
        enabled: true
 processManagement:
    fork: true
    pidFilePath: /opt/mongodb/replica_sets/myrs_27018/logs/mongod.pid
 net:
    bindIp: localhost,192.168.0.128
    port: 27018
 replication:
    replSetName: myrs
  • 启动主节点服务:
[root@dev mongodb]# /opt/mongodb/bin/mongod -f /opt/mongodb/replica_sets/myrs_27018/conf/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 22382
child process started successfully, parent exiting

创建仲裁节点

  • 建立存放数据和日志的目录:
mkdir -p /opt/mongodb/replica_sets/myrs_27019/logs \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27019/data/db \ & 
mkdir -p /opt/mongodb/replica_sets/myrs_27019/conf
  • 新建配置文件:vim /opt/mongodb/replica_sets/myrs_27019/conf/mongod.conf。注意空格!
 systemLog:
    destination: file
    path: /opt/mongodb/replica_sets/myrs_27019/logs/mongod.log
    logAppend: true
 storage:
    dbPath: /opt/mongodb/replica_sets/myrs_27019/data/db
    journal:
        enabled: true
 processManagement:
    fork: true
    pidFilePath: /opt/mongodb/replica_sets/myrs_27019/logs/mongod.pid
 net:
    bindIp: localhost,192.168.0.128
    port: 27019
 replication:
    replSetName: myrs
  • 启动主节点服务:
[root@dev mongodb]# /opt/mongodb/bin/mongod -f /opt/mongodb/replica_sets/myrs_27019/conf/mongod.conf
about to fork child process, waiting until server is ready for connections.
forked process: 22429
child process started successfully, parent exiting

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

  • 使用客户端命令连接任意一个节点,但尽量要连接主节点(27017节点):/opt/mongodb/bin/mongo --port=27017,结果连接上之后会发现很多命令无法使用,比如show dbs等,必须初始化副本集才行。
  • 准备初始化新的副本集,语法为:rs.initiate(configuration)
参数 类型 描述
configuration document Optional. A document that specifies configuration for the new replica set. If a configuration is not specified,MongoDB uses a default replica set configuration.
  • 使用默认的配置来初始化副本集:rs.initiate()
    • 若"ok"的值为1,则说明创建成功。
    • 命令执行后命令行提示符发生变化,变成了一个从节点角色,此时默认不能读写,稍等片刻后回车,变成主节点。
> rs.initiate()
{
    "info2" : "no configuration specified. Using a default configuration for the set",
    "me" : "192.168.0.128:27017",
    "ok" : 1,
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610359342, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    },
    "operationTime" : Timestamp(1610359342, 1)
}
myrs:SECONDARY> 
myrs:PRIMARY>
  • 查看副本集的配置内容,语法:rs.conf(configuration)rs.config()是该方法的别名。参数configuration可选,若没有配置,则使用默认主节点的配置。
myrs:PRIMARY> rs.conf()
{
    "_id" : "myrs",
    "version" : 1,
    "term" : 1,
    "protocolVersion" : NumberLong(1),
    "writeConcernMajorityJournalDefault" : true,
    "members" : [
        {
            "_id" : 0,
            "host" : "192.168.0.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("5ffc222e8f297cc24be48002")
    }
}
  • 说明:① "_id" : "myrs":副本集的配置数据存储的主键值,默认就是副本集的名字;②"members": []:副本集成员数组,此时只有一个:"host" : "192.168.0.128:27017";该成员不是仲裁节点:"arbiterOnly" : false;优先级(权重值):"priority" : 1;③"settings":副本集的参数配置。
  • 查看副本集状态,语法为:rs.status()。说明:此输出使用从副本集的其它成员发送的心跳包中获得的数据反映副本集的当前状态。
myrs:PRIMARY> rs.status()
{
    "set" : "myrs",
    "date" : ISODate("2021-01-11T10:11:06.345Z"),
    "myState" : 1,
    "term" : NumberLong(1),
    "syncSourceHost" : "",
    "syncSourceId" : -1,
    "heartbeatIntervalMillis" : NumberLong(2000),
    "majorityVoteCount" : 1,
    "writeMajorityCount" : 1,
    "votingMembersCount" : 1,
    "writableVotingMembersCount" : 1,
    "optimes" : {
        "lastCommittedOpTime" : {
            "ts" : Timestamp(1610359862, 1),
            "t" : NumberLong(1)
        },
        "lastCommittedWallTime" : ISODate("2021-01-11T10:11:02.751Z"),
        "readConcernMajorityOpTime" : {
            "ts" : Timestamp(1610359862, 1),
            "t" : NumberLong(1)
        },
        "readConcernMajorityWallTime" : ISODate("2021-01-11T10:11:02.751Z"),
        "appliedOpTime" : {
            "ts" : Timestamp(1610359862, 1),
            "t" : NumberLong(1)
        },
        "durableOpTime" : {
            "ts" : Timestamp(1610359862, 1),
            "t" : NumberLong(1)
        },
        "lastAppliedWallTime" : ISODate("2021-01-11T10:11:02.751Z"),
        "lastDurableWallTime" : ISODate("2021-01-11T10:11:02.751Z")
    },
    "lastStableRecoveryTimestamp" : Timestamp(1610359822, 1),
    "electionCandidateMetrics" : {
        "lastElectionReason" : "electionTimeout",
        "lastElectionDate" : ISODate("2021-01-11T10:02:22.706Z"),
        "electionTerm" : NumberLong(1),
        "lastCommittedOpTimeAtElection" : {
            "ts" : Timestamp(0, 0),
            "t" : NumberLong(-1)
        },
        "lastSeenOpTimeAtElection" : {
            "ts" : Timestamp(1610359342, 1),
            "t" : NumberLong(-1)
        },
        "numVotesNeeded" : 1,
        "priorityAtElection" : 1,
        "electionTimeoutMillis" : NumberLong(10000),
        "newTermStartDate" : ISODate("2021-01-11T10:02:22.725Z"),
        "wMajorityWriteAvailabilityDate" : ISODate("2021-01-11T10:02:22.758Z")
    },
    "members" : [
        {
            "_id" : 0,
            "name" : "192.168.0.128:27017",
            "health" : 1,
            "state" : 1,
            "stateStr" : "PRIMARY",
            "uptime" : 4143,
            "optime" : {
                "ts" : Timestamp(1610359862, 1),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2021-01-11T10:11:02Z"),
            "syncSourceHost" : "",
            "syncSourceId" : -1,
            "infoMessage" : "",
            "electionTime" : Timestamp(1610359342, 2),
            "electionDate" : ISODate("2021-01-11T10:02:22Z"),
            "configVersion" : 1,
            "configTerm" : 1,
            "self" : true,
            "lastHeartbeatMessage" : ""
        }
    ],
    "ok" : 1,
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610359862, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    },
    "operationTime" : Timestamp(1610359862, 1)
}
  • 说明:①"set" : "myrs":副本集的名字;②"myState" : 1:说明状态正常;③"members":副本集成员数组,此时只有一个:"name" : "192.168.0.128:27017",该成员的角色是"stateStr" : "PRIMARY" ,该节点是健康的:"health" : 1

添加副本从节点

  • 在主节点中添加从节点,将其它成员加入到副本集,语法为:rs.add(host, arbiterOnly)
参数 类型 描述
host string or document 要添加到副本集的新成员,指定为字符串或配置文档:①若是一个字符串,则需指定新成员的主机名和可选的端口号;②若是一个文档,则指定在members数组中找到的副本集成员配置文档。必须在成员配置文档中指定主机字段。有关文档配置字段的说明,详见下方文档:"主机成员的配置文档"
arbiterOnly boolean 可选。 仅在 <host> 值为字符串时适用。若为true,则添加的主机是仲裁者。
  • 主机成员的配置文档:
{
 _id: <int>,
 host: <string>,     #required
 arbiterOnly: <boolean>,
 buildIndexes: <boolean>,
 hidden: <boolean>,
 priority: <number>,
 tags: <document>,
 slaveDelay: <int>,
 votes: <number>
}
  • 将27018的副本节点添加到副本集中,"ok" : 1:说明添加成功。
myrs:PRIMARY> rs.add("公网ip:27018")
{
    "ok" : 1,
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610365858, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    },
    "operationTime" : Timestamp(1610365858, 1)
}

添加仲裁从节点

  • 添加一个仲裁节点到副本集,语法:rs.addArb(host)
  • 将27019的仲裁节点添加到副本集中:
myrs:PRIMARY> rs.addArb("公网ip:27019")
{
    "ok" : 1,
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610366033, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    },
    "operationTime" : Timestamp(1610366033, 1)
}
  • 查看副本集状态:
myrs:PRIMARY> rs.status()
{
    "set" : "myrs",
    "date" : ISODate("2021-01-11T11:54:52.719Z"),
    "myState" : 1,
    "term" : NumberLong(1),
    "syncSourceHost" : "",
    "syncSourceId" : -1,
    "heartbeatIntervalMillis" : NumberLong(2000),
    "majorityVoteCount" : 2,
    "writeMajorityCount" : 2,
    "votingMembersCount" : 3,
    "writableVotingMembersCount" : 2,
    "optimes" : {
        "lastCommittedOpTime" : {
            "ts" : Timestamp(1610366082, 1),
            "t" : NumberLong(1)
        },
        "lastCommittedWallTime" : ISODate("2021-01-11T11:54:42.875Z"),
        "readConcernMajorityOpTime" : {
            "ts" : Timestamp(1610366082, 1),
            "t" : NumberLong(1)
        },
        "readConcernMajorityWallTime" : ISODate("2021-01-11T11:54:42.875Z"),
        "appliedOpTime" : {
            "ts" : Timestamp(1610366082, 1),
            "t" : NumberLong(1)
        },
        "durableOpTime" : {
            "ts" : Timestamp(1610366082, 1),
            "t" : NumberLong(1)
        },
        "lastAppliedWallTime" : ISODate("2021-01-11T11:54:42.875Z"),
        "lastDurableWallTime" : ISODate("2021-01-11T11:54:42.875Z")
    },
    "lastStableRecoveryTimestamp" : Timestamp(1610366062, 1),
    "electionCandidateMetrics" : {
        "lastElectionReason" : "electionTimeout",
        "lastElectionDate" : ISODate("2021-01-11T10:02:22.706Z"),
        "electionTerm" : NumberLong(1),
        "lastCommittedOpTimeAtElection" : {
            "ts" : Timestamp(0, 0),
            "t" : NumberLong(-1)
        },
        "lastSeenOpTimeAtElection" : {
            "ts" : Timestamp(1610359342, 1),
            "t" : NumberLong(-1)
        },
        "numVotesNeeded" : 1,
        "priorityAtElection" : 1,
        "electionTimeoutMillis" : NumberLong(10000),
        "newTermStartDate" : ISODate("2021-01-11T10:02:22.725Z"),
        "wMajorityWriteAvailabilityDate" : ISODate("2021-01-11T10:02:22.758Z")
    },
    "members" : [
        {
            "_id" : 0,
            "name" : "192.168.0.128:27017",
            "health" : 1,
            "state" : 1,
            "stateStr" : "PRIMARY",
            "uptime" : 10369,
            "optime" : {
                "ts" : Timestamp(1610366082, 1),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2021-01-11T11:54:42Z"),
            "syncSourceHost" : "",
            "syncSourceId" : -1,
            "infoMessage" : "",
            "electionTime" : Timestamp(1610359342, 2),
            "electionDate" : ISODate("2021-01-11T10:02:22Z"),
            "configVersion" : 3,
            "configTerm" : 1,
            "self" : true,
            "lastHeartbeatMessage" : ""
        },
        {
            "_id" : 1,
            "name" : "公网ip:27018",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 234,
            "optime" : {
                "ts" : Timestamp(1610366082, 1),
                "t" : NumberLong(1)
            },
            "optimeDurable" : {
                "ts" : Timestamp(1610366082, 1),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2021-01-11T11:54:42Z"),
            "optimeDurableDate" : ISODate("2021-01-11T11:54:42Z"),
            "lastHeartbeat" : ISODate("2021-01-11T11:54:51.055Z"),
            "lastHeartbeatRecv" : ISODate("2021-01-11T11:54:51.038Z"),
            "pingMs" : NumberLong(1),
            "lastHeartbeatMessage" : "",
            "syncSourceHost" : "192.168.0.128:27017",
            "syncSourceId" : 0,
            "infoMessage" : "",
            "configVersion" : 3,
            "configTerm" : 1
        },
        {
            "_id" : 2,
            "name" : "公网ip:27019",
            "health" : 1,
            "state" : 7,
            "stateStr" : "ARBITER",
            "uptime" : 59,
            "lastHeartbeat" : ISODate("2021-01-11T11:54:51.085Z"),
            "lastHeartbeatRecv" : ISODate("2021-01-11T11:54:51.090Z"),
            "pingMs" : NumberLong(1),
            "lastHeartbeatMessage" : "",
            "syncSourceHost" : "",
            "syncSourceId" : -1,
            "infoMessage" : "",
            "configVersion" : 3,
            "configTerm" : 1
        }
    ],
    "ok" : 1,
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610366082, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    },
    "operationTime" : Timestamp(1610366082, 1)
}

副本集的数据读写操作

  • 登录主节点27017,写入和读取数据:
myrs:PRIMARY> use articledb
switched to 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("5ffc3daf321ee60a406090d4"), "articleid" : "100000", "content" : "今天天气真好,阳光明媚", "userid" : "1001", "nickname" : "Rose", "createdatetime" : ISODate("2021-01-11T11:59:43.728Z") }
  • 登录从节点27018:/opt/mongodb/bin/mongo --port 27018
[root@dev ~]# /opt/mongodb/bin/mongo --port 27018
myrs:SECONDARY> show dbs
uncaught exception: Error: listDatabases failed:{
    "topologyVersion" : {
        "processId" : ObjectId("5ffc14e97ffa677c852d618a"),
        "counter" : NumberLong(4)
    },
    "operationTime" : Timestamp(1610366712, 1),
    "ok" : 0,
    "errmsg" : "not master and slaveOk=false",
    "code" : 13435,
    "codeName" : "NotPrimaryNoSecondaryOk",
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610366712, 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:147:19
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:99:12
shellHelper.show@src/mongo/shell/utils.js:937:13
shellHelper@src/mongo/shell/utils.js:819:15
@(shellhelp2):1:1
  • 执行show dbs后发现不能读取集合的数据,默认情况下,从节点是没有读写权限的,可以增加读的权限,语法:rs.secondaryOk()或rs.secondaryOk(true)。
  • 在27018上设置作为从节点权限,具备读权限,但不允许插入文档:
myrs:SECONDARY> rs.secondaryOk()
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.comment.find()
{ "_id" : ObjectId("5ffc3daf321ee60a406090d4"), "articleid" : "100000", "content" : "今天天气真好,阳光明媚", "userid" : "1001", "nickname" : "Rose", "createdatetime" : ISODate("2021-01-11T11:59:43.728Z") }
myrs:SECONDARY> db.comment.insert({"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上,健康很重要,k一杯温水幸福你我他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"})
WriteCommandError({
    "topologyVersion" : {
        "processId" : ObjectId("5ffc14e97ffa677c852d618a"),
        "counter" : NumberLong(4)
    },
    "operationTime" : Timestamp(1610367532, 1),
    "ok" : 0,
    "errmsg" : "not master",
    "code" : 10107,
    "codeName" : "NotWritablePrimary",
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610367532, 1),
        "signature" : {
            "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
            "keyId" : NumberLong(0)
        }
    }
})
  • 取消作为从节点的读权限:
myrs:SECONDARY> rs.secondaryOk(false)
myrs:SECONDARY> show dbs
uncaught exception: Error: listDatabases failed:{
    "topologyVersion" : {
        "processId" : ObjectId("5ffc14e97ffa677c852d618a"),
        "counter" : NumberLong(4)
    },
    "operationTime" : Timestamp(1610367382, 1),
    "ok" : 0,
    "errmsg" : "not master and slaveOk=false",
    "code" : 13435,
    "codeName" : "NotPrimaryNoSecondaryOk",
    "$clusterTime" : {
        "clusterTime" : Timestamp(1610367382, 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:147:19
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:99:12
shellHelper.show@src/mongo/shell/utils.js:937:13
shellHelper@src/mongo/shell/utils.js:819:15
@(shellhelp2):1:1
  • 登录不存放任何业务数据的仲裁者节点27019:
[root@dev ~]# /opt/mongodb/bin/mongo --port 27019
myrs:ARBITER> rs.slaveOk()
WARNING: slaveOk() is deprecated and may be removed in the next major release. Please use secondaryOk() instead.
myrs:ARBITER> rs.secondaryOk()
myrs:ARBITER> show dbs
uncaught exception: Error: listDatabases failed:{
    "topologyVersion" : {
        "processId" : ObjectId("5ffc14f0bb6f0453b549db22"),
        "counter" : NumberLong(1)
    },
    "ok" : 0,
    "errmsg" : "node is not in primary or recovering state",
    "code" : 13436,
    "codeName" : "NotPrimaryOrSecondary"
} :
_getErrorWithCode@src/mongo/shell/utils.js:25:13
Mongo.prototype.getDBs/<@src/mongo/shell/mongo.js:147:19
Mongo.prototype.getDBs@src/mongo/shell/mongo.js:99:12
shellHelper.show@src/mongo/shell/utils.js:937:13
shellHelper@src/mongo/shell/utils.js:819:15
@(shellhelp2):1:1
  • 主节点的选举原则:MongoDB在副本集中,会自动进行主节点的选举,主节点选举的触发条件:①主节点故障;②主节点网络不可达(默认心跳信息为10秒);③人工干预(rs.stepDown(600))。一旦触发选举,就要根据一定规则来选主节点。
  • 选举规则是根据票数来决定谁获胜:
    • 票数最高且获得了"大多数"成员投票支持的节点获胜。"大多数"的定义为:假设复制集内投票成员数量为N,则大多数为 N/2 + 1。例如:3个投票成员,则大多数的值是2。当复制集内存活成员数量不足大多数时,整个复制集将无法选举出Primary,复制集将无法提供写服务,处于只读状态。
    • 若票数相同且都获得了"大多数"成员的投票支持,数据新的节点获胜。数据的新旧是通过操作日志oplog来对比的。
  • 在获得票数时,优先级(priority)参数影响重大。优先级即权重,取值为0-1000,相当于可额外增加0-1000的票数,优先级的值越大,就越可能获得多数成员的投票(votes)数。指定较高的值可使成员更有资格成为主要成员,更低的值可使成员更不符合条件。默认情况下,优先级的值是1。
myrs:PRIMARY> rs.conf()
{
    "_id" : "myrs",
    "version" : 3,
    "term" : 1,
    "protocolVersion" : NumberLong(1),
    "writeConcernMajorityJournalDefault" : true,
    "members" : [
        {
            "_id" : 0,
            "host" : "192.168.0.128:27017",
            "arbiterOnly" : false,
            "buildIndexes" : true,
            "hidden" : false,
            "priority" : 1,
            "tags" : {
                
            },
            "slaveDelay" : NumberLong(0),
            "votes" : 1
        },
        {
            "_id" : 1,
            "host" : "公网ip:27018",
            "arbiterOnly" : false,
            "buildIndexes" : true,
            "hidden" : false,
            "priority" : 1,
            "tags" : {
                
            },
            "slaveDelay" : NumberLong(0),
            "votes" : 1
        },
        {
            "_id" : 2,
            "host" : "公网ip: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("5ffc222e8f297cc24be48002")
    }
}
  • 从执行结果可以看出,主节点和副本节点的优先级各为 1,即默认已有一票,但仲裁节点的优先级是0。(注意:其不能是别的值,即不具备选举权,但具有投票权)

故障测试

  • 副本节点故障测试:关闭27018副本节点后发现主节点和仲裁节点对27018的心跳失败。因为主节点还在,所以没有触发投票选举。若此时在主节点写入数据,再启动从节点后发现主节点写入的数据会自动同步给从节点。
db.comment.insert({"_id":"1","articleid":"100001","content":"我们不应该把清晨浪费在手机上,健康很重要,k一杯温水幸福你我他。","userid":"1002","nickname":"相忘于江湖","createdatetime":new Date("2019-08-05T22:08:15.522Z"),"likenum":NumberInt(1000),"state":"1"})
  • 主节点故障测试:关闭27017节点后发现从节点和仲裁节点对27017的心跳失败,当失败超过10秒,因为没有了主节点,所以会自动发起投票。而副本节点只有一个(27018),因此候选人只有一个就是27018,开始投票:
    • 27019向27018投了一票,27018本身自带一票,总共两票,超过了"大多数";
    • 27019是仲裁节点,没有选举权,27018不向其投票,其票数是0;
    • 最终结果:27018成为主节点,其具备读写功能;在27018写入数据查看。
    • 再启动 27017节点,发现27017变成了从节点,而27018仍保持主节点。
    • 登录27017节点,发现是从节点了,其数据自动从27018进行同步,从而实现了高可用。
  • 仲裁节点和主节点故障:先关掉仲裁节点27019,再关掉主节点27018,登录27017后,发现27017仍然是从节点,副本集中没有主节点了,导致此时的副本集是只读状态,无法写入。
    • 为啥不选举了?因为从节点27017没有获得大多数的票数,即小于2,它只有默认的一票(优先级是1)。
    • 若要触发选举,随便加入一个成员即可。
    • 若只加入27019仲裁节点成员,则主节点一定是27017,因为没得选了,且仲裁节点不参与选举,但参与投票。
    • 若只加入 27018节点,则会发起选举,因为27017和27018都是两票,此时按照谁数据新,谁当主节点。
  • 仲裁节点和从节点故障:先关掉仲裁节点27019,再关掉副本节点27018,10秒后,27017主节点自动降级为副本节点。(服务降级)副本集不可写入数据了,已经故障了。
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容