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",
"state" : 2,
"stateStr" : "SECONDARY",
"uptime" : 21,
"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",
"state" : 7,
"stateStr" : "ARBITER",
"uptime" : 2,
"lastHeartbeat" : ISODate("2015-10-12T17:01:29Z"),
"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()
跟Primary一樣