以前,我们使用的是通过 AWS ElastiCache 禁用集群模式的 Redis。
我们使用 Jedis 的 Java 代码指向主要的单节点端点,该端点用于读取和写入。
我们现在启用了集群模式。
我们现在已经将代码更改为指向新 Redis 集群的配置端点,但是它现在在接收请求时会抛出错误,见下文:
Redis 不可用。继续使用 Queue requestMessage 代替。org.springframework.data.redis.ClusterRedirectException: Redirect: slot 2356 to [ipaddress]:6379.; 嵌套异常是 redis.clients.jedis.exceptions.JedisMovedDataException: MOVED 2356 [ipaddress]: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;
}
仅仅将 Jedis 更改为指向配置端点不就足够了吗?
我需要更改代码中的任何内容吗?