redis缓存的三大问题以及解决方法!!!!

专栏前言
   本专栏开启,目的在于帮助大家更好的掌握学习Redis,同时也是为了记录我自己学习Redis的过程,将会从基础的数据类型开始记录,直到一些更多的应用,如缓存击穿还有分布式锁以及Redis持久化等。希望大家有问题也可以一起沟通,欢迎一起学习,对于专栏内容有错还望您可以及时指点,非常感谢大家 。


1.缓存的三大问题
   话说学习缓存,缓存雪崩、击穿、穿透肯定是绕不开的一个话题,不仅在开发中我们需要注意这个问题,在面试中更是面试官有关Redis必问的面试题,可以说我们对这三个场景我们必须了解其中的差异,以及各自的解决方案。

2.缓存雪崩
2.1 什么是缓存雪崩?
   缓存雪崩指的是在同一时间,大量的Key同时失效,导致大量的请求直接绕开了我们的Redis直接打到数据库,数据库一下顶不住直接挂彩了,这就是缓存雪崩的场景。
那有的人肯定好奇,咦?怎么会那么巧大量的Key同时失效,考虑一个秒杀场景,比如双十一的时候,我们在晚上十一点集中上架一批商品,此时缓存过期时间设置为一小时,那么一到十二点这批商品的缓存就全部过期了,如果此时成千上万的用户想购买这些商品发送大量请求,就会导致数据库的压力上升从而可能压垮数据库。


  同一时间大量 Key 失效,就会导致Redis直接如同隐身了一样,那对于双十一这种数以千万级别甚至上亿量级的请求来到数据库,那后果就是灾难性的。一旦你一个库被打倒,那么其他的库可能也会收到影响,导致瞬间都挂掉了。你一重启用户又把你干崩,等你真正修好的时候,可能用户早就睡着了,还在心里吐槽一句什么垃圾产品。
  当然,如果Redis宕机了,那么显然也会触发缓存雪崩的情况。

2.如何解决缓存雪崩?
讨论完了案发场景,那我们该如何解决缓存雪崩了。

过期时间添加随机值。
那就对症下药嘛,既然你是大量的key同时过期导致的,那我就尽量让你不一起过期,所以我们在批量添加缓存的时候,可以给过期时间添加一个随机值,使得Key过期的时间尽量分散,这样保证缓存不会大面积的同时失效。
进行集群部署
集群部署的情况下,我们就无须担心某一台Redis宕机导致触发缓存雪崩,也可以将热点数据均匀分布在不同Redis库中,来避免全部失效的问题。
热点数据永不过期
我们也可以让热点数据永不过期,只进行更新的操作,这也可以避免缓存雪崩。但可能会带来数据不一致的问题。
3.缓存穿透
3.1 什么是缓存穿透?

  缓存穿透指的是对于一些缓存和数据库中都不存在的数据,而用户却不断对该数据进行请求,如果你的数据库甚至没有建立索引,那么数据库还会进行全表扫描,压力更大。每次数据库都需要去进行查,然后查不到,然后又继续查,然后又查不到,然后又…最终数据库卒,这就是缓存穿透。
  此时显然用户是一个攻击者,比如我们数据库id都是从1开始自增的,它可以故意访问一个负数的id,然后不断请求,如果是我们个人搭建的一些小网站,对这种行为没有预防,只需要用 postman 就可以干崩你的网站。


3.2 如何解决缓存穿透?
  我们考虑如何去解决缓存穿透问题。

参数校验
在场景中我们已经提及,对于一些非法的参数我们一定要进行校验,不合法的参数直接进行返回,比如一些负数的id,还有用户的鉴权校验。参数校验的思想我们一定要根深蒂固,在任何地方都不应该相信前端传来的参数,我们都应当手动判断其是否合法。
缓存空值
对于一些不存在的对象,我们也可以将其作为key缓存,value设置null,这样用户再次访问时就不会走数据库查询了。当然需要注意的是我们这个key的过期时间我们需要设置短一些。
 

@Component
public class CacheNullValue {

