Redis分布式锁如何防止缓存击穿

魁首哥

作者

Redis分布式锁如何防止缓存击穿

这篇文章主要为大家展示了“Redis分布式锁如何防止缓存击穿”，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下“Redis分布式锁如何防止缓存击穿”这篇文章吧。

缓存击穿

和缓存穿透不同的是，缓存击穿是指：缓存中没有，但是数据库中存在的热点数据。

例如：首页的热点新闻，并发访问量非常大的热点数据，如果缓存过期失效，服务器会去查询DB，这时候如果大量的并发去查询DB，可能会瞬间压垮DB。

画了个简图，如下所示：

解决方案：DB查询加分布式锁。

未加锁的情况

解决问题之前，先看一下不做处理的代码和运行情况。

根据商品ID查询商品详情代码

清空Redis缓存，开启5个线程去并发访问测试，测试代码如下：

我们预期希望DB只查询一次，后面4个查询从Redis缓存中取就行，但是结果：

没有加分布式锁，结果也在意料之中，但是这样容器给DB造成很大压力。

如果是单台服务器，直接使用Java的同步锁即可

遗憾的是，通常后端是会部署集群的，Java的同步锁可没办法实现分布式锁。

Redis分布式锁解决缓存击穿

Java的内置锁只能应用在单台机器上，无法实现分布式，可以巧用Redis来实现分布式锁。

加了分布式锁后的代码

//根据ID查询商品@GetMapping("/{id}")publicRid(@PathVariableStringid){//先查Redis缓存Objecto=redisTemplate.opsForValue().get(id);if(o!=null){//命中缓存System.err.println("id:"+id+",命中redis缓存...");returnR.success(o);}//缓存未命中查询数据库StringlockKey="lock"+id;//加锁，10s后过期for(;;){if(redisTemplate.opsForValue().setIfAbsent(lockKey,System.currentTimeMillis(),10L,TimeUnit.SECONDS)){//加锁成功的线程,再次检查o=redisTemplate.opsForValue().get(id);if(o!=null){//命中缓存System.err.println("Thread:"+Thread.currentThread().getName()+",id:"+id+",命中redis缓存...");//释放锁redisTemplate.delete(lockKey);returnR.success(o);}//仍未命中System.err.println("Thread:"+Thread.currentThread().getName()+",id:"+id+",查询DB...");Goodsgoods=goodsMapper.selectById(id);//结果存入RedisredisTemplate.opsForValue().set(id,goods);//释放锁redisTemplate.delete(lockKey);returnR.success(goods);}//竞争不到锁，暂时让出CPU资源Thread.yield();}}

启动5个线程，并发访问，结果如下图：