五样傍,復(fù)制集

一角塑,概念

mongodb復(fù)制集是一主多從多節(jié)點(diǎn)實(shí)現(xiàn)數(shù)據(jù)庫(kù)集群的方式

1.1作用

首頁(yè)目標(biāo)是通過(guò)主節(jié)點(diǎn)快速的將oplog同步給從節(jié)點(diǎn)五慈,并在主節(jié)點(diǎn)發(fā)生故障的時(shí)候進(jìn)行選舉達(dá)到數(shù)據(jù)庫(kù)的高可用纳寂。
除此之外,還有:

  • 數(shù)據(jù)分發(fā)—將數(shù)據(jù)從一個(gè)區(qū)域復(fù)制到另一個(gè)區(qū)域泻拦,減少另一個(gè)區(qū)域的讀延遲
  • 讀寫(xiě)分離—不同類(lèi)型的壓力分別在不同的節(jié)點(diǎn)上執(zhí)行
  • 異地容災(zāi)—在數(shù)據(jù)中心故障時(shí)候快速切換到異地
1.2數(shù)據(jù)分發(fā)過(guò)程

當(dāng)一個(gè)修改操作毙芜,無(wú)論是插入、更新或刪除争拐,到達(dá)主節(jié)點(diǎn)時(shí)腋粥,它對(duì)數(shù)據(jù)的操作將被
記錄下來(lái)(經(jīng)過(guò)一些必要的轉(zhuǎn)換),這些記錄稱(chēng)為 oplog。

從節(jié)點(diǎn)通過(guò)在主節(jié)點(diǎn)上打開(kāi)一個(gè) tailable 游標(biāo)不斷獲取新進(jìn)入主節(jié)點(diǎn)的 oplog隘冲,并
在自己的數(shù)據(jù)上回放闹瞧,以此保持跟主節(jié)點(diǎn)的數(shù)據(jù)一致。

1.3選舉過(guò)程
  • 具有投票權(quán)的節(jié)點(diǎn)之間兩兩互相發(fā)送心跳展辞;
  • 當(dāng)5次心跳未收到時(shí)判斷為節(jié)點(diǎn)失聯(lián)奥邮;
  • 如果失聯(lián)的是主節(jié)點(diǎn),從節(jié)點(diǎn)會(huì)發(fā)起選舉纵竖,選出新的主節(jié)點(diǎn)漠烧;
  • 如果失聯(lián)的是從節(jié)點(diǎn)則不會(huì)產(chǎn)生新的選舉杏愤;
  • 選舉基于 RAFT一致性算法 實(shí)現(xiàn)靡砌,選舉成功的必要條件是大多數(shù)投票節(jié)點(diǎn)存活;
  • 復(fù)制集中最多可以有50個(gè)節(jié)點(diǎn)珊楼,但具有投票權(quán)的節(jié)點(diǎn)最多7個(gè)通殃。

影響選舉的因素:

  • 整個(gè)集群必須有大多數(shù)節(jié)點(diǎn)存活;
  • 被選舉為主節(jié)點(diǎn)的節(jié)點(diǎn)必須:
    1厕宗, 能夠與多數(shù)節(jié)點(diǎn)建立連接
    2画舌,具有較新的 oplog
    3,具有較高的優(yōu)先級(jí)(如果有配置)

二已慢,部署

準(zhǔn)備3份配置文件mongo1.conf曲聂,mongo2.conf,mongo3.conf

將端口號(hào)分別設(shè)置為28017/28018/28019

3個(gè)數(shù)據(jù)目錄:
/root/mongo/data/db1
/root/mongo/data/db2
/root/mongo/data/db3

3個(gè)日志文件路徑:
/root/mongo/data/db1/mongod.log
/root/mongo/data/db2/mongod.log
/root/mongo/data/db3/mongod.log

分別修改下面的配置

systemLog:
 destination: file
 path: /root/mongo/data/db1/mongod.log # log path
 logAppend: true
storage:
 dbPath: /root/mongo/data/db1 # data directory
net:
 bindIp: 0.0.0.0
 port: 28017 # port
replication:
 replSetName: rs0
processManagement:
 fork: true

啟動(dòng):

mongod -f mongo1.conf
mongod -f mongo2.conf
mongod -f mongo3.conf

//進(jìn)入第一個(gè)mongo
mongo --port 28017

//在mongo shell,初始化復(fù)制集并將節(jié)點(diǎn)加入復(fù)制集
rs.initiate({
  _id: "rs0",
  members: [{
    _id: 0,
    host: "localhost:28017"
  },{
    _id: 1,
    host: "localhost:28018"
  },{
    _id: 2,
    host: "localhost:28019"
  }]
})

