Replica sets架構(gòu)復(fù)制集(2)詳解

接上文，我們已經(jīng)搭建成功了，下面是我們查看日志等詳細(xì)解讀

我們可以通過(guò)執(zhí)行“db.printCollectionStats()”命令查看到操作日志的一些基本信息，如大小，日志啟動(dòng)時(shí)間等，查看primary 的oplog.rs表的元信息，代碼如下：

PRIMARY> db.printCollectionStats()
oplog.rs
{
 "ns" : "local.oplog.rs",
 "count" : 1,
 "size" : 80,
 "avgObjSize" : 80,
 "storageSize" : 990003200,
 "numExtents" : 1,
 "nindexes" : 0,
 "lastExtentSize" : 990003200,
 "paddingFactor" : 1,
 "flags" : 0,
 "totalIndexSize" : 0,
 "indexSizes" : {
  
 },
 "capped" : 1,
 "max" : 2147483647,
 "ok" : 1
}
---
system.replset
{
 "ns" : "local.system.replset",
 "count" : 1,
 "size" : 176,
 "avgObjSize" : 176,
 "storageSize" : 12288,
 "numExtents" : 1,
 "nindexes" : 0,
 "lastExtentSize" : 12288,
 "paddingFactor" : 1,
 "flags" : 0,
 "totalIndexSize" : 0,
 "indexSizes" : {
  
 },
 "ok" : 1
}
---
PRIMARY>

復(fù)制集搭建之后，需要做的第一件事就是要查看復(fù)制集的同步狀態(tài)，因?yàn)槿绻麖?fù)制集數(shù)據(jù)不同步，mongodb的復(fù)制集是不會(huì)起到任何效果的，通過(guò)執(zhí)行“db.printSlaveReplicationInfo()”命令，查看所有slave延時(shí)情況，例如：28011,28012端口上的slave的同步狀態(tài)。代碼如下：

PRIMARY> db.printSlaveReplicationInfo()
source:   localhost:28011
  syncedTo: Fri Jul 25 2014 10:03:17 GMT+0800 (CST)
   = 3437 secs ago (0.95hrs)
source:   localhost:28012
  syncedTo: Fri Jul 25 2014 10:03:17 GMT+0800 (CST)
   = 3437 secs ago (0.95hrs)
PRIMARY>

字段說(shuō)明：

1， source :從庫(kù)的IP及端口

2，syncedTo: 目前的同步情況，以及最后一次同步時(shí)間等信息。

主從配置信息

PRIMARY> db
local
PRIMARY> show collections
oplog.rs
system.replset
PRIMARY> db.system.replset.find()
{ "_id" : "rs1", "version" : 1, "members" : [

 {  "_id" : 0,  "host" : "localhost:28010" },  

{  "_id" : 1,  "host" : "localhost:28011" },  

{  "_id" : 2,  "host" : "localhost:28012" } ]

 }
PRIMARY>

在本例中，字段ID存儲(chǔ)復(fù)制集的名字，本例中的值是rs1,字段“members”存儲(chǔ)復(fù)制集成員的IP及端口信息。

管理Replica Sets

1,主從切換

                                                mongodb復(fù)制集測(cè)試環(huán)境

端口                                                當(dāng)前成員角色                                   目標(biāo)成員角色

28010                                                  主                                                          從

28011                                                   從                                                         從

28012                                                   從                                                         主

在本例中，端口28010對(duì)應(yīng)的是主庫(kù)，現(xiàn)在要將主庫(kù)放到28012的端口上，下面逐步引導(dǎo)大家完成配置

步驟1：除了現(xiàn)有的主實(shí)例（端口28010）和目標(biāo)主實(shí)例（端口28012）以外，其他的實(shí)例群全部設(shè)置為“冰凍”（freeze）狀態(tài)，即（非主狀態(tài)）；

本實(shí)例中將端口28011“冰凍”，代碼如下

PRIMARY> exit                                  --------------退出，切換到我們的27011
bye
[root@dota ~]# /usr/local/mongodb/bin/mongo --port 28011
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:28011/test
SECONDARY> rs.freeze(30)
{ "ok" : 1 }
SECONDARY>

