1. 引言
Redis通过主从复制实现高可用性,通过集群模式实现数据分片和分布式扩展。本篇将深入剖析主从复制(replication.c
)和Redis Cluster(cluster.c
)的源码实现,揭示其同步机制、故障转移和分片逻辑。
2. 主从复制
2.1 主从同步概述
- 作用:从节点复制主节点数据,提供读扩展和容错。
- 方式:
- 全量同步(Full Resync):初次同步或数据差异过大。
- 增量同步(Partial Resync):通过复制偏移量同步增量命令。
2.2 全量同步(syncCommand()
)
代码片段(replication.c
):
void syncCommand(client *c) {if (server.masterhost == NULL) { // 主节点处理if (c->flags & CLIENT_SLAVE) return;c->flags |= CLIENT_SLAVE;listAddNodeTail(server.slaves, c);replicationSendNewline(c);replicationSendRdb(c); // 发送RDB文件}
}
硬核解析:
CLIENT_SLAVE
:标记从节点客户端。replicationSendRdb()
:主节点生成RDB快照并发送。
2.3 增量同步(PSYNC)
代码片段(replication.c
):
void replicationPSync(client *c, char *replid, long long offset) {if (memcmp(replid, server.replid, CONFIG_RUN_ID_SIZE) == 0 &&offset >= server.repl_backlog_first_byte_offset) {replicationSendContinuation(c, offset); // 增量同步} else {replicationSendFullResync(c); // 全量同步}
}
硬核解析:
replid
:复制ID,标识主节点实例。repl_backlog
:环形缓冲区,保存近期写命令。- 条件:ID匹配且偏移量在backlog内则增量同步,否则全量。
Mermaid同步流程: