使用Spring Data Redis连接Redis集群失败求助

尝试用Spring Data Redis连接Redis集群，已按文档完成基础配置（包含Jedis、Lettuce连接工厂及RedisTemplate），并编写了测试用的RedisListCache服务类，但运行时抛出RedisCommandTimeoutException连接初始化超时错误。

配置代码 #

import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;

@Configuration
public class RedisConfig {
 
    @Bean
    public JedisConnectionFactory jedisConnectionFactory(){
        RedisStandaloneConfiguration config= new RedisStandaloneConfiguration("server",portno);
        config.setPassword("password");
        return new JedisConnectionFactory(config);
    }

    @Bean
    public LettuceConnectionFactory lettuceConnectionFactory() {
        RedisStandaloneConfiguration config= new RedisStandaloneConfiguration("server",portno);
        config.setPassword("password");
        return new LettuceConnectionFactory(config);
    }

    @Bean
    public RedisTemplate<String, Object> redisTemplate(){
        RedisTemplate<String,Object> redisTemplate=new RedisTemplate<>();
        redisTemplate.setConnectionFactory(jedisConnectionFactory());
        return redisTemplate;
    }
}

测试服务类代码 #

@Service
public class RedisListCache {
    private RedisTemplate<String, Object> redisTemplate;
    private ListOperations<String, Object> listOperations;

    public  RedisListCache(RedisTemplate<String, Object> redisTemplate){
        this.redisTemplate=redisTemplate;
        listOperations=redisTemplate.opsForList();
    }

    @PostConstruct
    public void setup(){
        listOperations.leftPush("keytest","Redistesting");
        System.out.println(listOperations.rightPop("keytest"));
    }
}

错误日志片段 #

Caused by: io.lettuce.core.RedisCommandTimeoutException: Connection initialization timed out. Command timed out after 1 minute(s)
    at io.lettuce.core.internal.ExceptionFactory.createTimeoutException(ExceptionFactory.java:71) ~[lettuce-core-6.1.9.RELEASE.jar:6.1.9.RELEASE]
    at io.lettuce.core.protocol.RedisHandshakeHandler.lambda$channelRegistered$0(RedisHandshakeHandler.java:62) ~[lettuce-core-6.1.9.RELEASE.jar:6.1.9.RELEASE]
    at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]
    at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:106) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]
    at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:66) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]
    at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:986) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]
    at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]
    at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.1.70.Final.jar:4.1.70.Final]

• 切换集群专用配置类：当前用的RedisStandaloneConfiguration是单机Redis的配置，连接集群必须用RedisClusterConfiguration，示例如下：

  @Bean
  public RedisConnectionFactory redisConnectionFactory() {
      RedisClusterConfiguration clusterConfig = new RedisClusterConfiguration(Arrays.asList(
          "node1-host:port", "node2-host:port", "node3-host:port"
      ));
      clusterConfig.setPassword(RedisPassword.of("your-password"));
      // 配置超时参数
      LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
          .commandTimeout(Duration.ofSeconds(15))
          .build();
      return new LettuceConnectionFactory(clusterConfig, clientConfig);
  }
  

• 排查网络连通性：用redis-cli直接连接集群节点，比如redis-cli -h node-host -p node-port -a password，验证是否能正常执行命令。如果连不上，检查防火墙/安全组是否开放Redis端口，Redis配置文件的bind是否限制了访问IP，protected-mode是否开启（外部访问需关闭或设置密码）。
• 清理冗余连接工厂：当前同时定义了Jedis和Lettuce两个连接工厂，会造成容器内实例冲突，只保留实际要用的即可（推荐Lettuce，Spring Boot默认支持，对集群和异步操作更友好）。
• 调整超时与连接池参数：默认1分钟超时仍失败，说明网络延迟高或集群响应慢，可以在连接配置中调大超时时间，同时配置连接池参数优化连接复用：

  LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
      .commandTimeout(Duration.ofSeconds(20))
      .poolConfig(new GenericObjectPoolConfig<>() {{
          setMaxTotal(20);
          setMaxIdle(10);
          setMinIdle(5);
      }})
      .build();
  

• 优化测试时机：@PostConstruct会在服务启动阶段执行Redis操作，此时容器未完全初始化，容易和连接初始化冲突。把测试逻辑移到Controller接口或单元测试中，避免启动阶段执行。
• 完善RedisTemplate序列化配置：虽然不是超时直接原因，但序列化配置不当会导致后续操作异常，建议添加：

  redisTemplate.setKeySerializer(new StringRedisSerializer());
  redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
  redisTemplate.afterPropertiesSet();
  

内容的提问来源于stack exchange，提问作者Chaithra Rai