Redis集群节点通信与Gossip协议

Redis集群使用Gossip协议实现节点间的信息交换，通过周期性心跳保持集群状态一致性。

Gossip协议原理

核心思想

• 去中心化：所有节点对等，无中心协调者
• 最终一致性：信息逐步传播，最终达到一致
• 随机传播：随机选择节点交换信息
• 周期性同步：定时发送心跳消息

协议特点

优点：
- 扩展性强，节点增加不影响通信效率
- 容错性好，单节点故障不影响整体
- 实现简单，无复杂协调逻辑

缺点：
- 信息传播有延迟
- 存在冗余通信
- 最终一致性，非强一致

消息类型

PING/PONG消息

PING：节点探测消息
PONG：响应PING，携带节点状态信息
发送频率：每秒随机选择几个节点发送

MEET消息

# 将节点加入集群
CLUSTER MEET <ip> <port>

# MEET消息触发握手
节点A → MEET → 节点B
节点B → PONG → 节点A
节点A → PING → 节点B

FAIL消息

当节点A判定节点B下线(PFAIL)后
若多数主节点确认B下线
节点A广播FAIL消息
其他节点标记B为FAIL状态

PUBLISH消息

# 发布消息时广播到集群
PUBLISH channel message

# 消息通过Gossip传播到所有节点

心跳机制

心跳参数

# 节点超时时间（毫秒）
cluster-node-timeout 5000

# 心跳间隔 = cluster-node-timeout / 10
# 默认每500ms发送一次心跳

# 配置示例
cluster-node-timeout 15000  # 15秒超时
# 心跳间隔 = 15000 / 10 = 1500ms

PING策略

1. 每秒随机选择5个节点发送PING
2. 确保最近未通信的节点优先
3. 超过一半cluster-node-timeout未收到PONG则PING
4. 发现新节点立即发送MEET

消息内容

Gossip消息头包含：
- 发送节点ID
- 发送节点槽位信息
- 发送节点状态
- 集群状态版本(epoch)
- 已知节点信息摘要

节点发现流程

新节点加入

步骤1: 启动新节点
redis-server redis.conf --port 7006

步骤2: 发送MEET命令
CLUSTER MEET 192.168.1.100 7006

步骤3: 握手过程
[现有节点] → MEET → [新节点]
[新节点] → PONG → [现有节点]
[现有节点] → PING → [新节点]

步骤4: Gossip传播
信息通过心跳传播到所有节点

节点信息同步

# 查看集群节点
CLUSTER NODES

# 输出示例
node_id ip:port@bus_port flags master_id ping_sent pong_recv config_epoch link_state

故障检测流程

PFAIL状态

节点A在cluster-node-timeout内未收到节点B的响应
→ 节点A标记节点B为PFAIL(疑似下线)

FAIL状态

1. 节点A标记B为PFAIL
2. 通过Gossip询问其他节点
3. 若多数主节点确认B下线
4. 节点A标记B为FAIL
5. 广播FAIL消息到集群

检测流程图

正常 → 无响应(cluster-node-timeout) → PFAIL
                                          ↓
                               多数节点确认(PFAIL)
                                          ↓
                                     → FAIL → 广播

集群总线

端口规则

客户端端口：6379(默认)
集群总线端口：客户端端口 + 10000 = 16379

总线作用

- 节点间二进制通信
- 传输Gossip消息
- 故障检测信息
- 配置更新同步
- 数据迁移协调

防火墙配置

# 开放客户端端口
firewall-cmd --add-port=6379/tcp

# 开放集群总线端口
firewall-cmd --add-port=16379/tcp

配置参数

关键参数

# 节点超时（影响故障检测速度）
cluster-node-timeout 5000

# 从节点有效因子
cluster-replica-validity-factor 10

# 主节点最小从节点数
cluster-migration-barrier 1

# 集群配置文件
cluster-config-file nodes-6379.conf

# 集群公告IP（跨网段时必需）
cluster-announce-ip 192.168.1.100
cluster-announce-port 6379
cluster-announce-bus-port 16379

超时参数影响

cluster-node-timeout越小，故障检测越快，但网络开销越大。

要点总结

• Gossip协议通过随机节点间心跳实现信息传播
• 心跳间隔 = cluster-node-timeout / 10
• 节点状态：正常 → PFAIL → FAIL，需要多数确认
• 集群总线端口 = 客户端端口 + 10000
• cluster-node-timeout影响故障检测灵敏度，需根据网络环境调整
• 跨网段部署需配置cluster-announce-ip