我如何使用绝地连接到用于Redis集群的AWS ElastiCache？

Question

之前，我们使用的Redis是通过AWS ElastiCache禁用集群模式的。

我们使用Jedis的Java代码指向主要的单节点endpoint，用于读写。

我们现在启用了群集模式。

现在，我们已经将代码更改为指向新Redis群集的配置endpoint，但它现在在接收请求时会抛出错误，请参见以下内容：

Redis不可用。继续使用队列请求消息。org.springframework.data.redis.群集重定向异常：重定向：槽2356到[ip地址]： 6379。；嵌套异常是redis.clients.jedis.exceptions.JedisMovedDataExc0019： MOVED 2356[ip地址]： 6379

我们的配置代码如下：

    @Bean(name = "redisTemplate")
    public RedisTemplate<String, String> getRedisTemplate(JedisConnectionFactory jedisConnectionFactory) {
        RedisTemplate template = new RedisTemplate();
        template.setConnectionFactory(jedisConnectionFactory);
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        return template;
    }

    @Bean
    JedisConnectionFactory jedisConnectionFactory(Configuration config) {
        JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory();
        jedisConnectionFactory.setHostName(config.get(HOST));
        jedisConnectionFactory.setPort(config.getInt(PORT));
        jedisConnectionFactory.setUsePool(true);
        jedisConnectionFactory.setPoolConfig(createJedisPoolConfig(config));
        jedisConnectionFactory.afterPropertiesSet();
        return jedisConnectionFactory;
    }

    JedisPoolConfig createJedisPoolConfig(Config config) {
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(config.getInt(MAX, 8));
        poolConfig.setMaxIdle(config.getInt(MAXIDLE, 8));
        poolConfig.setMinIdle(config.getInt(MINIDLE, 1));
        poolConfig.setTestOnBorrow(true);
        poolConfig.setTestOnReturn(true);
        return poolConfig;
    }

仅仅改变绝地武士以指向配置endpoint就足够了吗？

我需要更改代码中的任何内容吗？

Answer 1

仅仅改变绝地武士以指向配置endpoint就足够了吗？

不，因为Redis客户机——本例中的绝地武士——需要知道它正在连接到一个集群，而目前没有。

当Redis集群告诉客户端所请求的数据现在已经被“重定向”到另一个节点时，您会得到“移动”。然而，Jedis不知道正在使用集群，因此还有任何其他节点，因此甚至不能连接到它们来检索数据。

我需要更改代码中的任何内容吗？

要发现Redis节点，需要使用JedisCluster而不是JedisPool

请注意，您只需要引用配置endpoint：

Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();

jedisClusterNodes.add(new HostAndPort(CONFIGURATION_ENDPOINT, 6379));

try (JedisCluster jedisCluster = new JedisCluster(jedisClusterNodes)) {
// ...
}