Redis怎么避免热点数据问题

使用 RedisTemplate 避免热点数据问题的解决方案、场景及示例：

1. 数据分片（Sharding）

场景：高频读写的计数器（如文章阅读量统计）
​原理​：将数据分散到多个子键，降低单个 Key 的压力。
​代码示例​：

// 写入分片数据
public void incrementShardedCounter(String entityId, int shardCount, long delta) {
    String baseKey = "counter:" + entityId;
    int shardIndex = Math.abs(entityId.hashCode()) % shardCount;
    String shardKey = baseKey + ":shard:" + shardIndex;
    redisTemplate.opsForValue().increment(shardKey, delta);
}

// 读取总分片数据（需遍历所有分片）
public long getTotalCounter(String entityId, int shardCount) {
    String baseKey = "counter:" + entityId;
    long total = 0;
    for (int i = 0; i < shardCount; i++) {
        String shardKey = baseKey + ":shard:" + i;
        total += redisTemplate.opsForValue().get(shardKey) != null ? 
                 (long) redisTemplate.opsForValue().get(shardKey) : 0;
    }
    return total;
}

2. 本地缓存 + 异步更新

场景：低频更新的热点数据（如商品详情页配置）
​原理​：应用层缓存热点数据，异步同步到 Redis。
​代码示例​：

// 使用 Caffeine 本地缓存
@Component
public class HotDataCache {
    private final Cache<String, String> cache = Caffeine.newBuilder()
            .expireAfterWrite(10, TimeUnit.SECONDS)
            .maximumSize(1000)
            .build();

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    // 读取数据（优先本地缓存）
    public String getData(String key) {
        return cache.get(key, k -> redisTemplate.opsForValue().get(k));
    }

    // 异步刷新数据
    @Scheduled(fixedRate = 5000)
    public void refreshData() {
        String hotKey = "product:detail:1001";
        String value = redisTemplate.opsForValue().get(hotKey);
        cache.put(hotKey, value); // 更新本地缓存
    }
}

3. Lua 脚本原子操作

场景：高并发库存扣减（如秒杀场景）
​原理​：通过 Lua 脚本在 Redis 服务端原子执行操作，减少网络开销。
​代码示例​：

// 定义 Lua 脚本
private static final String SECKILL_SCRIPT = 
    "local stock = tonumber(redis.call('GET', KEYS[1]) or 0)\n" +
    "if stock >= tonumber(ARGV[1]) then\n" +
    "    redis.call('DECRBY', KEYS[1], ARGV[1])\n" +
    "    return 1\n" +
    "else\n" +
    "    return 0\n" +
    "end";

// 执行扣减
public boolean seckill(String itemId, int quantity) {
    DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>(SECKILL_SCRIPT, Long.class);
    String key = "seckill:stock:" + itemId;
    Long result = redisTemplate.execute(redisScript, Collections.singletonList(key), String.valueOf(quantity));
    return result == 1;
}

4. Redis Cluster 自动分片

场景：海量数据和高可用需求（如实时排行榜）
​原理​：利用 Redis 集群自动分片数据，分散压力。
​代码示例​（需配置 RedisClusterConfiguration）：

@Configuration
public class RedisClusterConfig {
    @Bean
    public RedisTemplate<String, Object> redisClusterTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(factory);
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        return template;
    }
}

// 使用方式（与单机操作一致）
redisTemplate.opsForValue().increment("leaderboard:score:" + userId, 10);

总结

根据业务场景选择合适的方案，可有效避免 Redis 热点数据问题。