| | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.stream.Collectors; |
| | | |
| | | /** |
| | | * redis配置 |
| | |
| | | RedissonProperties.ClusterServersConfig clusterServersConfig = redissonProperties.getClusterServersConfig(); |
| | | if (ObjectUtil.isNotNull(clusterServersConfig)) { |
| | | // 使用集群模式 |
| | | String finalPrefix = prefix; |
| | | List<String> nodes = redisProperties.getCluster().getNodes() |
| | | .stream() |
| | | .map(node -> finalPrefix + node) |
| | | .collect(Collectors.toList()); |
| | | |
| | | config.useClusterServers() |
| | | .setConnectTimeout(((Long) redisProperties.getTimeout().toMillis()).intValue()) |
| | | .setPassword(StringUtils.isNotBlank(redisProperties.getPassword()) ? redisProperties.getPassword() : null) |
| | |
| | | .setScanInterval(clusterServersConfig.getScanInterval()) |
| | | .setReadMode(clusterServersConfig.getReadMode()) |
| | | .setSubscriptionMode(clusterServersConfig.getSubscriptionMode()) |
| | | .setNodeAddresses(redisProperties.getCluster().getNodes()); |
| | | .setNodeAddresses(nodes); |
| | | } |
| | | RedissonClient redissonClient = Redisson.create(config); |
| | | log.info("初始化 redis 配置"); |