如何为AWS ElastiCache的Lettuce客户端配置重试机制？

Lettuce本身支持通过配置实现重试机制，也可以手动在方法内定制重试逻辑，以下是两种可行方案：

一、全局重试配置（推荐） #

你可以在创建RedisCacheClient时，通过ClientOptions配置全局重试策略，让所有命令自动执行重试，无需修改现有业务方法：

// 构建重试策略：最多重试1次（初始尝试+1次重试，共2次执行）
RetryPolicy retryPolicy = RetryPolicy.builder()
        .maxAttempts(2)
        .build();

// 配置客户端选项，包含重试规则
ClientOptions clientOptions = ClientOptions.builder()
        .socketOptions(SocketOptions.builder().connectTimeout(Duration.ofSeconds(5)).build())
        .retryOptions(RetryOptions.builder()
                .retryPolicy(retryPolicy)
                .build())
        .build();

// 将配置应用到RedisCacheClient
RedisCacheClient redisCacheClient = RedisCacheClient.create(/* 你的连接配置 */);
redisCacheClient.setOptions(clientOptions);

这种方式全局生效，所有通过该客户端发起的Redis命令，在遇到可重试异常时都会自动重试1次。

二、方法内手动实现重试（精细化控制） #

如果只需要针对读取操作定制重试逻辑，也可以直接在getJson方法内添加重试循环：

public Object getJson(String key) {
    log.info("Reading from cache for key: {}", key);
    final int maxAttempts = 2;
    int attemptCount = 0;

    while (attemptCount < maxAttempts) {
        RedisAsyncCommands<String, String> async = null;
        try {
            async = redisCacheClient.connect().async();
            return async.jsonGet(key, JsonPath.ROOT_PATH).get();
        } catch (Exception e) {
            attemptCount++;
            log.error("Attempt {} failed reading cache: {}", attemptCount, e.getLocalizedMessage());
            
            if (attemptCount >= maxAttempts) {
                log.error("All {} attempts failed", maxAttempts);
                return null;
            }
            
            // 可选：重试前短暂休眠，避免频繁重试
            try {
                Thread.sleep(100);
            } catch (InterruptedException ie) {
                Thread.currentThread().interrupt();
                return null;
            }
        } finally {
            if (async != null) {
                async.quit();
            }
        }
    }
    return null;
}

注意事项 #

• 全局重试会覆盖所有命令（包括写入），需确认业务场景是否允许写入操作重试（可能导致重复数据）。
• 针对AWS ElastiCache，建议搭配合理的连接超时、读取超时配置，避免无意义的等待。
• 手动重试方式更灵活，可针对特定命令定制重试规则，比如仅读取失败时重试。

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