1.1.7.RELEASE 支持lettuce 动态刷新功能

redis-starter/src/main/java/com/secoo/mall/redis/config/MatrixeRedisAutoConfiguration.java

 package com.secoo.mall.redis.config;
 
 import com.secoo.mall.redis.utils.MatrixRedisClusterUtils;
+import io.lettuce.core.ReadFrom;
+import io.lettuce.core.cluster.ClusterClientOptions;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.lettuce.LettucePoolingClientConfiguration;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.RedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.connection.RedisClusterConfiguration;
+import io.lettuce.core.cluster.ClusterTopologyRefreshOptions;
+import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
+
+import java.time.Duration;
 
 
 /**
@@ -18,6 +28,7 @@ import org.springframework.data.redis.serializer.StringRedisSerializer;
 @Configuration
 public class MatrixeRedisAutoConfiguration {
 
+
     @Bean
     public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory redisConnectionFactory)  {
         RedisSerializer stringSerializer = new StringRedisSerializer();
@@ -36,5 +47,32 @@ public class MatrixeRedisAutoConfiguration {
         return new MatrixRedisClusterUtils();
     }
 
+    @Bean(destroyMethod = "destroy")
+    public LettuceConnectionFactory redisConnectionFactory(RedisProperties redisProperties) {
+        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(redisProperties.getCluster().getNodes());
+        redisClusterConfiguration.setPassword(redisProperties.getPassword());
+        redisClusterConfiguration.setMaxRedirects(redisProperties.getCluster().getMaxRedirects());
+        // 支持自适应集群拓扑刷新和动态刷新源
+        ClusterTopologyRefreshOptions clusterTopologyRefreshOptions = ClusterTopologyRefreshOptions.builder()
+                .enableAllAdaptiveRefreshTriggers()
+                    // 开启自适应刷新
+                .enableAdaptiveRefreshTrigger()
+                    // 开启定时刷新
+                .enablePeriodicRefresh(Duration.ofSeconds(5))
+                .build();
+
+        ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder()
+                .topologyRefreshOptions(clusterTopologyRefreshOptions).build();
+
+        LettuceClientConfiguration lettuceClientConfiguration = LettucePoolingClientConfiguration.builder()
+                .readFrom(ReadFrom.SLAVE_PREFERRED)
+                .clientOptions(clusterClientOptions).build();
+
+        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(redisClusterConfiguration, lettuceClientConfiguration);
+        lettuceConnectionFactory.setShareNativeConnection(false);// 是否允许多个线程操作共用同一个缓存连接，默认 true，false 时每个操作都将开辟新的连接
+        lettuceConnectionFactory.resetConnection();// 重置底层共享连接, 在接下来的访问时初始化
+        return lettuceConnectionFactory;
+    }
+
 
-}
+    }