上一篇 我們模擬了單機器下哨兵模式的搭建，那么接下來我們看下哨兵模式的實作與作業，
為什么又分成兩篇呢？因為篇幅太長（偷懶），再一個這篇主要說的是Sentinel的初始化以及資訊交換，下一篇著重說下狀態檢查、Sentinel頭領選舉與故障轉移 ，
啟動并初始化Sentinel
當一個Sentinel啟動時，需要執行以下步驟：
（1）初始化服務器，
因為Sentinel本事上是一個運行在特殊模式下的Redis服務器，所以啟動時的第一步也就是初始化一個普通的Redis服務器，不同點是在初始化的時候不會載入RDB或AOF檔案，
（2）將普通的Redis服務器使用的代碼替換成Sentinel專用代碼，
埠替換Redis服務器使用redis.h/REDIS_SERVERPORT（6379）常量作為服務器埠，而Sentinel則使用sentinel.c/REDIS_SENTINEL_PORT（26379）常量作為服務器埠，
另外Redis服務器使用redisCommandTable服務器作為命令表，而Sentinel則使用sentinelcmds作為服務器的命令表，并且其中的info命令會使用Sentinel模式下專用的sentinelInfoCommand函式，而不是普通redis服務器使用的redis.c/infoCommand函式，
（3）初始化Sentinel狀態，
服務器會初始化一個sentinel.c/sentinelState結構（'Sentinel狀態'），用于保存服務器中所有和Sentinel功能有關的狀態，
struct sentinelState{ //當前紀元，用于實作故障轉移 uint64_t current_epoch; //保存了所有被這個sentinel監視的主服務器 //字典的鍵是主服務器的名字 //字典中的值是一個指向sentinelRedisInstance結構的指標 dict *masters; //是否進入TILT模式 int tilt; //目前正在執行的腳本數量 int running_scripts; //進圖TILT模式的時間 mstime_t tilt_start_time; //一個FIFO佇列，包含了所有需要執行的用戶腳本 list *scripts_queue; } sentinel;
（4）根據給定的組態檔，初始化Sentinel的監視主服務器串列，
sentinelRedisInstance結構（實體結構）
typedef struct sentinelRedisInstance{ //標識值，記錄了實體的型別以及該實體的當前狀態 int flag; //實體的名稱（主服務器由用戶配置，從服務器自動設定ip:port） char *name; //實體的運行id char *runid; //配置紀元，用戶實作故障轉移 uint64_t config_epoch; //實體的地址 //sentinelAddr *addr; //實體無相應多少毫秒之后才會被判斷主觀下線 mstime_t down_after_period‘； //判斷這個實體為客觀下線所需要支持的投票數量 int quorun; //在執行故障轉移操作時，可以同時對新的主服務器進行同步的從服務器數量 int parallel_syncs; //重繪故障遷移狀態的最大時間限制 mstime_t fallover_timeout; } sentinelRedisInstance;
*addr 指向sentinelAddr結構：
typedef struct sentinelAddr{ char *ip; int port; } sentinelAddr;
根據用戶的配置初始化實體結構：
#名稱 ip port
sentinel monitor mymaster 127.0.0.1 6379 2
#實體在相應多少毫秒之后才會被判斷主觀下線
sentinel down-after-milliseconds mymaster 3000
sentinel failover-timeout mymaster 10000
#在執行故障轉移操作時，可以同時對新的主服務器進行同步的從服務器數量
sentinel parallel-syncs mymaster 1
（5）創建連向主服務器的網路連接，
Sentinel將稱為主服務器的客戶端，它可以向主服務器發送命令，并從命令回復中獲取相關的資訊：對于被Sentinel監視的主服務器來說，Sentinel會創建兩個連向主服務器的異步網路連接，一個是命令連接這個連接專門用于向主服務器發送命令，并接收命令回復；另一個是訂閱連接這個連接專門用于訂閱主服務器的_sentinel_:hollo頻道，
獲取主服務器資訊
sentinel默認會以每十秒一次的頻率，通過命令連接向被監視的主服務器發送INFO命令，并通過分析INFO命令的回復來獲取主服務器的當前資訊，
通過分析主服務器回傳的INFO命令回復，Sentinel可以獲取以下兩個方面的資訊：
一方面是關于主服務器本身的資訊，包括run_id域記錄的服務器運行ID以及role域記錄的服務器角色；另一方面是關于主服務器屬下的所有從服務器資訊，每個從服務器由一個“slave”字串開頭的行記錄，每行的ip=域記錄了從服務器的IP地址，而port=域則記錄了從服務器的埠號，根據這些IP地址和埠號，Sentinel無須用戶提供從服務器的地址資訊，就可以自動發現從服務器，
主服務器 實力結構的flags屬性的值為SRI_MASTER，而從服務器實體結構的flags屬性的值為SRI_SLAVE，
當Sentinel發現主服務器有新的從服務器出現時，Sentinel除了會為這個新的從服務器創建相應的實體結構外，Sentinel還會創建連接到從服務器的命令連接和訂閱連接，
在默認情況下，Sentinel會以每兩秒一次的頻率，通過命令連接向所有被監視的主服務器和從服務器發送以下格式的命令，PUBLISH _sentinel_:hello "< s_ip > < s_port >< s_runid >< s_epoch > < m_name > < m_ip >< m_ip ><m_epoch>"，
接收來自主服務器和從服務器的頻道資訊
當Sentinel與一個主服務器或者從服務器建立起訂閱連接之后，Sentinel就會通過訂閱連接，向服務器發送以下命令：SUBSCRIBE __semtomel__:hello
當一個Sentinel從__sentinel__:hello頻道收到一條資訊時，Sentinel會對這條資訊進行分析，提取出資訊中的Sentinel IP地址，Sentinel埠號，Sentinel運行ID等八個引數，并進行檢查：如果資訊中記錄的Sentinel運行ID和基爾獸資訊的Sentinel的運行ID相同，那么說明這條資訊時Sentinel自己發送的，Sentinel將丟棄這條資訊，不做處理，反之如果記錄的Sentinel運行ID和接收訊息的Sentinel的運行ID不相同，那么說明這條資訊時監視同一個服務器的其他Sentinel發來的，接收資訊的Sentinel將根據這些資訊中的引數，對相應主服務器的實體結構進行更新，
Sentinel為主服務器創建的實體結構中的sentinels字典中除了保存本身以外，還會保存同樣監視這個主服務器的其他Sentinel的資料，其中字典鍵為 ip:port 值為Sentinel實體結構，
如果目標Sentinel（接收訊息的Sentinel）接收到源Sentinel（發送訊息的Sentinel）的訊息，提取其中的引數檢查主服務器實體結構的sentinels字典中源Sentinel實體結構是否存在，如果存在則更新，不存在則創建實體結構并存盤到主服務器的sentinels字典中，并且，目標Sentinel還會創建連接向源Sentinel的命令連接，最終監視同一主服務器的多個Sentinel將形成互相連接的網路，
但是Sentinel之間不對創建訂閱連接，這是因為Sentinel需要通過接收主服務器或者從服務器發來的頻道資訊發現未知的新Sentinel，所以才需要建立訂閱連接，而相互已知的Sentinel只要使用命令連接來進行通信就足夠了，
每天學一點，總會有識訓，
下篇我們看下Redis的Sentinel(哨兵)的狀態檢查、Sentinel頭領選舉與故障轉移，
說明：尊重作者知識產權，文中內容參考《Redis設計與實作》，僅在此做學習與大家分享，
轉載請註明出處，本文鏈接：https://www.uj5u.com/shujuku/2471.html
標籤：NoSQL