From 61229e527688452c3dc67a219c6017e034ec7dd6 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 29 五月 2021 14:28:28 +0800
Subject: [PATCH] 礼金创建优化
---
service-lijin/src/main/java/com/ks/lijin/aspect/RedisCacheAspect.java | 15 ++++++++-------
1 files changed, 8 insertions(+), 7 deletions(-)
diff --git a/service-lijin/src/main/java/com/ks/lijin/aspect/RedisCacheAspect.java b/service-lijin/src/main/java/com/ks/lijin/aspect/RedisCacheAspect.java
index c9a0f33..703b68b 100644
--- a/service-lijin/src/main/java/com/ks/lijin/aspect/RedisCacheAspect.java
+++ b/service-lijin/src/main/java/com/ks/lijin/aspect/RedisCacheAspect.java
@@ -1,6 +1,5 @@
package com.ks.lijin.aspect;
-import com.ks.lijin.service.manager.RedisManager;
import com.ks.lijin.util.annotation.RedisCache;
import com.ks.lijin.util.annotation.RedisCacheEvict;
import org.aspectj.lang.ProceedingJoinPoint;
@@ -12,6 +11,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.core.DefaultParameterNameDiscoverer;
import org.springframework.core.annotation.Order;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.expression.EvaluationContext;
import org.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;
@@ -22,6 +22,7 @@
import javax.annotation.Resource;
import java.lang.reflect.Method;
+import java.util.concurrent.TimeUnit;
@Component
@Aspect
@@ -29,7 +30,7 @@
public class RedisCacheAspect {
Logger logger = LoggerFactory.getLogger(RedisCacheAspect.class);
@Resource
- private RedisManager redisManager;
+ private RedisTemplate redisTemplate;
private ExpressionParser parser = new SpelExpressionParser();
@@ -66,7 +67,7 @@
return cacheKey;
}
- @Around("execution(public * com.ks.app.service..*.*(..))")
+ @Around("execution(public * com.ks.lijin.service..*.*(..))")
public Object requestSerializable(ProceedingJoinPoint joinPoint) throws Throwable {
Signature signature = joinPoint.getSignature();
MethodSignature methodSignature = (MethodSignature) signature;
@@ -93,7 +94,7 @@
String cacheKey = getRedisKey(redisCache, joinPoint);
if (!StringUtil.isNullOrEmpty(cacheKey)) {
try {
- Object result = redisManager.getDataFromRedis(cacheKey);
+ Object result = redisTemplate.opsForValue().get(cacheKey);
if (result != null) {
return result;
}
@@ -111,7 +112,7 @@
String cacheKey = getRedisKey(redisCache, joinPoint);
if (!StringUtil.isNullOrEmpty(cacheKey)) {
try {
- redisManager.setDataToRedis(cacheKey, object, redisCache.second());
+ redisTemplate.opsForValue().set(cacheKey, object, redisCache.second(), TimeUnit.SECONDS);
} catch (Exception e) {
logger.error("redis淇濆瓨缂撳瓨鏁版嵁鍑洪敊", e.getMessage(), "key锛�" + cacheKey);
}
@@ -123,9 +124,9 @@
if (!StringUtil.isNullOrEmpty(cacheKey)) {
try {
if (!StringUtil.isNullOrEmpty(key)) {
- redisManager.remove(cacheKey);
+ redisTemplate.delete(cacheKey);
} else {
- redisManager.removePrefix(cacheKey);
+ redisTemplate.delete(cacheKey + "*");
}
} catch (Exception e) {
logger.error("redis娓呴櫎缂撳瓨鏁版嵁鍑洪敊", e.getMessage(), "key锛�" + cacheKey);
--
Gitblit v1.8.0