带生菜的Redis Spring数据：com.lambdaworks.redis.Redis命令执行异常：移动错误

Question

我在集群模式下使用AWS ElastiCache（Redis）。我有两个实现来连接ElastiCache。其中一种实现是直接使用本机莴苣驱动程序，另一种是使用Spring数据，并将莴苣作为底层驱动程序。AWS ElastiCache具有群集配置endpoint。我想用这个endpoint连接到ElastiCache。我能够使用带有本机驱动程序实现的群集endpoint成功连接到ElastiCache，但在使用带有群集endpoint的spring数据时，会出现以下错误

Spring数据：1.8.9-RELEASE（无法使用更高版本的Spring）

莴苣：4.5.0决赛

@Bean
public LettuceConnectionFactory redisConnectionFactory() {
    LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory();
    lettuceConnectionFactory.setHostName(<cluster_endpoint>);
    lettuceConnectionFactory.setPort();
    lettuceConnectionFactory.setUseSsl(Boolean.valueOf(useSsl));
    //lettuceConnectionFactory.setPassword(password);
    return lettuceConnectionFactory;
}

错误：

Caused by: org.springframework.data.redis.RedisSystemException: Error in execution; nested exception is com.lambdaworks.redis.RedisCommandExecutionException: MOVED 12894 cache---.usw2.cache.amazonaws.com:6379
at org.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:50)
at org.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:48)
at org.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:41)

它在以下两种情况下工作正常-
1）我使用集群节点endpoint，并通过RedisClusterConfiguration注入LettuceConnectionFactory。
2）如果我使用Lettuce作为直接实现（不是通过Spring数据）使用StatefulRedisClusterConnection。

上述两个错误的原因是什么？我更喜欢通过使用集群配置endpoint将莴苣与Spring数据结合使用。

Answer 1

下面是使用Spring数据连接到Elasticache Redis群集的解决方案-

使用ElastiCache群集配置endpoint：

@Bean
public RedisClusterConfiguration redisClusterConfiguration() {
  RedisClusterConfiguration clusterConfiguration = new 
  RedisClusterConfiguration();
  clusterConfiguration.clusterNode("host", port);
  new LettuceConnectionFactory(clusterConfiguration);
}

使用ElastiCache节点endpoint：

@Bean
public RedisClusterConfiguration redisClusterConfiguration() {
    RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration()
            .clusterNode("redis-cluster----0001-001.redis-cluster---.usw2.cache.amazonaws.com",6379)
            .clusterNode("redis-cluster----0001-002.redis-cluster---.usw2.cache.amazonaws.com",6379)
            .clusterNode("redis-cluster----0001-003.redis-cluster---.usw2.cache.amazonaws.com",6379)
            .clusterNode("redis-cluster----0001-004.redis-cluster---.usw2.cache.amazonaws.com",6379);
    return clusterConfiguration;
}

感谢Mark Paluch，他在Spring数据论坛上回复了我的问题。以下是细节-https://jira.spring.io/browse/DATAREDIS-898