源码：https://github.com/go-redis/redis/tree/v8.11.4

数据结构

flowchart LR subgraph clusterClient n["nodes *clusterNodes"] s["state *clusterState"] end subgraph sCNs["clusterNodes"] n2["nodes map[string]*clusterNode"] end subgraph sCS["clusterState"] s2["slots []*clusterSlot"] gg["generation uint32"] end subgraph sCSt["clusterSlot"] se["start, end int"] n3["nodes []*clusterNode"] end subgraph sCN["clusterNode"] c["Client *Client"] g["generation uint32"] end n --> sCNs s --> sCS s2 --> sCSt n2 --> sCN n3 --> sCN gg -.- g

• clusterClient：集群客户端抽象
• clusterNodes：维护集群内「实例地址=>节点」的映射
• clusterState：维护集群内「哈希槽=>节点」的映射，创建后不可修改，只能通过新建替换更新，每次新建 generation 自增。
• clusterSlot：一个范围的哈希槽以及负责这些槽的节点（第一个为主节点，其余为从节点），start为起始哈希槽编号，end为起结束希槽编号，nodes为负责这些槽的节点。
• clusterNode：集群节点抽象。client为连接此节点的客户端，generation与clusterState的generation关联。

算法

flowchart TD A[执行命令] --> B{"clusterClient.state<br/>是否存在?"}; B -->|不存在| C["使用 CLUSTER SLOTS 命令 获取「哈希槽=>实例地址」的映射信息"]; C --> D["根据「哈希槽=>实例地址」的映射信息创建clusterState， 设置最新的 clusterState.generation， 根据实例地址，请求clusterClient.nodes创建或获取clusterNode; 设置clusterNode.generation为clusterState.generation, clusterSlot.nodes引用这些clusterNode"] D --> E["根据命令key计算slot编号，根据slot编号 定位 clusterSlot = clusterClient.state.slots[*]"] E --> F["使用clusterSlot.nodes[0].Client执行命令"] D -."异步".-> G["运行一次性定时器，一段时间后检查clusterSlot.nodes， 如果其中包含clusterNode.generation小于该 clusterState.generation，移除这些clusterNode， 关闭clusterNode.Client释放资源"] B -->|存在| H[" "] --> E H -."如果clusterState创建时间 过旧，异步执行".-> S F --"如果返回MOVED重定向"--> I["根据重定向提供的实例地址， 请求clusterClient.nodes创建或获取clusterNode， 使用clusterNode.Client执行命令"] I -.->|异步执行| S subgraph S["Create/Update state"] C D G end