@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] 举报,一经查实,本站将立刻删除。