Spring Boot 3中Lettuce Redis连接DNS缓存TTL设置及故障解决

最优方案 #

针对AWS ElastiCache更新后IP切换、DNS缓存过期引发的连接超时问题，最优方案是结合被动触发（连接失败时即时刷新DNS）与主动定期刷新，既保证异常场景下快速恢复，又避免频繁DNS查询损耗性能。该方案基于Lettuce 6.2.x（Spring Boot 3默认传递依赖）的原生API实现，无需额外依赖。

可编译实现代码 #

1. 配置Lettuce客户端，开启DNS自动刷新 #

import io.lettuce.core.ClientOptions;
import io.lettuce.core.resource.DefaultDnsResolver;
import io.lettuce.core.resource.DnsRefreshOptions;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import java.time.Duration;

@Configuration
public class RedisConfig {

    @Bean
    public LettuceConnectionFactory lettuceConnectionFactory() {
        // 配置主动DNS刷新间隔：默认30分钟，可根据业务调整
        DnsRefreshOptions dnsRefreshOptions = DnsRefreshOptions.builder()
                .refreshPeriod(Duration.ofMinutes(30))
                .build();

        // 启用DNS刷新机制，绑定默认DNS解析器
        ClientOptions clientOptions = ClientOptions.builder()
                .dnsRefreshOptions(dnsRefreshOptions)
                .dnsResolver(DefaultDnsResolver.INSTANCE)
                .build();

        // 构建Lettuce客户端配置
        LettuceClientConfiguration clientConfig = LettuceClientConfiguration.builder()
                .clientOptions(clientOptions)
                .build();

        // 替换为你的Redis连接配置（可从application.yml读取参数）
        return new LettuceConnectionFactory(clientConfig);
    }
}

2. 监听连接失败事件，触发即时DNS刷新 #

import io.lettuce.core.event.connection.ConnectionFailedEvent;
import io.lettuce.core.resource.DefaultClientResources;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class RedisConnectionEventListener {

    private final DefaultClientResources clientResources;

    public RedisConnectionEventListener(DefaultClientResources clientResources) {
        this.clientResources = clientResources;
    }

    @EventListener
    public void onConnectionFailed(ConnectionFailedEvent event) {
        // 连接失败时强制刷新DNS缓存，立即获取ElastiCache新IP
        clientResources.dnsResolver().refresh();
    }
}

关键说明 #

• 版本适配：Lettuce 6.2.x中，ClientOptions.builder()直接支持dnsRefreshOptions()和dnsResolver()方法，解决旧版本API不存在导致的编译失败问题
• 性能平衡：主动刷新间隔设为30分钟（可按需调整），仅在连接失败时触发即时刷新，避免无意义的DNS查询
• ElastiCache适配：AWS ElastiCache更新IP后，Lettuce会自动通过DNS刷新获取新地址，无需重启应用
• 韧性增强：配合Lettuce默认的连接重试机制，确保应用在IP切换后快速恢复Redis连接

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