更改lettuce补丁

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

@@ -4,7 +4,9 @@ import com.secoo.mall.redis.utils.MatrixRedisClusterUtils;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisClusterConfiguration;
 import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.RedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
@@ -36,5 +38,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(10))
+                .build();
+
+        ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder()
+                .topologyRefreshOptions(clusterTopologyRefreshOptions).build();
+
+        LettuceClientConfiguration lettuceClientConfiguration = LettucePoolingClientConfiguration.builder()
+                .readFrom(ReadFrom.REPLICA_PREFERRED )
+                .clientOptions(clusterClientOptions).build();
+
+        LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(redisClusterConfiguration, lettuceClientConfiguration);
+        lettuceConnectionFactory.setShareNativeConnection(false);// 是否允许多个线程操作共用同一个缓存连接，默认 true，false 时每个操作都将开辟新的连接
+        lettuceConnectionFactory.resetConnection();// 重置底层共享连接, 在接下来的访问时初始化
+        return lettuceConnectionFactory;
+    }
+
 
 }