import redis import time import math import threading import typing from redis import Redis class _WatchThread(threading.Thread): def __init__(self, target, args=(), kwargs={}): super(_WatchThread, self).__init__() self.func = target self.args = args self.kwargs = kwargs self.result = None def run(self): # …

Redis Cluster 背景 并发量 <10万dps 数据量 单机内存<256G 带宽 网卡限制 解决方式 提高机器配置 分布式 数据分布 | 分布方式 | 特点 | 典型产品 | | ——– | —————– | ——– | | 哈希分布 | 数据分散度高数据分布业务无关无法顺序访问支持批量操作 | 一致性哈希MemcacheRedis Cluster缓存产品 | | 顺序分布 | 数据分散度易倾斜键值业务相关可顺序访问支持批量操作 | BigTableHBase | 哈希 …

集群伸缩 伸缩原理 伸：增加节点 缩：节点下线 集群伸缩：槽和数据在节点之间的移动 扩容集群 准备新节点 打开集群模式 配置和其他节点统一 启动后是孤立的节点 加入集群meet 在集群节点中配置：cluster meet 127.1 <newnodeport> 使用redis-trib.rb： redis-trib.rb ad-node new_host:new_port existing_host:existing_port --slave --master_id <arg>{扩展参数是配置为从节点} 为它迁移槽和数据可以实现扩容 可以作为从节点负责故障转移 迁移槽和数据 1). 对目标节点发 …

RedisCluster 客户端使用 moved重定向 对任意节点发送键命令 节点会计算槽和对应节点确定这个键是否指向自身 如果指向自身，就执行命令，返回key所在的槽 否则就回复moved异常，客户端拿到这个moved后，重定向节点，重新发送命令 ASK重定向 解决槽迁移时客户端的查询问题 对源节点发送键命令 节点发现正在进行槽迁移，回复客户端ask转向 客户端对目标节点Asking，发送命令 目标节点返回响应结果 两者的区别 两者都是客户端重定向 moved：槽已经确定迁移 ask：槽还在迁移中 smart客户端 目标：追求性能（不能使用代理模式） 从集群中选取一个可运行节点，使用cluster slots 初始化槽和节点映射 …