Redis中缓存预热与缓存穿透解决方案

public class RedisCachePreheating {

    /**
     * 缓存预热：基于数据量预热
     */
    public void preheatByDataSize(){
        // 读取所有数据
        List<Data> dataList = readAllData();
        for(Data data : dataList){
            // 将数据写入缓存
            writeToCache(data);
        }
    }
  
    /**
     * 缓存预热：基于时间预热
     */
    public void preheatByTime(){
        // 获取最近7天的数据列表
        List<Data> dataList = readDataByTime(7);
        for(Data data : dataList){
            // 将数据写入缓存
            writeToCache(data);
        }
    }

    /**
     * 缓存预热：周期性预热
     */
    public void periodPreheat(){
        // 每隔1小时预热一次
        Timer timer = new Timer();
        timer.schedule(new TimerTask() {
            @Override
            public void run() {
                // 预热操作，类似于preheatByDataSize()或preheatByTime()
            }
        }, 0, 60 * 60 * 1000);
    }
}

// 创建布隆过滤器并将其添加到 Redis 中
Jedis jedis = new Jedis("localhost", 6379);
RedisBloomFilter<Integer> bloomFilter = RedisBloomFilter.create(jedis, "bloom", 1000, 0.01);
bloomFilter.add(42);
// 检查元素是否存在于集合中
bloomFilter.contains(42); // 返回 true
bloomFilter.contains(666); // 返回 false

// 查询缓存。
Object result = redisTemplate.opsForValue().get(key);
if(result == null) {
    // 查询数据库。
    result = dao.query(key);
    // 将查询结果添加到缓存，有效期设置为 5 分钟。
    redisTemplate.opsForValue().set(key, result, Duration.ofMinutes(5));
}

// 获取当前时间戳。
long now = Instant.now().getEpochSecond();
// 在 Redis 中记录这 1 秒钟内的请求次数。
long current = redisTemplate.opsForValue().increment(key, 1);
// 设置有效期为 1 秒钟。
redisTemplate.expire(key, 1, TimeUnit.SECONDS);
if(current > maxRequests) {
    // 请求次数超限，返回失败。
    return new Response(false, "too many requests");
} else {
    // 请求次数未超限。
    // 如果是第一个请求，设置过期时间为 1 秒钟。
    redisTemplate.opsForValue().setIfAbsent(key, "", Duration.ofSeconds(1));
    return new Response(true, "");
}

@Service
public class UserService {
    @Autowired
    private UserDao userDao;

    @Autowired
    private RedisTemplate<String, User> redisTemplate;

    @Cacheable(value = "user", key = "#id")
    public User get(int id) {
        // 直接从数据库中获取用户。
        return userDao.get(id);
    }
}