redis-trib.rb –create源碼解析

一、 介紹

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

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

二、 流程概覽圖

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

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

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

四、 主從預分配以及節(jié)點預分配

說明：Redis-trib.rb create可以盡可能的將主庫的不同節(jié)點分配到不同的機器并且可以將主從庫物理機分離，此功能的實現調用了alloc_slots函數，我們截取了部分進行分析。

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

五、 配置集群

Redis-trib通過ruby連redis的客戶端進行配置集群

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

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

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

Redis-trib.rb –reshard源碼解析

一、概述

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

二、 流程圖

三、 關鍵步驟解析

說明：compute_reshard_table方法主要用來智能計算每個目標節(jié)點需要遷移多少slot

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

說明：在migrate節(jié)點之前需要設置slot importing狀態(tài)和migrating狀態(tài)

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

Redis-trib.rb --del-node

一、概述

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

二、流程圖

三、關鍵步驟

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

337行 選出集群中的master
338行-341行 根據master的slave個數排序，取出最少slave的master作為目標從庫的新master