通過(guò)執(zhí)行“rs.freeze(30)”命令，將端口在28011上的實(shí)例“冰凍”，其中30的單位是秒，說(shuō)明30秒內(nèi)這個(gè)實(shí)例不會(huì)參與primary的內(nèi)部選舉工作，即30內(nèi)此實(shí)例不會(huì)變成primary角色，那么就充分利用三十秒的時(shí)間完成切換工作。

步驟2，將當(dāng)前主庫(kù)的實(shí)例降級(jí),

 將端口在28010的主庫(kù)實(shí)例降級(jí)，代碼如下：

[root@dota ~]# /usr/local/mongodb/bin/mongo --port 28010
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:28010/test
PRIMARY> rs.stepDown()
Fri Jul 25 11:25:20 DBClientCursor::init call() failed
Fri Jul 25 11:25:20 query failed : admin.$cmd { replSetStepDown: 60.0 } to: 127.0.0.1:28010
Fri Jul 25 11:25:20 Error: error doing query: failed shell/collection.js:151
Fri Jul 25 11:25:20 trying reconnect to 127.0.0.1:28010
Fri Jul 25 11:25:20 reconnect 127.0.0.1:28010 ok

步驟3，查看操作之后的狀態(tài)

通過(guò)rs.status()查看操作后的狀態(tài)

