cluster 管理命令及实现
cluster管理
cluster reset
cluster reset [hard|soft]
cluster reset 分为soft reset和hard reset,不指定的情况下为soft
执行reset后:
- 所有节点会被forget
- 所有已指派过的slot会被释放清空
- node会变更为master
- nodes.conf 文件会被更新并且cluster state被修改
- 如果node是slave,数据会被flush
- (hard) 生成新的nodeid
- (hard) epoch 被重置为0
cluster bumpepoch
cluster bumpepoch
这是一个redis的隐藏命令。bumpepoch检查执行命令的节点当前的epoch,并与集群的最大epoch比较,如果当前
节点的epoch为0,或者小于集群的maxEpoch,则将集群的epoch加1,并且节点的configEpoch设置为等于currentEpoch。
cluster info
cluster info
获取当前节点的集群信息,
包括集群状态 slot分配状态 epoch。
node管理
cluster meet
cluster meet ip port
cluster meet 进行节点间的握手,握手成功后,新节点加入到集群。
if (!strcasecmp(c->argv[1]->ptr, "meet") && c->argc == 4)
{
// 校验ip port正确后开始进行握手
if (clusterStartHandshake(c->argv[2]->ptr, port) == 0 &&errno == EINVAL)
}
int clusterStartHandshake(char *ip, int port)
{
// ... ip port 合法性校验
{
// ip 不合法,返回EINVAL
errno = EINVAL;
return 0;
}
// 已经处于握手中,返回错误 EAGAIN
if (clusterHandshakeInProgress(norm_ip, port))
{
errno = EAGAIN;
return 0;
}
// 创建cluster node对象
n = createClusterNode(NULL, CLUSTER_NODE_HANDSHAKE | CLUSTER_NODE_MEET);
memcpy(n->ip, norm_ip, sizeof(n->ip));
n->port = port;
// 将新的node加入到集群。
// 此时,cluster state的node列表该节点还是处于handshake状态,只有后续心跳同步到其他节点后才会更新节点状态
clusterAddNode(n);
}
clusterAddNode只是把node加入到cluster->nodes的map中
并且flags被设置为handshake|meet。clusterCron任务会向该新节点发起tcp连接,并通过心跳gossip发送meet状态指令,
发送玩meet后,meet flags会被清空。meet flag被清空后,下一次心跳降发送ping指令,当收到pong响应后,如果该节点还处于
handshake,则handshake flags将被清空,节点成功加入cluster。
cluster nodes
nodes 返回集群所有的节点信息,通过clusterGenNodeDescription生成node 信息的描述
包括 nodeid ip:port slots 信息
slot管理
cluster flushslots
清空该节点所有已分配的slots,删除node的slot信息。
cluster addslots|delslots
cluster addslots [slot] ...
cluster delslots [slot] ...
添加删除slot只是简单地更新node的slot标记位,唯一需要注意的是,如果添加的slot处于importing状态
因为该node已经拥有了这个slot,因此需要清空这个slot的importing状态。
cluster setslot
SETSLOT 10 MIGRATING <node ID>
SETSLOT 10 IMPORTING <node ID>
SETSLOT 10 STABLE
SETSLOT 10 NODE <node ID>
cluster setslot 用于在集群节点间的dlot迁移。setslot命令只能在master节点上执行。
migrating将当前节点的slot迁移到nodeid,
if (!strcasecmp(c->argv[3]->ptr, "migrating") && c->argc == 5)
{
// 必须在当前节点执行
if (server.cluster->slots[slot] != myself)
{
addReplyErrorFormat(c, "I'm not the owner of hash slot %u", slot);
return;
}
// nodeid 必须是已知的节点
if ((n = clusterLookupNode(c->argv[4]->ptr)) == NULL)
{
addReplyErrorFormat(c, "I don't know about node %s",
(char *)c->argv[4]->ptr);
return;
}
// 添加migrating节点到migrating slots当中
server.cluster->migrating_slots_to[slot] = n;
}
- importing将slot从目标节点nodeid导入到当前节点,相应的该slot不应该属于当前节点。
- stable回滚slot的迁移状态,清除migrating和importing的标识。
- node将slot指派给nodeid所在节点,完成指派之前,需要判断当前slot是否还有key,如果还有,则无法完成slot的指派。
如果当前节点的slot之前处于importing状态,则需要更新epoch,以便slot的更新信息更新为最新的version同步到整个集群。
网友评论