Я пытаюсь настроить высокую доступность для своих экземпляров Redis, используя redis-sentinel. Я предполагаю, что мое Java-приложение должно использовать RedisSentinelConfiguration для создания фабрики соединений. Следовательно, я настроил фабрику соединений, как показано ниже.
@Bean(name = "redisConnectionFactory")
public JedisConnectionFactory redisConnectionFactory() {
String redisHost = redisSystemProperties.getProperty("redis.host");
int redisPort = redisSystemProperties.getIntegerProperty("redis.port", DEFAULT_REDIS_PORT);
logger.info(format("Creating redis connection factory. host: %s, port: %d", redisHost, redisPort));
JedisConnectionFactory connectionFactory = new JedisConnectionFactory(redisSentinelConfig(), jedisPoolConfig());
boolean usePool = Boolean.valueOf(redisSystemProperties.getProperty("pool.enabled", "true"));
connectionFactory.setUsePool(usePool);
connectionFactory.afterPropertiesSet();
return connectionFactory;
}
@Bean(name ="redisSentinelConfig")
public RedisSentinelConfiguration redisSentinelConfig(){
RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration();
for (int i = 0; i < MAX_REDIS_MASTER_NODES; i++) {
String hostPropertyName = format("redis.%d.host", i);
String host = redisSystemProperties().getProperty(hostPropertyName);
String portPropertyName = format("redis.%d.port", i);
String portStr = redisSystemProperties().getProperty(portPropertyName);
if (StrUtils.anyBlank(host, portStr)) {
break;
}
int port = toInt(portStr);
Assert.isTrue(port > 0, format("Invalid value '%s' for property '%s'", portStr, portPropertyName));
RedisNode redisNode = new RedisNode(host, port);
logger.info(format("Adding connection to redis sentinel [%d]: host: '%s', port: %d", i, host, port));
sentinelConfig.addSentinel(redisNode);
sentinelConfig.setMaster("mymaster");
}
return sentinelConfig;
}
IP-адрес и номера портов, которые используются для создания RedisSentinelConfiguration, относятся к экземплярам Sentinel, которые я запустил. Я запустил часового для каждого мастера. У меня работает 3 мастера, а также 3 стража. Приложение, похоже, работает отлично, пока работает главный узел, сопоставленный с дозорным «mymaster». Как только я ЗАКРЫВАЮ этот узел перераспределения, приложение не может установить соединение. Я вижу ошибку отказа в соединении. Во время отладки я вижу, что он пытается создать соединение, используя единственную конфигурацию Sentinel, которую он использовал в первой попытке.
Вот так выглядит моя конфигурация дозорного.
port 26379
sentinel monitor mymaster 127.0.0.1 7000 2
sentinel down-after-milliseconds mymaster 1
sentinel failover-timeout mymaster 1
sentinel config-epoch mymaster 0
# Generated by CONFIG REWRITE
dir "/Users/skandula/redis-3.0.2"
sentinel leader-epoch mymaster 0
sentinel known-sentinel mymaster 127.0.0.1 26380 e4bc16a7435eec64512acc03404beb9799dea73e
sentinel known-sentinel mymaster 127.0.0.1 26381 493d598ce30dd4429bdc53c94cf297b8a0436c67
sentinel current-epoch 0
Может кто-нибудь дать мне знать, что я могу делать неправильно? Я использую spring-data-redis 1.5.0.RELEASE и Jedis-2.7.0.
Спасибо