浅谈Redis缓存雪崩解决方案
缓存层承载着大量的要求,有效保护了存储层。但是如果由于大量缓存失效或缓存整体不能提供服务,致使大量的要求到达存储层,会使存储层负载增加(大量的要求查询数据库) 。这就是缓存雪崩的场景;
解决缓存雪崩可以从下面的几点着手：
1.保持缓存层的高可用
使用Redis哨兵模式或Redis集群部署方式,即是个别Redis节点下线,全部缓存层仍然可使用。除此以外还可以在多个机房部署Redis,这样即使是机房死机,仍然可以实现缓存层的高可用。
2.限流降级组件
不管是缓存层或者存储层都会有出错的几率,可以将它们视为资源。作为并发量较大的散布式系统，假设有一个资源不可用，可能会造成所有线程在获得这个资源时异常，造成全部系统不可用。降级在高并发系统中是非常正常的，比如推荐服务中，如果个性化推荐服务不可用，可以降级补充热门数据，不至于造成全部推荐服务不可用。常见的限流降级组件如 Hystrix、Sentinel 等。
3.缓存不过期
Redis 中保存的 key 永不失效，这样就不会出现大量缓存同时失效的问题，但是随之而来的就是Redis 需要更多的存储空间。
4.优化缓存过期时间
设计缓存时，为每个 key 选择适合的过期时间，避免大量的 key 在同一时刻同时失效，造成缓存雪崩。
5.使用互斥锁重建缓存
在高并发场景下，为了不大量的要求同时到达存储层查询数据、重建缓存，可使用互斥锁控制，如根据 key 去缓存层查询数据，当缓存层为命中时，对 key 加锁，然后从存储层查询数据，将数据写入缓存层，最后释放锁。若其他线程发现获得锁失败，则让线程休眠一段时间后重试。对锁的类型，如果是在单机环境下可使用 Java 并发包下的 Lock，如果是在散布式环境下，可使用散布式锁（Redis 中的 SETNX 方法）。
散布式环境下互斥锁重建缓存伪代码
* 互斥锁建立缓存
*
**/
public String get(String key) {
// redis中查询key对应的value
String value = redis.get(key);
// 缓存未命中
if (value == null) {
// 互斥锁
String key_mutex_lock = “mutex:lock” + key;
// 互斥锁加锁成功
if(redis.setnx(key_mutex_lock,”1″)) { // 返回 0（false）,1（true）
try {
// 设置互斥锁超时时间,这里设置的是锁的失效时间,而不是key的失效时间
redis.expire(key_mutex_lock,3*60);
// 从数据库查询
value = db.get(key);
// 数据写入缓存
redis.set(key,value);
} finally {
// 释放锁
boolean keyExist = jedis.exists(key_mutex_lock);
if(keyExist){
redis.delete(key_mutex_lock);
}
} else {
// 加锁失败,线程休息50ms后重试
Thread.sleep(50);
return get(key); // 直接返回缓存结果
}
}
}
散布式环境下使用Redis 散布式锁实现缓存重建，优点是设计思路简单，对数据一致性有保障;缺点是代码复杂度增加，有可能会造成用户等待。假定在高并发下，缓存重建期间 key 是锁着的，如果当前并发 1000 个要求，其中 999 个都在阻塞，会致使 999 个用户要求阻塞而等待。
6.异步重建缓存
在这类方案下构建缓存采取异步策略，会从线程池中获得线程来异步构建缓存，从而不会让所有的要求直接到达存储层，该方案中每一个Redis key 保护逻辑超时时间，当逻辑超时时间小于当前时间时，则说明当前缓存已失效，应当进行缓存更新，否则说明当前缓存未失效，直接返回缓存中的 value 值。如在Redis 中将 key 的过期时间设置为 60 min，在对应的 value 中设置逻辑过期时间为 30 min。这样当 key 到了 30 min 的逻辑过期时间，就能够异步更新这个 key 的缓存，但是在更新缓存的这段时间内，旧的缓存仍然可用。这类异步重建缓存的方式可以有效避免大量的 key 同时失效。
* 异步重建缓存: ValueObject为对应的封装的实体模型
*
**/
public String get(String key) {
// 重缓存中查询key对应的ValueObject对象
ValueObject valueObject = redis.get(key);
// 获得存储中对应的value值
String value = valueObject.getValue();
// 获得实体模型中的缓存过期的时间：timeOut = 设置缓存时确当前时间+过期时间(如30秒,60秒等等)
long logicTimeOut = valueObject.getTimeOut(); // 等位换算为long类型
// 当前可以在逻辑上失效
if (logicTimeOut <= System.currentTimeMillis()) {
// 异步更新缓存
threadPool.execute(new Runnable() {
String key_mutex_lock = “mutex_lock” + key;
// 互斥锁加锁成功
if(redis.setnx(key_mutex_lock,”1″)) { // 返回 0（false）,1（true）
try {
// 设置互斥锁超时时间,这里设置的是锁的失效时间,而不是key的失效时间
redis.expire(key_mutex_lock,3*60);
// 从数据库查询
dbValue = db.get(key);
// 数据写入缓存
redis.set(key,dbValue);
} finally {
// 释放锁
boolean keyExist = jedis.exists(key_mutex_lock);
if(keyExist){
redis.delete(key_mutex_lock);
}
}
} else {
}
});
return value; // 直接返回缓存结果
}
}
到此这篇关于浅谈Redis缓存雪崩解决方案的文章就介绍到这了,更多相关Redis缓存雪崩内容请搜索之前的文章或继续浏览下面的相关文章希望大家以后多多支持！
文章来源：丸子建站
文章标题：浅谈Redis缓存雪崩解决方案
https://www.wanzijz.com/view/67447.html
