MongoDB 副本集

MongoDB 副本集

副本集介绍

• 副本集是什么

- MongoDB 复制是将数据同步在多个服务器的过程。

- 复制提供了数据的冗余备份,并在多个服务器上存储数据副本,提高了数据的可用性, 并可以保证数据的安全性。

– 复制还允许您从硬件故障和服务中断中恢复数据

复制原理

• 副本集工作过程

– mongodb 的复制至少需要两个节点。其中一个是主节点,负责处理客户端请求,其余的都是从节点,负责复制主节点上的数据。

– mongodb 各个节点常见的搭配方式为:一主一从、一主多从。

– 主节点记录在其上的所有操作 oplog ,从节点定期轮询主节点获取这些操作,然后对自己的数据副本执行这些操作,从而保证从节点的数据与主节点一致。

副本集实现方式

• Master-Slave 主从复制

– 实现数据同步只需要在某一台服务器启动时加上 "-master" 参数,以指明此服务器的角色是 primary ;另一台服务器加上 "-slave" 和 "-source" 参数,以指明此服务器的角色是 slave 。

• 主从复制的优点如下:

– 从服务器可以执行查询工作,降低主服务器访问压力。

– 在从服务器执行备份,避免备份期间锁定主服务器的数据。

– 当主服务器出现故障时,可以快速切换到从服务器,减少当机时间。

副本集实现方式(续 1 )

• Replica Sets 复制集

– MongoDB 在 1.6 版本对开发了新功能 replica set,这比之前的 replication 功能要强大一些,增加了故障自动切换和自动修复成员节点,各个 DB 之间数据完全一致, 大大降低了维护成功。使用 replica set故障切换完全自动。

– Replica Sets 的结构类似一个集群,完全可以把它当成一个集群,因为它确实与集群实现的作用是一样的:如果其中一个节点出现故障,其他节点马上会将业务接管过来而无须停机操作

运行服务

• 启动服务时,指定主机所在副本集名称

– 副本集成员间使用相同的副本集名称

– --replSet rs1 // 指定副本集名称

[root@server0 ~]#mkdir /data/db

[root@server0 ~]#./mongod --bind_ip 192.168.4.51

--logpath=/var/log/mongod.log --replSet rs1 &

[root@server0 ~]# jobs

Running .........

配置节点信息

• 在任意一台主机连接 mongod 服务,执行如下操作

[root@server0 ~]# ./mongo --host 192.168.4.51