    private static final int CACHE_EXPIRATION = 60; // 缓存过期时间,单位为秒

    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    //@NotBlank对参数进行校验
    public String getData(@NotBlank String key) {
        String data = stringRedisTemplate.opsForValue().get(key);
        if (data == null) {
            data = getDataFromDatabase(key);
            if (data == null) {
                // 将空值缓存指定时间
                stringRedisTemplate.opsForValue().set(key, "", CACHE_EXPIRATION);
            } else {
                // 将数据缓存指定时间
                stringRedisTemplate.opsForValue().set(key, data, CACHE_EXPIRATION);
            }
        }
        return data;
    }

    private String getDataFromDatabase(String key) {
        // 从数据库中获取数据的逻辑
        System.out.println("查询数据");
        return null;
    }
}

布隆过滤器
这是一个解决缓存穿透效果最好的办法,但是确定就是代码维护起来比较复杂。它是一种数据结构,主要的作用是用来判断某个元素是否存在在集合内,具有运行速度快,占用内存小等优点,但是具有一定的误判率,而且删除困难等问题。但它有一个特点,就是会可能会误报但不会漏报,存在的元素它一定会知道,不存在的元素它可能也会告诉你存在。
这样我们就可以使用布隆过滤器来对一些数据进行白名单,如果不存在的话我们直接返回null或者失败。
监控IP
要知道正常的用户,肯定不会同时发大量的非法请求,当请求次数超过某个阈值时,那么我们可以对该用户ip进行拉黑,把他关进小黑屋。
4. 缓存击穿
4.1 什么是缓存击穿?

  接下来最后聊聊缓存击穿,有的同学可能容易把它和缓存穿透搞混,听起来意思很像,这里分析一下我的记法——巴雷特 (当然你也可以记成 AWM )。不知道大家玩过枪战游戏没,巴雷特是一把杀伤力巨大的狙击枪,单点的杀伤力爆炸,哪怕你站在门后都能把你一枪 击穿。
  回到正题,缓存击穿有点类型我们刚刚举的小例子,它指的是对于一个非常热门的key在不停地扛着大并发需求,如果这个key瞬间失效了,此时瞬间大并发就直接到达了数据库,数据库瞬间挂彩,这感觉就像大木桶打穿了一个洞的感觉(没错就是巴雷特的感觉 )
  缓存击穿一般是两个场景产生,注意我们强调的是并发的场景下:

该数据没有人查询过,所以缓存中没有,第一次就遭受大并发访问(某些冷门数据)
缓存中存在,但恰好失效了,大并发访问瞬间落到数据库(热点数据)
4.2 如何解决缓存击穿?
加互斥锁
由于是并发场景下,我们可以考虑加锁解决该问题,当缓存未命中时,只有持有锁的线程才能进行数据库查询,然后将查询结构写入缓存,其余的线程只能自旋进行等待。
下面是逻辑的流程图


@Component
public class RedisCache {
    
    private final static String CACHE_PREFIX = "my_cache_";
    private final static int EXPIRE_TIME_SECONDS = 60;
    private final ReentrantLock lock = new ReentrantLock();
    @Autowired
    private StringRedisTemplate stringRedisTemplate;
    public Object get(@NotBlank String key) {
        String cacheKey = CACHE_PREFIX + key;
        //1.先查询缓存
        ValueOperations<String, String> ops = redisTemplate.opsForValue();
        String value = ops.get(cacheKey);
        //2.缓存未命中
        if (value == null) {
            //3.尝试获取锁
            lock.lock();
            try {
                 //4.双重校验
                value = ops.get(cacheKey);           
                if (value == null) {
                    //5.查询数据库
                    value = fetchDataFromDatabase(key);
                    //6.写回redis
                    ops.set(cacheKey, value, EXPIRE_TIME_SECONDS);
                    
                }
            } catch (Exception e) {
                System.out.println("出现异常");
            } finally {
                //释放锁
                lock.unlock();
            }
        }
        return value;
    }

    private String fetchDataFromDatabase(String key) {
        System.out.println("查询数据库");
        return key;
    }
}

需要注意我们这里的场景是单机的情况下,如果是分布式环境的话我们就得使用分布式锁了,这里我们使用synchronized和lock都是可以的。有关分布式锁我们后续文章会进行讲解

热点数据永不过期
同样因为是数据过期的问题,那我们也可以考虑设置热点数据永不过期,当后台更新数据的同时更新缓存中的数据,当然可能会带来数据不一致的问题,适用于不严格要求缓存一致性的场景。