spring:
 redis:
   cluster:
     nodes:
     - ${redis.host.cluster} #redis集群ip-port
   password: ${redis.password}
   timeout: 5000 #連接超時(shí)時(shí)間
   lettuce:
     pool:
       max-active: 10 #連接池最大連接數(shù)
       max-wait: -1 #連接池最大阻塞時(shí)間
       max-idle: 5 #連接池中最大空閑連接
       min-idle: 1 #連接池中最小空閑連接
redis:
 cluster:
   enabled: true

@Data
@Component
@ConditionalOnProperty(name = "redis.cluster.enabled", havingValue = "true", matchIfMissing = false)
public class RedisConfig {
    @Autowired
    RedisProperties redisProperties;
    // 在構(gòu)建LettuceConnectionFactory時(shí)，如果不使用內(nèi)置的destroyMethod，可能會(huì)導(dǎo)致Redis連接早于其它Bean被銷毀
    @Bean(destroyMethod = "destroy")
    public RedisConnectionFactory newLettuceConnectionFactory() {
        // 配置用于開啟自適應(yīng)刷新和定時(shí)刷新。如自適應(yīng)刷新不開啟，Redis集群變更時(shí)將會(huì)導(dǎo)致連接異常
        ClusterTopologyRefreshOptions clusterTopologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
                .enablePeriodicRefresh(Duration.ofSeconds(60))// 開啟周期刷新(默認(rèn)60秒)
                .enableAdaptiveRefreshTriggers(RefreshTrigger.ASK_REDIRECT,RefreshTrigger.UNKNOWN_NODE)// 開啟自適應(yīng)刷新
                .build();
        ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder()
                                 .topologyRefreshOptions(clusterTopologyRefreshOptions)//拓?fù)渌⑿?
                                 .disconnectedBehavior(ClientOptions.DisconnectedBehavior.REJECT_COMMANDS)
                                 .autoReconnect(true)
                                 .socketOptions(SocketOptions.builder().keepAlive(true).build())
　　　　　　　　　　　　　　　　       .validateClusterNodeMembership(false)// 取消校驗(yàn)集群節(jié)點(diǎn)的成員關(guān)系
                                 .build();
        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                .clientOptions(clusterClientOptions)
                                .readFrom(ReadFrom.SLAVE_PREFERRED)
                                .build();
        return new LettuceConnectionFactory(getClusterConfiguration(), clientConfig);
    }
    
    private  RedisClusterConfiguration getClusterConfiguration() {
        RedisProperties.Cluster clusterProperties = redisProperties.getCluster();
        RedisClusterConfiguration config = new RedisClusterConfiguration(clusterProperties.getNodes());
        if (clusterProperties.getMaxRedirects() != null) {
            config.setMaxRedirects(clusterProperties.getMaxRedirects());
        }
        if (redisProperties.getPassword() != null) {
            config.setPassword(RedisPassword.of(redisProperties.getPassword()));
        }
        return config;
    }
}