spring:
  data:
    #redis配置
    redis:
      password: ****
      lettuce:
        pool:
          max-idle: 200
          min-idle: 50
          max-active: 5000
          max-wait: 1000
      timeout: 2000
      cluster: # 此处新增
        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 #最大重定向次数

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

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

@Configuration
public class RedissonConfig {

    @Value("${spring.data.redis.cluster.nodes}")
    private List<String> nodes;

    @Value("${spring.data.redis.password}")
    private String password;


    @Bean
    public 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

CLUSTER NODES

/**
 * @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;


    @Bean
    public 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;
    }


}

INFO replication

测试环境(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"