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

Redis缓存查询(防缓存击穿)

@GetMapping("getResourceByConsumer")
    public APIResponse getResourceByConsumer(String consumerId){
        String error = "";
        try {
            List<TReConsumerResource> resourceByConsumer = new ArrayList<>();
            long startTime = System.currentTimeMillis();
            RedisUtil redisUtil = new RedisUtil(redistemplate);
            error = "hasKeyPre";
            if(redisUtil.hasKey(consumerId)){
                long getKeyEndTime = System.currentTimeMillis();
                error = "hasKey";
                resourceByConsumer = (List<TReConsumerResource>) redisUtil.get(consumerId);
                error = "redisUtilGet";
                long endTime = System.currentTimeMillis();
                long totalTime = endTime -startTime;
                long getKeyTime = getKeyEndTime - startTime;
                long getValueTime = endTime - getKeyEndTime;
                return new APIResponse(ResponeCode.SUCCESS,
                        "查询成功,通过redis查询,总用时:"+totalTime+"ms 判断redisKey用时:"
                                +getKeyTime+"ms 获取redis值用时"+ getValueTime+"ms"
                        ,resourceByConsumer);
            }else {
                synchronized (this){
                    long getKeyEndTime = System.currentTimeMillis();
                    error = "bysqlPre";
                    resourceByConsumer = tReConsumerResourceService.getResourceByConsumerId(consumerId);
                    error = "bysqlEnd";
                    long getValueEndTime = System.currentTimeMillis();
//            redisUtil.sSetAndTime(consumerId,1L*60L*60L*24L,resourceByConsumer);
                    redisUtil.set(consumerId,resourceByConsumer);
                    long endTime = System.currentTimeMillis();
                    long totalTime = endTime -startTime;
                    long getKeyTime = getKeyEndTime - startTime;
                    long getValueTime = getValueEndTime - getKeyEndTime;
                    long putRedisTime = endTime - getValueEndTime;
                    return new APIResponse(ResponeCode.SUCCESS,
                            "查询成功,通过数据库查询,总用时:"+totalTime+"ms 判断redisKey用时:"
                                    +getKeyTime+"ms 通过数据库获取值用时:"+getValueTime+"ms 放入redis用时:"+putRedisTime+"ms"
                            ,resourceByConsumer);
                }
            }
        }catch (Exception e){
            return new APIResponse(ResponeCode.INTERNAL_SERVER_ERROR,e.getMessage()+error);
        }

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

相关推荐