天天看點

MongoDB 簡單複制配置

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一樣