如何解决Redis缓存雪崩问题？

缓存雪崩指的是大量缓存同时失效导致的数据库压力激增，可能导致数据库崩溃和系统瘫痪。以下是几种解决方案： ### 1. 缓存失效时间分散 避免所有缓存同时失效是解决缓存雪崩的最简单有效的方法之一。通过设置不同的缓存过期时间，使得缓存失效时间分散开。 **实现方法**： - **随机过期时间**：在设定缓存时，给每个缓存键设置一个随机的过期时间。 ```java import redis.clients.jedis.Jedis; import java.util.Random; public class CacheUtil { private static final Jedis jedis = new Jedis("localhost", 6379); private static final Random random = new Random(); public static void setCache(String key, String value, int baseExpireTime) { int randomExpireTime = baseExpireTime + random.nextInt(600); // 在基础时间上增加随机秒数 jedis.setex(key, randomExpireTime, value); } public static void main(String[] args) { setCache("key1", "value1", 3600); // 基础过期时间为 3600 秒 } } ``` ### 2. 加锁或队列 在缓存失效时，通过加锁或队列来控制对数据库的访问，避免大量并发请求直接打到数据库。 **实现方法**： - **加锁**：当缓存失效时，只有一个线程能获取锁并访问数据库，其他线程等待锁释放后从缓存获取数据。 ```java import redis.clients.jedis.Jedis; import redis.clients.jedis.params.SetParams; public class CacheWithLock { private static final Jedis jedis = new Jedis("localhost", 6379); public static String getCacheWithLock(String key) { String value = jedis.get(key); if (value == null) { // 尝试加锁 String lockKey = key + "_lock"; String lockValue = String.valueOf(System.currentTimeMillis() + 5000); SetParams setParams = new SetParams().nx().px(5000); if (jedis.set(lockKey, lockValue, setParams) != null) { // 获取到锁，从数据库中获取数据并更新缓存 value = queryDatabase(key); jedis.setex(key, 3600, value); // 释放锁 jedis.del(lockKey); } else { // 未获取到锁，等待并重试 try { Thread.sleep(100); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } return getCacheWithLock(key); // 递归重试 } } return value; } private static String queryDatabase(String key) { // 模拟数据库查询 return "database_value_for_" + key; } public static void main(String[] args) { System.out.println(getCacheWithLock("key1")); } } ``` ### 3. 双重缓存机制 使用双重缓存机制，即在一个缓存失效之前，提前加载新的缓存，这样即使一个缓存失效了，还有备用缓存可以使用。 **实现方法**： - **定时刷新缓存**：在缓存即将过期之前，主动刷新缓存。 ```java import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; import redis.clients.jedis.Jedis; public class DoubleCache { private static final Jedis jedis = new Jedis("localhost", 6379); private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); public static void main(String[] args) { // 定时刷新缓存 scheduler.scheduleAtFixedRate(DoubleCache::refreshCache, 0, 30, TimeUnit.MINUTES); } public static void refreshCache() { // 获取需要刷新的key列表 String[] keys = {"key1", "key2", "key3"}; for (String key : keys) { String value = queryDatabase(key); jedis.setex(key, 3600, value); // 更新缓存，设置过期时间为 3600 秒 } } private static String queryDatabase(String key) { // 模拟数据库查询 return "database_value_for_" + key; } } ``` ### 4. 限流保护 在缓存失效期间，对请求进行限流，保护数据库不被压垮。 **实现方法**： - **限流器**：使用限流器控制请求的速率，例如使用令牌桶算法。 ```java import com.google.common.util.concurrent.RateLimiter; public class CacheWithRateLimiter { private static final Jedis jedis = new Jedis("localhost", 6379); private static final RateLimiter rateLimiter = RateLimiter.create(100); // 每秒最多处理100个请求 public static String getCache(String key) { if (rateLimiter.tryAcquire()) { String value = jedis.get(key); if (value == null) { value = queryDatabase(key); jedis.setex(key, 3600, value); } return value; } else { // 限流保护 return "System is busy, please try again later."; } } private static String queryDatabase(String key) { // 模拟数据库查询 return "database_value_for_" + key; } public static void main(String[] args) { System.out.println(getCache("key1")); } } ``` ### 总结 解决 Redis 缓存雪崩问题的方法包括： 1. **分散缓存失效时间**：设置随机过期时间，避免缓存同时失效。 2. **加锁或队列**：控制对数据库的访问，避免并发请求打到数据库。 3. **双重缓存机制**：在缓存失效之前提前刷新缓存，保持备用缓存。 4. **限流保护**：在缓存失效期间，对请求进行限流，保护数据库不被压垮。 这些方法可以单独使用，也可以结合使用，以提高系统的稳定性和可靠性。

缓存雪崩主要指的是短时间内大量key失效，导致所有请求全部转向数据库，导致数据库压力过大。 解决方案： 1.在给缓存设置失效时间时加一个随机值，避免集体失效。 2.双缓存机制，缓存A的失效时间为20分钟，缓存B的失效时间会比A长一些，从缓存A读取数据，缓存A中没有时，去缓存B中读取数据，并且启动一个异步线程来更新缓存A(如果已经有异步线程正在更新了，就不用重复更新了)。以及更新缓存B，以便延迟B的过期时间。