集群
ASK错误
ASKING命令
ASKING命令唯一要做的就是打开发送该命令的客户端的REDIS_ASKING标识,以下是该命令的伪代码实现:
def ASKING():
# 打开标识
client.flags |= REDIS_ASKING# 向客户端返回OK回复
reply("OK")
在一般情况下,如果客户端向节点发送一个关于槽i的命令,而槽i又没有指派给这个节点的话,那么节点将向客户端返回一个MOVED错误;但是,如果节点的clusterState.importing_slots_from[i]显示节点正在导入
槽i,并且发送命令的客户端带有REDIS_ASKING标识,那么节点将破例执行这个关于槽i的命令一次,过程如图所示。当客户端接收到ASK错误并转向至正在导入槽的节点时,客户端会先向节点发送一个ASKING命令,
然后才重新发送想要执行的命令,这是因为如果客户端不发送ASKING命令,而直接发送想要执行的命令的话,那么客户端发送的命令将被节点拒绝执行,并返回MOVED错误。
例子
- 举个例子,我们可以使用普通模式的redis-cli客户端,向正在导入槽16198的节点7003发送以下命令:
./redis-cli -p 7003
127.0.0.11:7003> GET "love"
(error) MOVED 16198 127.0.0.1:7002
虽然节点7003正在导入槽16198,但槽16198目前仍然是指派给了节点7002,所以节点7003会向客户端返回MOVED错误,指引客户端转向节点7002.但是,如果我们在发送GET命令之前,先向节点发送一个
ASKING命令,那么这个GET命令就会被节点7003执行:
127.0.0.1:7003> ASKING
OK
127.0.0.1:7003> GET "love"
"you get the key 'love'"
另外要注意的是,客户端的REDIS_ASKING标识是一个一次性标识,当节点执行了一个带有REDIS_ASKING标识的客户端发送的命令之后,客户端的REDIS_ASKING标识就会被移除。
- 举个例子。如果我们在成功执行GET命令之后,再次向节点7003发送GET命令,那么第二次发送的GET命令将执行失败,因为这时客户端的REDIS_ASKING标识已经被移除:
127.0.0.1:7003> ASKING # 打开REDIS_ASKING标识
OK
127.0.0.1:7003> GET "love" # 移除REDIS_ASKING标识
"you get the key 'love'"
127.0.0.1:7003> GET 'love' # REDIS_ASKING 标识未打开,执行失败
(error) MOVED 16198 127.0.0.1:7002
ASK错误和MOVED错误的区别
ASK错误和MOVED错误都会导致客户端转向,它们的区别在于:
- 1.MOVED错误代表槽的负责全已经从一个节点转移到了另一个节点:在客户端收到关于槽i的MOVED错误之后,客户端每次遇到关于槽i的命令请求时,都可以直接将命令请求发送至MOVED错误所指向的节点,因为该节点就是目前负责槽i的节点
- 2.与此相反,ASK错误只是两个节点在迁移槽的过程中使用的一种临时措施:在客户端收到关于槽i的ASK错误之后,客户端只会在接下来的一次命令请求中将关于槽i的命令请求产生任何影响,客户端仍然会将关于槽i的命令请求发送至目前负责处理槽i的节点,除非ASK错误再次出现
复制与故障转移
Redis集群中的节点分为主节点(master)和从节点(slave),其中主节点用于处理槽,而从节点则用于复制某个主节点,并在被复制的主节点下线时,代替下线主节点继续处理命令请求
例子
- 举个例子。对于包含7000、7001、7002、7003四个主节点的集群来说,我们可以将7004、7005两个节点添加到集群里面,并将这两个节点设定为节点7000的从节点,如图所示(双圆形代表主节点,单圆形表示从节点),如表所示记录了集群各个节点的当前装填,以及它们正在做的工作。
如果这时,节点7000进入下线状态,那么集群中仍在正常运作的几个主节点将在节点7000的两个从节点——节点7004和节点7005中选出一个节点作为新的主节点,这个新的主节点将接管原来节点7000负责处理的槽,并继续处理客户端发送的命令请求。
例如,如果节点7004被选中为新的主节点,那么节点7004将接管原来由节点7000负责处理的槽0至槽5000,节点7005也会从原来的复制节点7000改为复制节点7004,如图所示
另一张表记录了在对节点7000进行故障转移之后,集群各个节点的当前状态,以及它们正在做的工作.如果在故障转移完成之后,下线的节点7000重新上线,那么它将成为节点7004的从节点,如图所示