SECONDARY> rs.status()
{
 "set" : "rs1",
 "date" : ISODate("2014-07-25T03:29:03Z"),
 "myState" : 2,
 "syncingTo" : "localhost:28012",
 "members" : [
  {
   "_id" : 0,
   "name" : "localhost:28010",
   "health" : 1,
   "state" : 2,
   "stateStr" : "SECONDARY",                                 -------此處降級(jí)實(shí)現(xiàn)
   "optime" : {
    "t" : 1406253797000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T02:03:17Z"),
   "self" : true
  },
  {
   "_id" : 1,
   "name" : "localhost:28011",
   "health" : 1,
   "state" : 2,
   "stateStr" : "SECONDARY",
   "uptime" : 219,
   "optime" : {
    "t" : 1406253797000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T02:03:17Z"),
   "lastHeartbeat" : ISODate("2014-07-25T03:29:02Z"),
   "pingMs" : 0
  },
  {
   "_id" : 2,
   "name" : "localhost:28012",
   "health" : 1,
   "state" : 1,
   "stateStr" : "PRIMARY",                                            -----看看，這貨升級(jí)了
   "uptime" : 219,
   "optime" : {
    "t" : 1406253797000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T02:03:17Z"),
   "lastHeartbeat" : ISODate("2014-07-25T03:29:02Z"),
   "pingMs" : 0
  }
 ],
 "ok" : 1
}
SECONDARY>

讀寫(xiě)分離

步驟一：先向主庫(kù)插入一條測(cè)試數(shù)據(jù)，代碼如下

------我們前面做了主從切換，28010不是 主，28012才是主，搞清楚實(shí)驗(yàn)環(huán)境

[root@dota ~]# /usr/local/mongodb/bin/mongo --port 28012
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:28012/test
PRIMARY> db
test
PRIMARY> db.c1.insert({age:30})
PRIMARY> db.c1.find()
{ "_id" : ObjectId("53d1ed7cb017538f84368f95"), "age" : 30 }

步驟二：在從庫(kù)中執(zhí)行查詢操作，代碼如下

------切換到從庫(kù)

[root@dota ~]# /usr/local/mongodb/bin/mongo --port 28011   MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:28011/test
SECONDARY> show dbs
admin (empty)
local 1.203125GB
test 0.203125GB
SECONDARY> db
test
SECONDARY> show collections                     ----在執(zhí)行這一行的時(shí)候報(bào)錯(cuò) 說(shuō)明這個(gè)從庫(kù)暫時(shí)不能執(zhí)行查詢操作
Fri Jul 25 13:40:36 uncaught exception: error: { "$err" : "not master and slaveok=false", "code" : 13435 }

步驟三，使從庫(kù)可以讀，以分擔(dān)主庫(kù)的壓力，代碼如下

SECONDARY> db.getMongo().setSlaveOk()
not master and slaveok=false
SECONDARY> show dbs
admin (empty)
local 1.203125GB
test 0.203125GB
SECONDARY> show collections
c1
system.indexes
SECONDARY> db.c1.find()
{ "_id" : ObjectId("53d1ed7cb017538f84368f95"), "age" : 30 }
SECONDARY>

故障轉(zhuǎn)移

將主庫(kù)的端口28012的mongodb進(jìn)程殺掉，在看看復(fù)制集的狀態(tài)

步驟一：殺掉28012端口的mongodb進(jìn)程，代碼如下

[root@dota ~]# ps aux | grep mongod
root      1523  0.4  4.8 1791408 49420 ?       Sl   Jul20  29:36 /usr/local/mongodb/bin/mongod --dbpath=/usr/local/mongodb/data --logpath=/usr/local/mongodb/logs/mongo.logs --logappend --fork
root      2737  0.0  0.0 103248   800 pts/0    S+   14:15   0:00 grep mongod
root     27933  1.5  4.2 3455684 42988 ?       Sl   09:50   4:01 /usr/local/mongodb/bin/mongod --replSet rs1 --keyFile /data/key/r0 --fork --port 28010 --dbpath /data/data/r0 --logpath=/data/log/r0.log --logappend
root     27950  0.3  3.6 3441068 36752 ?       Sl   09:52   0:55 /usr/local/mongodb/bin/mongod --replSet rs1 --keyFile /data/key/r1 --fork --port 28011 --dbpath /data/data/r1 --logpath=/data/log/r1.log --logappend
root     27967  3.0  3.7 3453368 38072 ?       Sl   09:53   7:54 /usr/local/mongodb/bin/mongod --replSet rs1 --keyFile /data/key/r2 --fork --port 28012 --dbpath /data/data/r2 --logpath=/data/log/r2.log --logappend
[root@dota ~]# kill -9 27967
[root@dota ~]#

步驟2，查看復(fù)制集狀態(tài)，代碼如下：

[root@dota ~]# /usr/local/mongodb/bin/mongo --port 28011
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:28011/test
SECONDARY> rs.status()
{
 "set" : "rs1",
 "date" : ISODate("2014-07-25T06:19:24Z"),
 "myState" : 2,
 "syncingTo" : "localhost:28010",
 "members" : [
  {
   "_id" : 0,
   "name" : "localhost:28010",
   "health" : 1,
   "state" : 1,
   "stateStr" : "PRIMARY",
   "uptime" : 15356,
   "optime" : {
    "t" : 1406266748000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T05:39:08Z"),
   "lastHeartbeat" : ISODate("2014-07-25T06:19:23Z"),
   "pingMs" : 0
  },
  {
   "_id" : 1,
   "name" : "localhost:28011",
   "health" : 1,
   "state" : 2,
   "stateStr" : "SECONDARY",
   "optime" : {
    "t" : 1406266748000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T05:39:08Z"),
   "self" : true
  },
  {
   "_id" : 2,
   "name" : "localhost:28012",
   "health" : 0,
   "state" : 8,
   "stateStr" : "(not reachable/healthy)",
   "uptime" : 0,
   "optime" : {
    "t" : 1406266748000,
    "i" : 1
   },
   "optimeDate" : ISODate("2014-07-25T05:39:08Z"),
   "lastHeartbeat" : ISODate("2014-07-25T06:17:17Z"),
   "pingMs" : 0,
   "errmsg" : "socket exception"
  }
 ],
 "ok" : 1
}
SECONDARY>

上面?zhèn)兛梢钥吹剑ㄟ^(guò)執(zhí)行rs.status命令查看復(fù)制集狀態(tài)，28012端口mongodb出現(xiàn)異常，狀態(tài)信息是not reaschable/healthy,說(shuō)明他已經(jīng)是一個(gè)無(wú)效的復(fù)制集成員，而系統(tǒng)經(jīng)過(guò)自動(dòng)選舉之后，選舉28010端口作為主庫(kù)，28011端口任然為從庫(kù)，則有的故障處理機(jī)制，能將系統(tǒng)的穩(wěn)定性和連續(xù)性大大提高，解決了藏劍的單點(diǎn)故障問(wèn)題。