Redis

关注公众号 jb51net

关闭
首页 > 数据库 > Redis > Redis缓存穿透、缓存击穿与缓存雪崩

Redis缓存穿透、缓存击穿与缓存雪崩实战指南

作者:河阿里

本文介绍Redis在高并发分布式系统中的应用及可能引发的问题,包括缓存穿透、缓存击穿和缓存雪崩,针对这些问题,提出了布隆过滤器、分布式锁、随机过期时间、高可用集群、本地缓存和预热策略等多种解决方案,通过合理配置和组合使用这些方案,可以有效提升系统的稳定性和性能

在现代高并发的分布式系统架构中,Redis凭借其高性能的内存读写能力,已成为企业级应用不可或缺的缓存中间件。然而,缓存的引入虽然极大地提升了系统响应速度,降低了数据库负载,但也带来了一系列复杂的边缘风险。

一、缓存穿透(Cache Penetration)

1. 定义与问题
缓存穿透是指查询一个数据库根本不存在的数据。由于缓存中无对应key,请求直接穿透缓存层访问数据库。若大量此类请求存在(如恶意攻击或业务误操作),数据库将承受巨大压力,甚至崩溃。

2. 核心原因

3. 解决方案
(1)缓存空值

public Object getData(String key) {
    Object value = redis.get(key);
    if (value == null) { // 缓存未命中
        value = db.queryData(key); // 查询数据库
        if (value == null) { // 数据不存在
            redis.set(key, "NULL", 60); // 缓存空值,过期时间1分钟
        } else {
            redis.set(key, value, 3600); // 缓存有效数据,过期时间1小时
        }
    }
    return value;
}

(2)布隆过滤器(Bloom Filter)[推荐]

BloomFilter<String> filter = BloomFilter.create(Funnels.stringFunnel(), 1000000, 0.01); // 容量100万,误判率1%
// 初始化:将数据库所有key预加载到布隆过滤器
filter.putAll(db.getAllKeys());
public Object getData(String key) {
    if (!filter.mightContain(key)) { // 布隆过滤器判断不存在
        return null; // 直接返回,不访问数据库
    }
    Object value = redis.get(key);
    if (value == null) {
        value = db.queryData(key);
        redis.set(key, value, 3600);
    }
    return value;
}

二、缓存击穿(Cache Breakdown)

1. 定义与问题
缓存击穿又称热点Key问题,指一个访问极其频繁的热点key突然失效,大量并发请求同时穿透缓存,直接冲击数据库。例如,电商平台秒杀商品的缓存过期瞬间,大量用户抢购导致数据库崩溃。

2. 核心原因

3. 解决方案
(1)互斥锁(分布式锁)[推荐]

public Object getData(String key) {
    Object value = redis.get(key);
    if (value == null) { // 缓存未命中
        if (redis.setNX(key + "_lock", "1", 10)) { // 获取锁,过期时间10秒
            try {
                value = db.queryData(key); // 查询数据库
                redis.set(key, value, 3600); // 重建缓存
            } finally {
                redis.del(key + "_lock"); // 释放锁
            }
        } else { // 未获取锁,等待重试
            Thread.sleep(50);
            return getData(key); // 递归调用
        }
    }
    return value;
}

(2)逻辑过期(不设置物理过期)

public class CacheData {
    private Object data;
    private long expireTime; // 逻辑过期时间戳
}
public Object getData(String key) {
    CacheData data = redis.get(key);
    if (data == null) {
        data = db.queryData(key);
        redis.set(key, data, 3600);
    }
    if (data.expireTime < System.currentTimeMillis()) { // 逻辑过期
        Thread asyncThread = new Thread(() -> {
            // 异步更新缓存
            CacheData newData = db.queryData(key);
            redis.set(key, newData, 3600);
        });
        asyncThread.start();
    }
    return data.data;
}

三、缓存雪崩(Cache Avalanche)

1. 定义与问题
缓存雪崩指大量缓存key同时过期或Redis服务宕机,导致所有请求穿透缓存,直接压垮数据库,引发系统瘫痪。例如,电商平台商品缓存统一过期,凌晨用户访问高峰导致MySQL崩溃。

2. 核心原因

3. 解决方案(分层防御)
(1)过期时间错开

redis.set(key, value, 3600 + new Random().nextInt(300)); // 基础1小时 + 0-5分钟随机

(2)Redis高可用集群

(3)本地缓存兜底

LoadingCache<String, Object> localCache = Caffeine.newBuilder()
    .expireAfterWrite(30, TimeUnit.MINUTES) // 本地缓存过期30分钟
    .build(key -> redis.get(key));
public Object getData(String key) {
    Object value = localCache.get(key);
    if (value == null) {
        value = redis.get(key);
        localCache.put(key, value);
    }
    return value;
}

(4)缓存预热

public void warmUpCache() {
    List<String> hotKeys = db.getTopNKeys(); // 获取Top N热点key
    for (String key : hotKeys) {
        redis.set(key, db.queryData(key), 3600);
    }
}

四、总结

  1. 缓存穿透:使用布隆过滤器前置拦截无效请求,或缓存空值兜底。
  2. 缓存击穿分布式锁控制并发重建,或逻辑过期异步更新。
  3. 缓存雪崩分层防御策略,过期时间随机化 + 高可用集群 + 本地缓存兜底 + 缓存预热。
  4. 监控与预警:实时监控Redis命中率、数据库QPS等指标,异常时自动报警或熔断。

通过以上方案组合使用,可大幅提升系统稳定性,避免因缓存问题导致的服务崩溃。架构设计时需根据实际业务场景权衡性能与一致性,选择最适合的解决方案。

到此这篇关于Redis:缓存穿透、缓存击穿与缓存雪崩的文章就介绍到这了,更多相关Redis缓存穿透、缓存击穿与缓存雪崩内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文