redis分布式锁解决缓存双写一致性

目录

• 如何解决缓存双写问题
• 业务背景-美食分享
• 分布式锁
• 查询
• 修改

//根据id查询美食信息  
public GoodsVO loadGoodsInfoById(Long id) {
  //从redis中拿用户信息
  Object obj = redisTemplate.opsForValue().get(GOODS_KEY + id);
  if(obj == null) {
      //如果redis中不存在，就从数据库中获取
      GoodsVO goods = loadGoodsFromDb(id);
      //将结果保存到redis中
      redisTemplate.opsForValue().set(GOODS_KEY+id,JSONUtil.toJsonPrettyStr(goods));
      return fileUser;
  }
  return JSONUtil.toBean(obj.toString(), GoodsVO.class);
}

//编辑美食信息
public void modifyGoodsById(GoodsVO goodsVO) throws Exception{
    //删除缓存
    redisTemplate.delete(GOODS_KEY + goodsVO.getId());
    //更新用户信息
    goodsMapper.updateById(goodsVO);
    //删除缓存
    Thread.sleep(1000);
    redisTemplate.delete(GOODS_KEY + goodsVO.getId());
}

//根据id查询美食信息  
public GoodsVO loadGoodsInfoById(Long id) {
  //从redis中拿用户信息
  Object obj = redisTemplate.opsForValue().get(GOODS_KEY + id);
  if(obj == null) {
      //如果redis中不存在，就从数据库中获取
      GoodsVO goods = loadGoodsFromDb(id);
      return fileUser;
  }
  return JSONUtil.toBean(obj.toString(), GoodsVO.class);
}
//查询缓存中没有，这时候就要去数据库中查询
public String getGoodInfoFromDb(Long id) {
    //此时这里要加的锁和 modifyGoodsById()方法加的应该是同一把锁，这样才能保证双写一致性
    boolean lock = redisLock.tryLock(GOODS_KEY+id);
    if(!lock) {
    	//获取锁失败,尝试从缓存中获取
    	Object obj = redisTemplate.opsForValue().get(GOODS_KEY + id);
      if(obj != null){
          return JSONUtil.toBean(obj.toString(), GoodsVO.class);
      }else{
          //直接返回一个操作频繁的信息给前端
          throw new GloableException("访问频繁，请稍后再试");
      }
    }
    try{
        //获取到锁了
        //尝试从缓存中拿
        Object obj = redisTemplate.opsForValue().get(GOODS_KEY + id);
        if(obj != null) {
            return JSONUtil.toBean(obj.toString(), GoodsVO.class);
        }
        //缓存中没有，从MySql中拿
        GoodsVO goods = goodsMapper.selectById(id);
        if(goods == null) {
            //为了解决缓存穿透的问题
            redisTemplate.opsForValue().set(GOODS_NULL_KEY + id);
            return null;
        }
        //将数据库查到的数据放到缓存中
        redisTemplate.opsForValue().set(GOODS_KEY+id,JSONUtil.toJsonPrettyStr(goods));
        return goods;
    }finally{
       //释放锁
       redisLock.unLock(GOODS_KEY+goodsVO.getId());
    }
}

//编辑美食信息
public void modifyGoodsById(GoodsVO goodsVO) throws Exception{
    //尝试获取锁
    boolean lock = redisLock.tryLock(GOODS_KEY+goodsVO.getId());
    if(!lock) {
      	//直接返回一个操作频繁的信息给前端
        throw new GloableException("更新数据失败,请稍后再试.....");
    }
    try{
        //获取到锁了
        //更新用户信息
        goodsMapper.updateById(goodsVO);
        //更新完之后，将数据库最新的数据更新到缓存中
        redisTemplate.opsForValue().set(GOODS_KEY+id,JSONUtil.toJsonPrettyStr(goodsVO));
    }finally{
        //释放锁
        redisLock.unLock(GOODS_KEY+goodsVO.getId());
    }
}