config = {

_id:"rs1",

members:[

{_id:0,host:“IP 地址 : 端口 "},

{_id:1,host:“IP 地址 : 端口 "},

{_id:2,host:“IP 地址 : 端口 "}

]

};

1.修改配置

# vim mongodb.conf

... ...

replSet=rs1

//加上这条

2.配置节点

> config = { _id:"rs1",

members:[

{_id:0,host:"192.168.4.51:27051"}, {_id:1,host:"192.168.4.52:27052"}, {_id:2,host:"192.168.4.53:27053"}, ] };

3.初始化

初始化 Replica Sets 环境

• 执行如下命令

– >rs.initiate(config)

查看副本集信息

• 查看状态信息

– > rs.status( )

• 查看是否是 master 库

– > rs .isMaster( )

验证副本集配置

• 同步数据验证

– >db.getMongo( ).setSlaveOk( ) //允许从库查看数据

• 自动切换主库验证

– > rs.isMaster( ) 查看是否是主库

插入文档

save( )

• 格式

– db. 集合名 .save({ key:”值”, key:“值” })

• 注意

– 集合不存在时创建集合,后插入记录

– _id 字段值已存在时修改文档字段值

– _id 字段值不已存在时插入文档

insert()

• 格式

– db. 集合名 .insert({key:“值”, key:”值” })

• 注意

– 集合不存在时创建集合,后插入记录

– _id 字段值已存在时放弃插入

– _id 字段值不已存在时插入文档

insert()( 续 1)

• 插入多条记录

db. 集合名 .insertMany(

[ {name:"xiaojiu”,age:19} ,

{name:"laoshi“,email:”yaya@tedu.cn“}]

)

查询语法

• 显示所有行,默认一次只输出 20 行输入 it 显示后续的

– db. 集合名 .find()

• 显示第 1 行

– > db. 集合名 .findOne()

• 指定查询条件并指定显示的字段

– > db. 集合名 .find ( { 条件 },{ 定义显示的字段 } )

– > db.user.find({},{_id:0,name:1,shell:1})

– 0 不显示 1 显示

行数显示限制

• limit( 数字 ) // 显示前几行

> db. 集合名 .find().limit(3)

• skip( 数字 ) // 跳过前几行

– > db. 集合名 .find().skip(2)

• sort({字段名} ) // 排序

– > db. 集合名 .find().sort({age:1|-1}) 1 升序 -1 降序

– > db.user.find({shell:"/sbin/nologin"},{_id:0,name:1,uid:

1,shell:1}).skip(2).limit(2)

rs1:PRIMARY> db.user.find({},{_id:0,name:1,uid:1}).limit(10).sort({uid:-1})

查询条件

查询条件

• 简单条件

– db. 集合名 .find({key:”值”})

– db. 集合名 .find({key:”值”, keyname:”值”})

– db.user.find({shell:"/bin/bash"})

– db.user.find({shell:"/bin/bash",name:"root"})

查询条件(续 1 )

• 范围比较

– $in 在...里

– $nin 不在...里

– $or 或

– > db.user.find({uid:{$in:[1,6,9]}})

– > db.user.find({uid:{$nin:[1,6,9]}})

– > db.user.find({$or: [{name:"root"},{uid:1} ]})

查询条件(续 2 )

• 正则匹配

– > db.user.find({name: /^a/ })

• 数值比较

– $lt $lte $gt $gte $ne

< <= > >= !=

– db.user.find( { uid: { $gte:10,$lte:40} } , {_id:0,name:1,uid:1})

– db.user.find({uid:{$lte:5,}})

查询条件(续 3 )

• 匹配 null , 也可以匹配没有的字段

– > db.user.save({name:null,uid:null})

– > db.user.find({name:null})

{ "_id" : ObjectId("5afd0ddbd42772e7e458fc75"), "name" : null, "uid" : null }

更新文档

update()

• 语法格式

– > db. 集合名 .update({ 条件 },{ 修改的字段 } )

注意:把文件的其他字段都删除了,只留下了 password 字段, 且只修改与条件匹配的第 1 行 !!!

$set / $unset

• $set 条件匹配时,修改指定字段的值

– db.user.update({ 条件 },$set: { 修改的字段 })

– db.user3.update({name:"bin"},{$set:{passwd:"A"}})

• $unset 删除与条件匹配文档的字段

– db. 集合名 .update({ 条件 },{$unset:{key:values}})

– db.user3.update({name:"bin"},{$unset:{passwd:"A"}})

1.字段值全改

更新：

db.user.update({passwd:"x"},{$set:{passwd:"B"}},false,true)

查看：

db.user.find({},{_id:0,passwd:1})

查看：

db.user.find({},{_id:0,passwd:1})

结果：

{"name":"bob","likes" : [ "a", "b", "c", "d", "e", "f",”w” ] }

多文档更新

• 语法格式:默认只更新与条件匹配的第 1 行

– > db.user.update({ 条件 },{$set:{ 修改的字段 }} ,false,true )

- > db.user.update({name:”bin”},{$set:{password:”abc12123”}}

,false,true)

$inc

• $inc 条件匹配时,字段值自加或自减

– Db. 集合名 .update({ 条件 },{$inc:{ 字段名 : 数字 }})

正整数自加负整数自减!!!!

– db.user.update({name:"bin"},{$inc:{uid:2}}) 字段值自加 2

– db.user.update({name:“bin”},{$inc:{uid:-1}}) 字段自减 1

$push / $addToSet

• $push 向数组中添加新元素

– db. 集合名 .update({ 条件 },{$push:{ 数组名 :”值”}})

– db.user.insert({name:"bob",likes:["a","b","c","d","e","f"]})

– db.user.update({name:"bob"},{$push:{likes:"w"}})

• $addToSet 避免重复添加

– db. 集合名 .update({ 条件 },{$addToSet:{ 数组名 :”值” }})

> db.user.update({name:"bob"},{$addToSet:{likes:”f”}})

$pop /$pull

• $pop 从数组头部删除一个元素

– db. 集合名 .update({ 条件 },{$pop:{ 数组名 : 数字 }})

– db.user.update({name:"bob"},{$pop:{likes:1}})

– db.user.update({name:"bob"},{$pop:{likes:-1}})

1 删除数组尾部元素 -1 删除数组头部元素

• $pull 删除数组指定元素

– db. 集合名 .update({ 条件 },{$pull:{ 数组名 : 值 }})

– db.user.update({name:"bob"},{$pull:{likes:"b"}})

删除文档

$drop/$remove

************************************

• $drop 删除集合的同时删除索引

– db. 集合名 .drop( )

– db.user.drop( )

• remove() 删除文档时不删除索引

– db. 集合名 .remove({}) // 删除所有文档

– db. 集合名 .remove({ 条件 }) // 删除与条件匹配的文档

– db.user.remove({uid:{$lte:10}})

– db.user.remove({})

文档更新

更新命令总结