redis-trib.rb –create源碼解析

一、 介紹

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

創(chuàng)新互聯(lián)建站堅(jiān)持“要么做到，要么別承諾”的工作理念，服務(wù)領(lǐng)域包括：網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣等服務(wù)，滿足客戶于互聯(lián)網(wǎng)時(shí)代的資興網(wǎng)站設(shè)計(jì)、移動(dòng)媒體設(shè)計(jì)的需求，幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴！

二、 流程概覽圖

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

 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)信息:

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

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

說明：Redis-trib.rb create可以盡可能的將主庫的不同節(jié)點(diǎn)分配到不同的機(jī)器并且可以將主從庫物理機(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)的分開
第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通過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)檢測

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

---

---

Redis-trib.rb –reshard源碼解析

一、概述

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

二、 流程圖

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

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

775行 通過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ù)的百分比來遷移slot，及slot個(gè)數(shù)越多的節(jié)點(diǎn)將被遷移更多。還可以看到slot節(jié)點(diǎn)最多的節(jié)點(diǎn)會(huì)為slot的最大整數(shù)
786行-791行 將slot的分派到節(jié)點(diǎn)的信息插入moved變量中

說明：在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)鍵步驟

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

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

網(wǎng)頁標(biāo)題：Redis-trib.rb解析
文章分享：http://chinadenli.net/article24/gogsce.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計(jì)、手機(jī)網(wǎng)站建設(shè)、微信小程序、ChatGPT、網(wǎng)站排名、網(wǎng)站收錄

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)