Redis原始碼閱讀（五）叢集-故障遷移（上）

void clusterSendPing(clusterLink *link, int type) { //隨機算去本節點所在叢集中的任意兩個其他node節點(不包括link本節點和link對應的節點)資訊傳送給link對應的節點
unsigned char buf[sizeof(clusterMsg)];
clusterMsg *hdr = (clusterMsg*) buf;
int gossipcount = 0, totlen;
/* freshnodes is the number of nodes we can still use to populate the
* gossip section of the ping packet. Basically we start with the nodes
* we have in memory minus two (ourself and the node we are sending the
* message to). Every time we add a node we decrement the counter, so when
* it will drop to <= zero we know there is no more gossip info we can
* send. */
int freshnodes = dictSize(server.cluster->nodes)-2; //除去本節點和接收本ping資訊的節點外，整個叢集中有多少其他節點
// 如果傳送的資訊是 PING ，那麼更新最後一次傳送 PING 命令的時間戳
if (link->node && type == CLUSTERMSG_TYPE_PING)
link->node->ping_sent = mstime();
// 將當前節點的資訊（比如名字、地址、埠號、負責處理的槽）記錄到訊息裡面
clusterBuildMessageHdr(hdr,type);
/* Populate the gossip fields */
// 從當前節點已知的節點中隨機選出兩個節點
// 並通過這條訊息捎帶給目標節點，從而實現 gossip 協議
// 每個節點有 freshnodes 次傳送 gossip 資訊的機會
// 每次向目標節點發送 3 個被選中節點的 gossip 資訊（gossipcount 計數）
while(freshnodes > 0 && gossipcount < 3) {
// 從 nodes 字典中隨機選出一個節點（被選中節點）
dictEntry *de = dictGetRandomKey(server.cluster->nodes);
clusterNode *this = dictGetVal(de);

clusterMsgDataGossip *gossip; ////pingpong meet訊息體部分用該結構
int j;

if (this == myself ||
this->flags & (REDIS_NODE_HANDSHAKE|REDIS_NODE_NOADDR) ||
(this->link == NULL && this->numslots == 0))
{
freshnodes--; /* otherwise we may loop forever. */
continue;
}

/* Check if we already added this node */
// 檢查被選中節點是否已經在 hdr->data.ping.gossip 數組裡面
// 如果是的話說明這個節點之前已經被選中了
// 不要再選中它（否則就會出現重複）
for (j = 0; j < gossipcount; j++) {//這裡是避免前面隨機選擇clusterNode的時候重複選擇相同的節點
if (memcmp(hdr->data.ping.gossip[j].nodename,this->name,
REDIS_CLUSTER_NAMELEN) == 0) break;
}
if (j != gossipcount) continue;
/* Add it */
// 這個被選中節點有效，計數器減一
freshnodes--;
// 指向 gossip 資訊結構
gossip = &(hdr->data.ping.gossip[gossipcount]);
// 將被選中節點的名字記錄到 gossip 資訊
memcpy(gossip->nodename,this->name,REDIS_CLUSTER_NAMELEN);
// 將被選中節點的 PING 命令傳送時間戳記錄到 gossip 資訊
gossip->ping_sent = htonl(this->ping_sent);
// 將被選中節點的 PING 命令回覆的時間戳記錄到 gossip 資訊
gossip->pong_received = htonl(this->pong_received);
// 將被選中節點的 IP 記錄到 gossip 資訊
memcpy(gossip->ip,this->ip,sizeof(this->ip));
// 將被選中節點的埠號記錄到 gossip 資訊
gossip->port = htons(this->port);
// 將被選中節點的標識值記錄到 gossip 資訊
gossip->flags = htons(this->flags);
// 這個被選中節點有效，計數器增一
gossipcount++;
}
// 計算資訊長度
totlen = sizeof(clusterMsg)-sizeof(union clusterMsgData);
totlen += (sizeof(clusterMsgDataGossip)*gossipcount);
// 將被選中節點的數量（gossip 資訊中包含了多少個節點的資訊）
// 記錄在 count 屬性裡面
hdr->count = htons(gossipcount);
// 將資訊的長度記錄到資訊裡面
hdr->totlen = htonl(totlen);
// 傳送資訊
clusterSendMessage(link,buf,totlen);
}

收到ping訊息的節點，如果發現ping訊息中帶的某個節點屬於疑似下線狀態，則找到自身記錄該節點的ClusterNode結構，並向該結構的下線報告連結串列中插入一條上報記錄，上報源頭為發出Ping的節點。例如：節點A向節點C傳送了ping訊息， ping訊息中帶上B節點狀態，並且B節點狀態為疑似下線，那麼C節點收到這個Ping訊息之後，就會查詢自身記錄節點B的clusterNode，向這個clusterNode的fail_reports連結串列中插入來自A的下線報告。

void clusterSendFail(char *nodename) { 
//如果超過一半的主節點認為該nodename節點下線了，則需要把該節點下線資訊同步到整個cluster叢集
unsigned char buf[sizeof(clusterMsg)];
clusterMsg *hdr = (clusterMsg*) buf;
// 建立下線訊息 
clusterBuildMessageHdr(hdr,CLUSTERMSG_TYPE_FAIL); 
// 記錄命令 
memcpy(hdr->data.fail.about.nodename,nodename,REDIS_CLUSTER_NAMELEN); 
// 廣播訊息
clusterBroadcastMessage(buf,ntohl(hdr->totlen));
}

void clusterBroadcastMessage(void *buf, size_t len) { //buf裡面的內容為clusterMsg+clusterMsgData
dictIterator *di;
dictEntry *de;

// 遍歷所有已知節點
di = dictGetSafeIterator(server.cluster->nodes);
while((de = dictNext(di)) != NULL) {
clusterNode *node = dictGetVal(de);

// 不向未連線節點發送資訊
if (!node->link) continue;

// 不向節點自身或者 HANDSHAKE 狀態的節點發送資訊
if (node->flags & (REDIS_NODE_MYSELF|REDIS_NODE_HANDSHAKE))
continue;

// 傳送資訊
clusterSendMessage(node->link,buf,len);
}
dictReleaseIterator(di);