调整RedissionConfig

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/config/RedissonConfig.java

@@ -19,8 +19,6 @@ import org.springframework.context.annotation.Configuration;
 @Configuration
 public class RedissonConfig {
 
-    @Value("${spring.redis.cluster-enabled}")
-    private Boolean clusterEnabled;
     //@Value("${spring.redis.host}")
     //private String host;
     //@Value("${spring.redis.port}")
@@ -48,18 +46,17 @@ public class RedissonConfig {
             //redis://ip:port
             //redis的部署方式有单节点部署、主从方式部署、哨兵方式部署、集群方式部署
 
-            if (clusterEnabled == null || !clusterEnabled) {
-                //单机模式
-                //config.useSingleServer().setAddress("redis://".concat(host).concat(StrConstant.COLON).concat(port));
-                //config.useSingleServer().setPassword(password);
-                //config.useSingleServer().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE);
-                //config.useSingleServer().setDatabase(NumConstant.TEN);
-            } else {
-                //集群模式
-                config.useClusterServers().addNodeAddress(getClusterNodes());
-                config.useClusterServers().setPassword(password);
-                config.useClusterServers().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE);
-            }
+            //单机模式
+            //config.useSingleServer().setAddress("redis://".concat(host).concat(StrConstant.COLON).concat(port));
+            //config.useSingleServer().setPassword(password);
+            //config.useSingleServer().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE);
+            //config.useSingleServer().setDatabase(NumConstant.TEN);
+
+            //集群模式
+            config.useClusterServers().addNodeAddress(getClusterNodes());
+            config.useClusterServers().setPassword(password);
+            config.useClusterServers().setConnectTimeout(NumConstant.ONE_THOUSAND * NumConstant.FIVE);
+
             return Redisson.create(config);
         } catch (Exception e) {
             log.error("初始化redisson失败", e);