您的位置:首页 > 数据库 > Mongodb

MongoDB 简单复制配置

2015-10-12 20:07 411 查看
MongoDB的replication配置比MySQL简单,而且感觉更智能一些。
配置非常简单,先简单介绍一下环境:
Primary 一台
Secondary 一台
Arbiter 一台
分别三台机器,通过一个10.10.1.0 的subnet链接起来。
分别在每台机器的mongo.conf的配置文件上添加一个配置如下:
replSet=rs0
可以不命名为rs0,也可以命名其它,反正每台机器的repSet一样就OK了。

用mongo shell登录mongodb,然后,创建一个cfg的BSON格式变量,如下:
cfg={
"_id" : "rs0",
"members" :
[ { "_id" : 0, "host" : "10.10.1.55:27017" }, { "_id" : 1, "host" : "10.10.1.56:27017" } ]
}
10.10.1.55是Primary机器,1.56是secondary,在此无需添加Arbiter先。
继续输入下面的命名(只要在Primary上输入即可)
rs.initiate(cfg)
rs.status()
经过上面的两条命令你就发现一台机器是Primary,一台是Secondary。

现在输入下面的命令创建Arbiter:

rs.addArb("10.10.1.57")
再次输入rs.statsu(),应该会有如下内容:
rs0:PRIMARY> rs.status()
{
"set" : "rs0",
"date" : ISODate("2015-10-12T17:01:31Z"),
"myState" : 1,
"members" : [
{
"_id" : 0,
"name" : "10.10.1.55:27017",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
"uptime" : 66,
"optime" : Timestamp(1444636144, 1),
"optimeDate" : ISODate("2015-10-12T07:49:04Z"),
"electionTime" : Timestamp(1444669275, 1),
"electionDate" : ISODate("2015-10-12T17:01:15Z"),
"self" : true
},
{
"_id" : 1,
"name" : "10.10.1.56:27017",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
"uptime" : 21,
"optime" : Timestamp(1444636144, 1),
"optimeDate" : ISODate("2015-10-12T07:49:04Z"),
"lastHeartbeat" : ISODate("2015-10-12T17:01:30Z"),
"lastHeartbeatRecv" : ISODate("2015-10-12T17:01:30Z"),
"pingMs" : 105,
"lastHeartbeatMessage" : "syncing to: 10.10.1.55:27017",
"syncingTo" : "10.10.1.55:27017"
},
{
"_id" : 2,
"name" : "10.10.1.57:27017",
"health" : 1,
"state" : 7,
"stateStr" : "ARBITER",
"uptime" : 2,
"lastHeartbeat" : ISODate("2015-10-12T17:01:29Z"),
"lastHeartbeatRecv" : ISODate("2015-10-12T17:01:30Z"),
"pingMs" : 1002
}
],
"ok" : 1
}

这样MongoDB的Replication就配置完成了,再看看能不能实现复制。
在Primary 上输入:
rs0:PRIMARY> use students;
switched to db students
rs0:PRIMARY> db.scores.insert({"stuid":1,"subject":"math","score":99})
WriteResult({ "nInserted" : 1 })

rs0:PRIMARY> use local
switched to db local

rs0:PRIMARY> db.oplog.rs.find()
{ "ts" : Timestamp(1444636024, 1), "h" : NumberLong(0), "v" : 2, "op" : "n", "ns" : "", "o" : { "msg" : "initiating set" } }
{ "ts" : Timestamp(1444636144, 1), "h" : NumberLong("-5201159559565017071"), "v" : 2, "op" : "n", "ns" : "", "o" : { "msg" : "Reconfig set", "version" : 2 } }
{ "ts" : Timestamp(1444669489, 1), "h" : NumberLong("-3625785754623372300"), "v" : 2, "op" : "i", "ns" : "students.scores", "o" : { "_id" : ObjectId("561be83187dabed86388bff7"), "stuid" : 1, "subject" : "math", "score" : 99 } }

最后一条,表示刚刚插入的数据通过oplog复制过去Secondary了,这时候可以登录Secondary查看是否有该数据库以及该条数据:
rs.slaveOk();
use students
db.scores.find()
这样就会出现刚刚那条数据。

现在模拟一下Primary机器挂掉的情况,在系统shell上输入:
ps -ef|grep mongo

kill -9 mongodPID
杀掉mongodb进程

在原来的secondary上输入rs.status()你会发现secondary变成了primary了。重新启动挂掉的primary就会成为新的secondary了。可以在新的primary服务器上输入:rs.setpDown()来重新选举出原来的primary。
如果Secondary挂掉,重启后是否还能自动完成复制?
现在用kill来杀掉secondary的进程,之后在primary上插入若干条记录。
rs0:PRIMARY> for(var i=2;i<1000;i++) db.scores.insert({"stuid":i,"subject":"math","score":99})

rs0:PRIMARY> db.scores.find().count()
999

一共有999行。现在重启一下secondary数据库,输入:
rs.slaveOk()
rs0:SECONDARY> db.scores.find().count()
999
跟Primary一样

本文出自 “技术博客” 博客,请务必保留此出处http://raytech.blog.51cto.com/7602157/1702227
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: