Redis Cluster Gossip Protocol: FAIL, UPDATE

本文主要是介绍Redis Cluster Gossip Protocol: FAIL, UPDATE，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

返回目录

FAIL的发送

过程

1. 构建消息头
2. 把处于FAIL状态的node的ID填入消息的数据部分
3. 广播消息

遍历cluster节点字典:跳过还没有创建连接的node跳过myself和处于handshake的node给node发送FAIL消息

FAIL的接收处理

过程

第1 ~ 3步是涵盖所有类型的消息，详细请参考PING/PONG/MEET。

1. 合法性检查
2. 根据link和消息头，从cluster节点字典中查找实体sender
3. 通用处理
4. 处理FAIL消息

if sender存在:根据FAIL消息数据中的nodename，在cluster节点字典中查找nodeif node存在 && node != myself &&	/* 我们都收到消息了，不可能FAIL */node没有处于FAIL状态:  /* 没FAIL才需要更新状态 */把node更新成FAIL		/* 如果原本处于PFAIL，则先需要清除PFAIL */设置node的failTime为当前时间
else: /* sender不存在 */不清楚sender的身份，所以忽略此消息

---

UPDATE的发送

过程

1. 构建消息头
2. 把需要update的node的ID，configEpoch和slots填入消息的数据部分
3. 给node发送UPDATE消息

UPDATE的接收处理

过程

第1 ~ 3步是涵盖所有类型的消息，详细请参考PING/PONG/MEET。

1. 合法性检查
2. 根据link和消息头，从cluster节点字典中查找实体sender
3. 通用处理
4. 处理UPDATE消息

if sender不存在:		/* 不清楚sender的身份，丢弃消息 */return
根据消息数据中的hostname，在cluster节点字典中查找node
if node不存在:	/* 没有node的信息，不需要更新 */return
if node的configEpoch >= 消息数据中的configEpoch:	/* 消息是旧的，丢弃掉 */return
if node原本是slave:	/* UPDATE消息是用来更新slot的归属，所以只针对master节点 */把node转换成master	/* 参考PING/PONG/MEET的 Point-3 */
/* 更新node的configEpoch */
node的configEpoch = 消息数据中的configEpoch
重新绑定消息数据中的slots到node /* 参考PING/PONG/MEET的 Point-6 */

这篇关于Redis Cluster Gossip Protocol: FAIL, UPDATE的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---