本文主要講述了MongoDB複製集的配置，動態修改及部分原理，最後建立了一個自動化部署的指令碼。

1 原理

資料集是多臺伺服器之間維護相同的資料副本，提高伺服器的可用性。主伺服器負責讀寫，從伺服器保持和主伺服器同樣的資料集，從伺服器為只讀狀態。

檢視複製集的幫助rs.help()

2 建立複製集過程

2.1 建立目錄

sudo mkdir /home/m17 /home/m18 /home/m19 /home/mlog

2.2 啟動3個例項

sudo mongod --dbpath /home/m17 --logpath /home/mlog/m17.log --fork --port 27017
 
 --replSet rs3
sudo mongod --dbpath /home/m18 --logpath /home/mlog/m18.log --fork --port 27018 --replSet rs3
sudo mongod --dbpath /home/m19 --logpath /home/mlog/m19.log --fork --port 27019 --replSet rs3

# --replSet宣告這個例項屬於某個複製集

2..3 配置複製集

登陸到任意一臺伺服器上

/* 複製集的配置 */
var rsconf = {
  _id: 'rs3',
  members: [
  {
    _id:0
 
,
    host: '192.168.21.130:27017'
  },
  {
    _id: 1,
    host: '192.168.21.130:27018'
  },
  {
    _id: 2,
    host: '192.168.21.130:27019'
  }
  ]
}

2.4 複製集的初始化

rs.initiate(rsconf);

rs3:OTHER> rs.status()  /* 檢視複製集狀態 */
{
    "set" : "rs3",
    "date" : ISODate("2016-04-20T01:27:29.900Z"),
    "myState"
 
 : 1,
    "term" : NumberLong(1),
    "heartbeatIntervalMillis" : NumberLong(2000),
    "members" : [  /* 表示了當前複製集的成員 */
        {
            "_id" : 0,
            "name" : "192.168.21.130:27017",
            "health" : 1,
            "state" : 1,
            "stateStr" : "PRIMARY",
            "uptime" : 686,
            "optime" : {
                "ts" : Timestamp(1461115634, 2),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2016-04-20T01:27:14Z"),
            "infoMessage" : "could not find member to sync from",
            "electionTime" : Timestamp(1461115634, 1),
            "electionDate" : ISODate("2016-04-20T01:27:14Z"),
            "configVersion" : 1,
            "self" : true
        },
        {
            "_id" : 1,
            "name" : "192.168.21.130:27018",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 26,
            "optime" : {
                "ts" : Timestamp(1461115634, 2),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2016-04-20T01:27:14Z"),
            "lastHeartbeat" : ISODate("2016-04-20T01:27:28.052Z"),
            "lastHeartbeatRecv" : ISODate("2016-04-20T01:27:29.707Z"),
            "pingMs" : NumberLong(1),
            "syncingTo" : "192.168.21.130:27017",
            "configVersion" : 1
        },
        {
            "_id" : 2,
            "name" : "192.168.21.130:27019",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 26,
            "optime" : {
                "ts" : Timestamp(1461115634, 2),
                "t" : NumberLong(1)
            },
            "optimeDate" : ISODate("2016-04-20T01:27:14Z"),
            "lastHeartbeat" : ISODate("2016-04-20T01:27:28.054Z"),
            "lastHeartbeatRecv" : ISODate("2016-04-20T01:27:29.708Z"),
            "pingMs" : NumberLong(0),
            "syncingTo" : "192.168.21.130:27017",
            "configVersion" : 1
        }
    ],
    "ok" : 1
}

2.5 動態修改複製整合員

/* 在primary例項上執行 */

/* 刪除成員 */
rs3:PRIMARY> rs.remove('192.168.21.130:27019')

/* 新增成員 */
rs3:PRIMARY> rs.add('192.168.21.130:27018')

2.6 檢視資料狀態

secondary 例項預設不能讀寫，只和 primary 例項保持通訊

在 secondary 例項上新增 rs.slaveOk() 來確保能夠正常讀

在primary例項上新增資料，可以在secondary例項上看到資料被同步了。

2.7 資料庫例項的角色切換

/* 關閉primary */
rs3:PRIMARY> use admin
switched to db admin
rs3:PRIMARY> db.shutdownServer()

/* 此時其他例項會自動變成primary */

2.8 自動化部署

下面的指令碼是一個自動部署三臺 MongoDB 例項的指令碼。

#!/bin/bash
#History:
#   Michael  4月,20,2016
#Program:
#

MONGOD=/usr/local/mongodb/bin/mongod
MONGO=/usr/local/mongodb/bin/mongo
IP=192.168.21.130
NA=rs3

sudo pkill -9 mongo
if [ -d /home/mlog ]
then
    sudo rm -rf /home/mlog || exit 1
fi
sudo mkdir -p /home/mlog || exit 2

for item in 17 18 19
do
    if [ -d /home/m${item} ]
    then
        sudo rm -rf /home/m${item} || exit 1
    fi
    sudo mkdir -p /home/m${item} || exit 2

    sudo $MONGOD --dbpath /home/m${item} --logpath /home/mlog/m${item}.log --port 270${item} --fork --smallfiles --replSet ${NA}
done

${MONGO} <<EOF
use admin
var rsconf = {
  _id: 'rs3',
  members: [
    { _id:0, host: '${IP}:27017' },
    { _id:1, host: '${IP}:27018' },
    { _id:2, host: '${IP}:27019' }
  ]
}
rs.initiate(rsconf);
EOF