Elasticache集群部分Key未存储问题求助

1. 统一Key的序列化规则 #

检查Java客户端（Jedis/Lettuce）的Key序列化配置，确保所有读写缓存的操作使用完全一致的序列化器。比如用Spring的RedisTemplate时，必须全局统一keySerializer和hashKeySerializer为StringRedisSerializer，避免出现"逻辑相同但字节编码不同"的Key（比如用JDK序列化存对象Key，用字符串读取就会匹配失败）。

示例配置（Spring）：

@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
    RedisTemplate<String, Object> template = new RedisTemplate<>();
    template.setConnectionFactory(factory);
    StringRedisSerializer stringSerializer = new StringRedisSerializer();
    template.setKeySerializer(stringSerializer);
    template.setHashKeySerializer(stringSerializer);
    // Value序列化可根据业务选择，但Key必须统一
    template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    return template;
}

2. 排查Key冲突与命名空间 #

给不同业务模块的缓存Key添加唯一前缀（比如order-service:user-profile:123），避免不同逻辑复用相同Key导致覆盖或误删。同时检查是否有代码路径在更新DDB后未同步更新/删除缓存，或者存在定时任务批量删除缓存的逻辑，误删了部分有效Key。

3. 补全缓存写入的逻辑覆盖 #

梳理所有读取DDB的代码分支：

• 确保所有读取请求都先走缓存查询，未命中时再查DDB，必须同步写入缓存（包括异常场景，比如DDB查询成功但缓存写入失败要记录日志）。
• 检查是否有特殊分支（比如批量查询、异常降级逻辑）跳过了缓存写入步骤，比如某些批量接口直接查DDB而未更新缓存。

4. 检查Elasticache集群状态与客户端配置 #

• 查看Elasticache控制台的监控指标：重点看CacheMisses/CacheHits的分布是否集中在某些节点，RejectedConnections是否有非零值，KeyspaceHits/KeyspaceMisses是否与业务日志匹配。
• 确认客户端集群配置正确：比如Lettuce客户端是否开启了集群自动发现，Jedis是否配置了所有集群节点地址，避免Key路由到不可用节点导致写入失败。

5. 验证Key的合法性 #

提取无法存入缓存的Key，检查：

• 是否包含不可见字符（如换行、制表符）或特殊编码字符，导致客户端与集群的Key解析不一致。
• Key长度是否超出合理范围（虽然Redis支持512MB的Key，但过长可能引发客户端或集群的处理异常）。
• 打印Key的哈希值和字符串内容，与能正常存储的Key做对比，找出差异。

6. 完善缓存操作的异常日志 #

在缓存写入、读取的代码块中添加详细异常日志，捕获所有可能的异常（网络超时、连接拒绝、序列化失败等），比如：

String key = "user:profile:" + userId;
UserProfile profile;
try {
    profile = redisTemplate.opsForValue().get(key);
} catch (Exception e) {
    log.warn("Cache read failed for key: {}", key, e);
    profile = null; // 降级到查DDB
}

if (profile == null) {
    profile = ddbClient.loadUserProfile(userId);
    try {
        redisTemplate.opsForValue().set(key, profile, 2, TimeUnit.DAYS);
    } catch (Exception e) {
        log.error("Cache write failed for key: {}", key, e);
        // 这里可以考虑告警，避免缓存写入失败长期未发现
    }
}

7. 排查缓存穿透场景 #

如果部分未命中的Key对应的DDB记录本身不存在，会导致缓存永远无法命中。这种情况可以：

• 缓存空值（设置较短TTL，比如5分钟），避免重复查询DDB。
• 引入布隆过滤器，提前拦截不存在的Key请求。

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