//mongo shell佑惠,查看整個(gè)復(fù)制集群狀態(tài)
rs.status()
//返回,具體含義:https://docs.mongodb.com/manual/reference/command/replSetGetStatus/#dbcmd.replSetGetStatus
{
        "set" : "rs0",
        "date" : ISODate("2021-01-19T17:57:06.050Z"),//復(fù)制集當(dāng)前時(shí)間朋腋,可以通過(guò)和members[n].lastHeartbeat比對(duì)來(lái)確定節(jié)點(diǎn)延遲
        "myState" : 1,//0-10來(lái)代表節(jié)點(diǎn)不同狀態(tài),具體意思:https://docs.mongodb.com/manual/reference/replica-states/
        "term" : NumberLong(1),//投票計(jì)數(shù)器
        "syncSourceHost" : "",
        "syncSourceId" : -1,
        "heartbeatIntervalMillis" : NumberLong(2000),
        "majorityVoteCount" : 2,
        "writeMajorityCount" : 2,
        "votingMembersCount" : 3,
        "writableVotingMembersCount" : 3,
        "optimes" : {
                "lastCommittedOpTime" : {//當(dāng)前節(jié)點(diǎn)視角膜楷,最后已寫(xiě)入大多數(shù)副本集成員的最新操作的信息
                        "ts" : Timestamp(1611079016, 1),
                        "t" : NumberLong(1)
                },
                "lastCommittedWallTime" : ISODate("2021-01-19T17:56:56.332Z"),
                "readConcernMajorityOpTime" : {
                        "ts" : Timestamp(1611079016, 1),
                        "t" : NumberLong(1)
                },
                "readConcernMajorityWallTime" : ISODate("2021-01-19T17:56:56.332Z"),
                "appliedOpTime" : {//最后應(yīng)用于當(dāng)前節(jié)點(diǎn)操作信息
                        "ts" : Timestamp(1611079016, 1),
                        "t" : NumberLong(1)
                },
                "durableOpTime" : {//最后寫(xiě)入當(dāng)前節(jié)點(diǎn)日志操作信息
                        "ts" : Timestamp(1611079016, 1),
                        "t" : NumberLong(1)
                },
                "lastAppliedWallTime" : ISODate("2021-01-19T17:56:56.332Z"),
                "lastDurableWallTime" : ISODate("2021-01-19T17:56:56.332Z")
        },
        "lastStableRecoveryTimestamp" : Timestamp(1611078996, 1),
        "electionCandidateMetrics" : {
                "lastElectionReason" : "electionTimeout",
                "lastElectionDate" : ISODate("2021-01-19T17:51:36.306Z"),
                "electionTerm" : NumberLong(1),
                "lastCommittedOpTimeAtElection" : {
                        "ts" : Timestamp(0, 0),
                        "t" : NumberLong(-1)
                },
                "lastSeenOpTimeAtElection" : {
                        "ts" : Timestamp(1611078684, 1),
                        "t" : NumberLong(-1)
                },
                "numVotesNeeded" : 2,
                "priorityAtElection" : 1,
                "electionTimeoutMillis" : NumberLong(10000),
                "numCatchUpOps" : NumberLong(0),
                "newTermStartDate" : ISODate("2021-01-19T17:51:36.319Z"),
                "wMajorityWriteAvailabilityDate" : ISODate("2021-01-19T17:51:37.461Z")
        },
        "members" : [
                {
                        "_id" : 0,
                        "name" : "localhost:28017",
                        "health" : 1,
                        "state" : 1,
                        "stateStr" : "PRIMARY",
                        "uptime" : 783,
                        "optime" : {
                                "ts" : Timestamp(1611079016, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2021-01-19T17:56:56Z"),
                        "syncSourceHost" : "",
                        "syncSourceId" : -1,
                        "infoMessage" : "",
                        "electionTime" : Timestamp(1611078696, 1),
                        "electionDate" : ISODate("2021-01-19T17:51:36Z"),
                        "configVersion" : 1,
                        "configTerm" : 1,
                        "self" : true,
                        "lastHeartbeatMessage" : ""
                },
                {
                        "_id" : 1,
                        "name" : "localhost:28018",
                        "health" : 1,
                        "state" : 2,
                        "stateStr" : "SECONDARY",
                        "uptime" : 341,
                        "optime" : {
                                "ts" : Timestamp(1611079016, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDurable" : {
                                "ts" : Timestamp(1611079016, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2021-01-19T17:56:56Z"),
                        "optimeDurableDate" : ISODate("2021-01-19T17:56:56Z"),
                        "lastHeartbeat" : ISODate("2021-01-19T17:57:04.311Z"),
                        "lastHeartbeatRecv" : ISODate("2021-01-19T17:57:05.814Z"),
                        "pingMs" : NumberLong(0),
                        "lastHeartbeatMessage" : "",
                        "syncSourceHost" : "localhost:28017",
                        "syncSourceId" : 0,
                        "infoMessage" : "",
                        "configVersion" : 1,
                        "configTerm" : 1
                },
                {
                        "_id" : 2,
                        "name" : "localhost:28019",
                        "health" : 1,
                        "state" : 2,
                        "stateStr" : "SECONDARY",
                        "uptime" : 341,
                        "optime" : {
                                "ts" : Timestamp(1611079016, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDurable" : {
                                "ts" : Timestamp(1611079016, 1),
                                "t" : NumberLong(1)
                        },
                        "optimeDate" : ISODate("2021-01-19T17:56:56Z"),
                        "optimeDurableDate" : ISODate("2021-01-19T17:56:56Z"),
                        "lastHeartbeat" : ISODate("2021-01-19T17:57:04.312Z"),
                        "lastHeartbeatRecv" : ISODate("2021-01-19T17:57:05.815Z"),
                        "pingMs" : NumberLong(0),
                        "lastHeartbeatMessage" : "",
                        "syncSourceHost" : "localhost:28017",
                        "syncSourceId" : 0,
                        "infoMessage" : "",
                        "configVersion" : 1,
                        "configTerm" : 1
                }
        ],
        "ok" : 1,
        "$clusterTime" : {
                "clusterTime" : Timestamp(1611079016, 1),
                "signature" : {
                        "hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
                        "keyId" : NumberLong(0)
                }
        },
        "operationTime" : Timestamp(1611079016, 1)
}

從節(jié)點(diǎn)默認(rèn)是備份節(jié)點(diǎn)旭咽,無(wú)法讀取數(shù)據(jù),將從節(jié)點(diǎn)設(shè)置成可讀從節(jié)點(diǎn)

rs.slaveOk()//舊版本
rs.secondaryOk()//新版本

嘗試主節(jié)點(diǎn)寫(xiě)入赌厅,從節(jié)點(diǎn)讀惹蠲唷:

//主
mongo localhost:28017
db.test.insert({ a:1 })

//從
mongo localhost:28018
db.test.find()
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市特愿,隨后出現(xiàn)的幾起案子仲墨,更是在濱河造成了極大的恐慌,老刑警劉巖揍障,帶你破解...
    沈念sama閱讀 218,036評(píng)論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件目养,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡亚兄,警方通過(guò)查閱死者的電腦和手機(jī)混稽,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,046評(píng)論 3 395
  • 文/潘曉璐 我一進(jìn)店門(mén),熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái),“玉大人匈勋,你說(shuō)我怎么就攤上這事礼旅。” “怎么了洽洁?”我有些...
    開(kāi)封第一講書(shū)人閱讀 164,411評(píng)論 0 354
  • 文/不壞的土叔 我叫張陵痘系,是天一觀(guān)的道長(zhǎng)。 經(jīng)常有香客問(wèn)我饿自,道長(zhǎng)汰翠,這世上最難降的妖魔是什么? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 58,622評(píng)論 1 293
  • 正文 為了忘掉前任昭雌,我火速辦了婚禮复唤,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘烛卧。我一直安慰自己佛纫,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,661評(píng)論 6 392
  • 文/花漫 我一把揭開(kāi)白布总放。 她就那樣靜靜地躺著呈宇,像睡著了一般。 火紅的嫁衣襯著肌膚如雪局雄。 梳的紋絲不亂的頭發(fā)上甥啄,一...
    開(kāi)封第一講書(shū)人閱讀 51,521評(píng)論 1 304
  • 那天,我揣著相機(jī)與錄音炬搭,去河邊找鬼蜈漓。 笑死,一個(gè)胖子當(dāng)著我的面吹牛尚蝌,可吹牛的內(nèi)容都是我干的迎变。 我是一名探鬼主播,決...
    沈念sama閱讀 40,288評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼飘言,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼衣形!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起姿鸿,我...
    開(kāi)封第一講書(shū)人閱讀 39,200評(píng)論 0 276
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤谆吴,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后苛预,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體句狼,經(jīng)...
    沈念sama閱讀 45,644評(píng)論 1 314
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,837評(píng)論 3 336
  • 正文 我和宋清朗相戀三年热某,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了腻菇。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片胳螟。...
    茶點(diǎn)故事閱讀 39,953評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖筹吐,靈堂內(nèi)的尸體忽然破棺而出糖耸,到底是詐尸還是另有隱情,我是刑警寧澤丘薛,帶...
    沈念sama閱讀 35,673評(píng)論 5 346
  • 正文 年R本政府宣布嘉竟,位于F島的核電站,受9級(jí)特大地震影響洋侨,放射性物質(zhì)發(fā)生泄漏舍扰。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,281評(píng)論 3 329
  • 文/蒙蒙 一希坚、第九天 我趴在偏房一處隱蔽的房頂上張望边苹。 院中可真熱鬧,春花似錦吏够、人聲如沸勾给。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 31,889評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至脓钾,卻和暖如春售睹,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背可训。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,011評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工昌妹, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人握截。 一個(gè)月前我還...
    沈念sama閱讀 48,119評(píng)論 3 370
  • 正文 我出身青樓飞崖,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親谨胞。 傳聞我的和親對(duì)象是個(gè)殘疾皇子固歪,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,901評(píng)論 2 355

推薦閱讀更多精彩內(nèi)容