Redis实战篇

缓存击穿问题也叫热点Key问题就是一个被高并发访问并且缓存重建业务较复杂的Key突然失效了无数的请求访问会在瞬间给数据库带来巨大的冲击。

Redis实战篇

需求修改根据id查询商铺的业务基于互斥锁方式来解决缓存击穿问题

核心思路就是利用redis的setnx方法来表示获取锁如果redis没有这个key则插入成功返回1如果已经存在这个key则插入失败返回0。

在StringRedisTemplate中返回true/false我们可以根据返回值来判断是否有线程成功获取到了锁

ShopServiceImpl

stringRedisTemplate.opsForValue().get(CACHE_SHOP_KEY

{Shop

queryWithMutex(id);}//查不到则将空值写入Redisshop

getById(id);if

{stringRedisTemplate.opsForValue().set(CACHE_SHOP_KEY

id,

JSONUtil.toJsonStr(shop);//并存入redis设置TTLstringRedisTemplate.opsForValue().set(CACHE_SHOP_KEY

id,

TimeUnit.MINUTES);//最终把查询到的商户信息返回给前端}

catch

stringRedisTemplate.opsForValue().setIfAbsent(key,

10,

key){stringRedisTemplate.delete(key);}

直接在redis中设计一个永久的热点key当发现逻辑时间已过期则采用类似互斥锁方式解决缓存击穿

需求根据id查询商铺的业务基于逻辑过期方式来解决缓存击穿问题思路分析当用户开始查询redis时判断是否命中

如果没有命中则直接返回空数据不查询数据库如果命中则将value取出判断value中的过期时间是否满足

如果没有过期则直接返回redis中的数据如果过期则在开启独立线程后直接返回之前的数据独立线程去重构数据重构完成后再释放互斥锁

封装数据因为现在redis中存储的数据的value需要带上过期时间此时要么你去修改原来的实体类要么新建一个类包含原有的数据和过期时间

步骤一这里我们选择新建一个实体类包含原有数据(用万能的Object)和过期时间这样对原有的代码没有侵入性

Data

RedisData();redisData.setData(shop);redisData.setExpireTime(LocalDateTime.now().plusSeconds(expirSeconds));stringRedisTemplate.opsForValue().set(CACHE_SHOP_KEY

id,

JSONUtil.toJsonStr(redisData));

步骤三正式代码

//这里需要声明一个线程池因为下面我们需要新建一个现成来完成重构缓存

private

Executors.newFixedThreadPool(10);Override

public

stringRedisTemplate.opsForValue().get(CACHE_SHOP_KEY

id);//2.

(LocalDateTime.now().isBefore(expireTime))

{//5.

开启独立线程CACHE_REBUILD_EXECUTOR.submit(()

{try