Spring Boot中Lettuce连接Redis重复创建及复用方案咨询

问题根源 #

1. 重复创建连接工厂：你的redisConnectionFactory()方法未添加@Bean注解，导致每次初始化RedisTemplate时都会新建一个LettuceConnectionFactory实例，每个实例维护独立的连接池，完全无法实现连接复用。
2. 强制连接验证：setValidateConnection(true)会让Lettuce在每次获取连接前发送PING命令验证连接可用性，这就是你监控到的频繁PING请求，既增加额外开销，也违背了连接池的复用逻辑。

修正后的配置代码 #

@Bean
public LettuceConnectionFactory redisConnectionFactory() throws FileNotFoundException {
    final SocketOptions socketOptions = SocketOptions.builder()
            .connectTimeout(Duration.ofMillis(connectionTimeout)).keepAlive(true).build();
    final SslOptions sslOptions = sslEnabled ? SslOptions.builder().jdkSslProvider()
            .trustManager(ResourceUtils.getFile(truststorePath)).build() : null;
    final ClientOptions clientOptions = sslEnabled
            ? ClientOptions.builder().sslOptions(sslOptions).socketOptions(socketOptions).build()
            : ClientOptions.builder().socketOptions(socketOptions).build();

    // 显式配置连接池，Lettuce默认使用连接池，显式配置更可控
    LettucePoolingClientConfiguration clientConfig = LettucePoolingClientConfiguration.builder()
            .commandTimeout(Duration.ofMillis(timeout))
            .clientOptions(clientOptions)
            .useSsl()
            // 可选：根据业务场景调整连接池参数
            .poolConfig(new GenericObjectPoolConfig<>() {{
                setMaxTotal(20); // 最大连接数
                setMaxIdle(10);  // 最大空闲连接
                setMinIdle(5);   // 最小空闲连接
                setTestWhileIdle(true); // 空闲时验证连接有效性，替代每次获取时的PING
            }})
            .build();

    RedisStandaloneConfiguration serverConfig = new RedisStandaloneConfiguration(hostname, port);
    serverConfig.setPassword(accessKey);

    final LettuceConnectionFactory lettuceConnectionFactory =
            new LettuceConnectionFactory(serverConfig, clientConfig);
    // 关闭每次获取连接时的强制PING验证
    lettuceConnectionFactory.setValidateConnection(false);
    lettuceConnectionFactory.setEagerInitialization(true);
    lettuceConnectionFactory.afterPropertiesSet();
    return lettuceConnectionFactory;
}

@Bean
public RedisTemplate<String, Long> redisTemplate() throws FileNotFoundException {
    RedisTemplate<String, Long> redisTemplate = new RedisTemplate<>();
    // 复用Spring管理的单例连接工厂
    redisTemplate.setConnectionFactory(redisConnectionFactory());
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(new GenericToStringSerializer<>(Long.class));
    return redisTemplate;
}

关键调整说明 #

• 添加@Bean注解：让Spring将LettuceConnectionFactory管理为单例，确保所有RedisTemplate复用同一个连接池。
• 关闭validateConnection：取消每次获取连接的PING验证，改为通过连接池的testWhileIdle参数在后台定期验证空闲连接，既保证连接有效性又避免频繁PING开销。
• 显式配置连接池：通过LettucePoolingClientConfiguration自定义连接池参数，根据业务并发需求优化连接复用效率。

内容的提问来源于stack exchange，提问作者saket agarwal