Spring-data-redis создает кластер для RedisCacheManager - PullRequest
Новая
       9

Spring-data-redis создает кластер для RedisCacheManager

0 голосов
/ 28 февраля 2019

Привет! Я пытаюсь создать rediscluster для RedisCacheManager, но свойства кластера не работают.Информация об ошибке, такая как: Причина: org.springframework.data.redis.RedisConnectionFailureException: Не удалось получить ресурс из пула;вложенное исключение - redis.clients.jedis.exceptions.JedisConnectionException: не удалось получить ресурс из пула

Пример: RedisClusterConfig.class 

@Configuration
public class RedisClusterConfig {
    @Bean
    RedisClusterConfiguration redisClusterConfiguration(){
        List<String> nodes = new ArrayList<>();
        nodes.add("192.168.145.141:7001");nodes.add("192.168.145.141:7002");nodes.add("192.168.145.141:7003");
        nodes.add("192.168.145.141:7004");nodes.add("192.168.145.141:7005");nodes.add("192.168.145.141:7006");
        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(nodes);
        return redisClusterConfiguration;
    }
    @Bean("redisConnectionFactory")
    JedisConnectionFactory redisConnectionFactory(){
        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration());
        return jedisConnectionFactory;
    }
    @Bean("redisCacheManager")
    public RedisCacheManager redisCacheManager() {
        return RedisCacheManager.create(redisConnectionFactory());
    }
}

DemoApplication.class 

@SpringBootApplication
public class DemoApplication {
   public static void main(String[] args) {
      SpringApplication.run(DemoApplication.class, args);
   }
   @Bean
   public CommandLineRunner commandLineRunner(ApplicationContext ctx) {
      return args -> {
         System.out.println("Let's inspect the beans provided by Spring Boot:");
         String[] beanNames = ctx.getBeanDefinitionNames();
         Arrays.sort(beanNames);
         for (String beanName : beanNames) {
            System.out.println(beanName);
         }
         RedisConnectionFactory redisConnectionFactory = (RedisConnectionFactory)ctx.getBean("redisConnectionFactory");
         RedisCacheManager redisCacheManager = (RedisCacheManager)ctx.getBean("redisCacheManager");
         Cache cache = redisCacheManager.getCache("abc");
         if(cache != null){
            cache.put("13",13);
            String a = cache.get("13").toString();
            System.out.println("a is " + a);
         }else {
            System.out.println("can not find cache");
         }
      };
   }
}

Я отлаживаю код, нахожу это так:

Информация об отладке: введите описание изображения здесь

Я не знаю, почему кластерные узлы расшатывают узлы кэша.POM файл, как это:

...