当前位置：首页 > news >正文

通过问题了解redis集群通信原理

news 2026/5/12 17:42:45

环境

配置

spring:data:#redis配置redis:password: ****lettuce:pool:max-idle: 200min-idle: 50max-active: 5000max-wait: 1000timeout: 2000cluster: # 此处新增nodes: 101.4.3.191:7000,101.4.3.191:7001,101.4.3.190:7000,101.4.3.190:7001,101.4.3.189:7000,101.4.3.189:7001     # 集群地址max-redirects: 6 #最大重定向次数

异常场景

使用redis template 写入再读取没有数据

写入

   redisTemplate.opsForZSet().add(AgenticBusRedisConstants.AGENTIC_BUS_LONG_POLLING_KEY, taskNo, nextPollingTime);

读取数量返回0

        Long size = redisTemplate.opsForZSet().size(AgenticBusRedisConstants.AGENTIC_BUS_LONG_POLLING_KEY);

问题排查

使用客户端工具访问集群的key

排除是写入失败的问题

是否是key序列化问题

怀疑是不是底层改变了key，调试到最底层，写入和读取key是一致的

了解集群通信原理

选择机制代码配置参考

@Configuration
public class RedissonConfig {@Value("${spring.data.redis.cluster.nodes}")private List<String> nodes;@Value("${spring.data.redis.password}")private String password;@Beanpublic RedissonClient clusterRedisClient() {Config config = new Config();ClusterServersConfig clusterServersConfig = config.useClusterServers();if (!StringUtils.isBlank(password)) {clusterServersConfig.setPassword(password);}// 集群状态扫描间隔时间，单位是毫秒clusterServersConfig.setScanInterval(2000);// 关键配置：启用集群槽位全覆盖检查，确保正确处理 MOVED/ASK 重定向clusterServersConfig.setCheckSlotsCoverage(true);// 设置读取模式：MASTER - 只从主节点读取，确保数据一致性
        clusterServersConfig.setReadMode(org.redisson.config.ReadMode.MASTER);// 设置订阅模式：MASTER
        clusterServersConfig.setSubscriptionMode(org.redisson.config.SubscriptionMode.MASTER);for (String node : nodes) {String url = "redis://" + node;clusterServersConfig.addNodeAddress(url);}RedissonClient redissonClient = Redisson.create(config);return redissonClient;}}

View Code

MOVED/ASK 重定向原理

查看当前集群状态

执行命令

CLUSTER NODES

可以让AI生成可视化表格

问题排查

1、通过打断点发现路由的服务为

[addr=redis://101.4.3.189:7000] 无数据查询没有数据，未从节点

2、我将ReadModel改为主节点则可以正常查询到数据

/*** @Description redisson相关配置* @Date 2023/9/26 10:44* @Author liqiang*/
@Configuration
public class RedissonConfig {@Value("${spring.data.redis.cluster.nodes}")private List<String> nodes;@Value("${spring.data.redis.password}")private String password;@Beanpublic RedissonClient clusterRedisClient() {Config config = new Config();ClusterServersConfig clusterServersConfig = config.useClusterServers();if (!StringUtils.isBlank(password)) {clusterServersConfig.setPassword(password);}// 集群状态扫描间隔时间，单位是毫秒clusterServersConfig.setScanInterval(2000);// 关键配置：启用集群槽位全覆盖检查，确保正确处理 MOVED/ASK 重定向clusterServersConfig.setCheckSlotsCoverage(true);// 设置读取模式：MASTER - 只从主节点读取，确保数据一致性
        clusterServersConfig.setReadMode(org.redisson.config.ReadMode.MASTER);// 设置订阅模式：MASTER
        clusterServersConfig.setSubscriptionMode(org.redisson.config.SubscriptionMode.MASTER);for (String node : nodes) {String url = "redis://" + node;clusterServersConfig.addNodeAddress(url);}RedissonClient redissonClient = Redisson.create(config);return redissonClient;}}

3、101.4.3.189:7000为从节点，是不是没有复制到数据连上这台机执行

INFO replication

反馈给运维处理，回复

其他命令

计算一个key的槽位

测试环境(101.4.3.191:7001)>CLUSTER KEYSLOT agentic-bus:task:long_polling:
"11299"

查看槽位分配

101.4.3.189(101.4.3.189:7000)>CLUSTER SLOTS
1) 1) "10923"2) "16383"3) 1) "101.4.3.191"2) "7001"3) "ebb6538d73bd3324cbde380ce6dc5afb83bad7c4"4) 1) "101.4.3.189"2) "7000"3) "4019bbab983d360c15b7f68d8afdae8a27cf6861"2) 1) "0"2) "5460"3) 1) "101.4.3.191"2) "7000"3) "7b74ab40f4a2c0bdc615ad95ee593785d0a805a0"4) 1) "101.4.3.190"2) "7001"3) "ea8b427b4b0b5b21fe721b7ef9b62488e488f596"3) 1) "5461"2) "10922"3) 1) "101.4.3.190"2) "7000"3) "ac7020869fab5a1c4e6f2789d1945a7c31ad0246"4) 1) "101.4.3.189"2) "7001"3) "8f9349d8fb48b809fbd065d7e9013acf59b2abe3"

查看全文

http://www.jsqmd.com/news/408350/