1

我正在尝试使用 redis-sentinel 为我的 redis 实例设置 HA。我假设我的 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;
    }

用于创建 RedisSentinelConfiguration 的 IP 和端口号是我已经启动的哨兵实例。我已经为每个主人设立了一个哨兵。我有 3 个大师在运行，3 个哨兵也在运行。只要映射到哨兵“mymaster”的主节点正在运行，该应用程序似乎运行良好。一旦我关闭了那个 redis 节点，应用程序就无法获得连接。我看到连接被拒绝错误。在调试时，我可以看到它正在尝试使用它在第一次尝试中使用的单个 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

谢谢

4

1 回答 1

1

There's a gap between failover and the actual implementation to pick up the newly elected master node. 尽管 Sentinel 本身可能被配置为立即故障转移，但 java 驱动程序的实现可能会有点落后。您需要处理这些情况。

运行sentinel 示例，您可以通过随机关闭 Redis 和/或 Sentinel 实例轻松探索行为，同时观察命令行打印错误以及实际恢复需要多长时间。

您还可以使用spring-retry重新安排写入 redis 的尝试。有一张票 ( DATAREDIS-370 ) 可供集成RetryTemplate- 所以你可能想投票给它。

于 2015-06-23T06:03:44.183 回答