Redis-trib.rb –create源碼解析

一、 介紹

Redis-trib.rb為主流的Redis管理工具，對(duì)Redis一系列命令進(jìn)行了封裝通過(guò)ruby客戶端完成Create Cluster，Reshard Cluster,Add Slave，Remove Node等功能。下面我們來(lái)看下Create Cluster建立cluster集群是如何實(shí)現(xiàn)的。

創(chuàng)新互聯(lián)是專業(yè)的天涯網(wǎng)站建設(shè)公司，天涯接單;提供做網(wǎng)站、網(wǎng)站制作,網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行天涯網(wǎng)站開(kāi)發(fā)網(wǎng)頁(yè)制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛(ài)的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來(lái)合作!

二、 流程概覽圖

三、 節(jié)點(diǎn)可用性檢測(cè)

 1. 節(jié)點(diǎn)連通性
 2. 是否配置了cluster模式(if cluster_enabled==1?）
 3. 是否已經(jīng)為其他集群成員（if cluster_known_nodes==1?）
 4. 檢查至少有三個(gè)可用節(jié)點(diǎn)
 5. 獲取節(jié)點(diǎn)信息:

通過(guò)cluster nodes 命令獲得統(tǒng)計(jì)信息
name,addr,flags,master_id, ping_sent,ping_recv,config_epoch,link_status,slot信息
如：

四、 主從預(yù)分配以及節(jié)點(diǎn)預(yù)分配

說(shuō)明：Redis-trib.rb create可以盡可能的將主庫(kù)的不同節(jié)點(diǎn)分配到不同的機(jī)器并且可以將主從庫(kù)物理機(jī)分離，此功能的實(shí)現(xiàn)調(diào)用了alloc_slots函數(shù)，我們截取了部分進(jìn)行分析。

第559行-562行：將節(jié)點(diǎn)根據(jù)ip進(jìn)行歸類，dict的key為ip，value為這個(gè)ip所對(duì)應(yīng)的節(jié)點(diǎn)信息。
第566行-577行：循環(huán)ip，每次抽取ip的一個(gè)節(jié)點(diǎn)放到interleaved里。這可以盡可能讓相同節(jié)點(diǎn)的分開(kāi)
第578行：截取interleaved里前幾個(gè)節(jié)點(diǎn)作為masters_count，master_count是根據(jù)節(jié)點(diǎn)參數(shù)個(gè)數(shù)以及replacas個(gè)數(shù)決定的。
第585行-594行:根據(jù)節(jié)點(diǎn)的個(gè)數(shù)，對(duì)每個(gè)master節(jié)點(diǎn)所對(duì)應(yīng)的slot范圍進(jìn)行計(jì)算。

五、 配置集群

Redis-trib通過(guò)ruby連redis的客戶端進(jìn)行配置集群

1. 對(duì)主節(jié)點(diǎn)進(jìn)行slot分配（addslots），cluster_state become ok and cluster_slots_assigned become not null
2. 為每個(gè)節(jié)點(diǎn)設(shè)置不同的config_epoch（set-config-epoch）
3. 節(jié)點(diǎn)加入集群（CLUSTER MEET）
4. 主從配置（replicate）
5. 等待所有節(jié)點(diǎn)都有相同的集群配置信息

六、 集群狀態(tài)檢測(cè)

1. 檢查是否有open slot
   Openslot定義為slot信息為migrating或者importing，標(biāo)示為->-。
   2.檢查slot是否全覆蓋

---

Redis-trib.rb –reshard源碼解析

一、概述

在新主節(jié)點(diǎn)被加入集群后，他沒(méi)有任何slot數(shù)據(jù)，需要通過(guò)reshard從其他節(jié)點(diǎn)中遷移些slot到新節(jié)點(diǎn)。

二、 流程圖

三、 關(guān)鍵步驟解析

說(shuō)明：compute_reshard_table方法主要用來(lái)智能計(jì)算每個(gè)目標(biāo)節(jié)點(diǎn)需要遷移多少slot

775行 通過(guò)slot個(gè)數(shù)對(duì)源節(jié)點(diǎn)進(jìn)行排序，slot多的排在前面
776行-778行 計(jì)算源節(jié)點(diǎn)的slot總個(gè)數(shù)
779行-785行 可以看到按照節(jié)點(diǎn)占slot總數(shù)的百分比來(lái)遷移slot，及slot個(gè)數(shù)越多的節(jié)點(diǎn)將被遷移更多。還可以看到slot節(jié)點(diǎn)最多的節(jié)點(diǎn)會(huì)為slot的大整數(shù)
786行-791行 將slot的分派到節(jié)點(diǎn)的信息插入moved變量中

說(shuō)明：在migrate節(jié)點(diǎn)之前需要設(shè)置slot importing狀態(tài)和migrating狀態(tài)

redis支持動(dòng)態(tài)遷移。當(dāng)slot被設(shè)置為狀態(tài)migrating狀態(tài)后，當(dāng)redis client查詢節(jié)點(diǎn)這個(gè)slot所對(duì)應(yīng)的key時(shí)，如果節(jié)點(diǎn)發(fā)現(xiàn)這個(gè)key存在直接返回值，如果發(fā)現(xiàn)這個(gè)key不存在自己的slot里他會(huì)發(fā)送asking 請(qǐng)求告訴客戶端去遷移的目標(biāo)節(jié)點(diǎn)查并且不更改客戶端維護(hù)的slot分布信息，當(dāng)客戶端請(qǐng)求目標(biāo)節(jié)點(diǎn)時(shí)該slot時(shí)都是refuse并重定向的，當(dāng)請(qǐng)求包含asking時(shí)他就會(huì)接受這個(gè)請(qǐng)求并讀取key。當(dāng)遷移完成，他會(huì)設(shè)置setslot node ，這個(gè)操作將會(huì)把slot遷移狀態(tài)清除并設(shè)置該slot的新的目標(biāo)節(jié)點(diǎn)。

---

Redis-trib.rb --del-node

一、概述

del-node用于剔除集群中的節(jié)點(diǎn)。

二、流程圖

三、關(guān)鍵步驟

說(shuō)明：get_master_with_least_replicas方法如果delete node有從庫(kù)，他將指定他的從庫(kù)去其他主節(jié)點(diǎn)。

337行 選出集群中的master
338行-341行 根據(jù)master的slave個(gè)數(shù)排序，取出最少slave的master作為目標(biāo)從庫(kù)的新master

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

網(wǎng)站標(biāo)題：Redis-trib.rb解析-創(chuàng)新互聯(lián)
當(dāng)前URL：http://weahome.cn/article/hpjed.html