微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

分布式锁处理缓存rdisson实例

场景:

首页菜单的数据获取 通过读取缓存来实现
并发请求首页
redis命中 有则返回数据
redis不命中 启动分布式锁
放第一条请求进来 查库防止缓存
非第一条请求 再次先 先验证是否有缓存 有责直接读缓存

 @Override
 public Map<String, List<Catelog2Vo>>  getCatalogJson() {
     //给缓存存放json 拿出的json字符串需要逆转为对象类型【序列化与反序列化】
     //1.从缓存取出的json
     String redisString = stringRedistemplate.opsForValue().get(RedisConstant.INDEX_CATALOGJSON);
     if(StringUtils.isEmpty(redisString)){
         System.out.println("缓存不命中 查数据库...");
         //2.缓存中没有 查询数据库
         Map<String, List<Catelog2Vo>> catlogJsonFromDb = getCatalogJsonFromDbWithReddisson();
         return catlogJsonFromDb;
     }
     System.out.println("缓存命中 直接返回...");
     //2. - 直接把缓存取出结果 逆转指定类型
     Map<String, List<Catelog2Vo>> result = JSON.parSEObject(redisString, new TypeReference< Map<String, List<Catelog2Vo>>>(){});
     return  result;

 }

带有分布式锁的处理缓存:

 /**
     *  缓存里面的数据如何和数据库一致性
     *   双写模式: 数据库更新后查出数据把redis更新  存在产生脏数据的风险 -> 读写锁解决
     *   失效模式: 数据库更新 删除缓存redis.del(RedisConstant.INDEX_CATALOGJSON_LOCK) 等待下次查询更新  存在产生脏数据的风险 -> 读写锁解决
     *
     *   系统一致性解决方案:
     *   1.缓存数据都有过期时间,下一次过期触发主动更新数据
     *   2.读写数据在 加上分布式的读写锁。
     *          经常写 经常读   (读写锁会影响性能 主要是写会影响)
     *
     *   id udpate ->

     */
    public Map<String,List<Catelog2Vo>> getCatalogJsonFromDbWithReddisson(){
        // 1.占分布式锁  (锁的名字 锁的粒度 越细越快)
        RLock lock = redisson.getLock(RedisConstant.INDEX_CATALOGJSON_LOCK);
        lock.lock(30,TimeUnit.SECONDS);
        Map<String, List<Catelog2Vo>> dataFromDb;
        try{
            dataFromDb = getDataFromDb();
        }finally {
            lock.unlock();
        }
        return dataFromDb;

    }

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