MongoDB的replication配置比MySQL简单,而且感觉更智能一些。
配置非常简单,先简单介绍一下环境:
Primary 一台
Secondary 一台
Arbiter 一台
分别三台机器,通过一个10.10.1.0 的subnet链接起来。
分别在每台机器的mongo.conf的配置文件上添加一个配置如下:
replSet=rs0
可以不命名为rs0,也可以命名其它,反正每台机器的repSet一样就OK了。?
用mongo shell登录mongodb,然后,创建一个cfg的BSON格式变量,如下:
10.10.1.55是Primary机器,1.56是secondary,在此无需添加Arbiter先。
继续输入下面的命名(只要在Primary上输入即可)
经过上面的两条命令你就发现一台机器是Primary,一台是Secondary。?
现在输入下面的命令创建Arbiter:
再次输入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一样
更多MongoDB相关内容可以看看以下的有用链接:?