Spring AOP实现对redis统一管理 （注解方式）
/** * redis 缓存切面*
* @author shangdc
*
*/
public> //由于每个人的环境，日志用的不一样，怕报错，就直接关掉了此日志输出，如有需要可加上
//private Logger LOG = Logger.getLogger(RedisCacheAspect.class);
/**
* 这块可配置，每个公司都要自己的缓存配置方式，到时候可配置自己公司所用的缓存框架和配置方式
*/
@Resource(name = "redisTemplate")
private ValueOperations valueOperations;
/**
* 具体的方法
* @param jp
* @return
* @throws Throwable
*/
public Object cache(ProceedingJoinPoint jp, RedisCache cacheable) throws Throwable{
// result是方法的最终返回结果
Object result = null;
// 得到类名、方法名和参数
Object[] args = jp.getArgs();
//获取实现类的方法
Method method = getMethod(jp);
//注解信息 key
String key = cacheable.key();
//是否转换成md5值
boolean keyTransformMd5 = cacheable.keyTransformMd5();
//----------------------------------------------------------
// 用SpEL解释key值
//----------------------------------------------------------
//解析EL表达式后的的redis的值
String keyVal = SpringExpressionUtils.parseKey(key, method, jp.getArgs(), keyTransformMd5);
// 获取目标对象
Object target = jp.getTarget();
//这块是全路径包名+目标对象名 ，默认的前缀，防止有的开发人员乱使用key，乱定义key的名称，导致重复key，这样在这加上前缀了，就不会重复使用key
String target_class_name = target.getClass().getName();
StringBuilder redis_key = new StringBuilder(target_class_name);
redis_key.append(keyVal);
//最终的redis的key
String redis_final_key = redis_key.toString();
String value = valueOperations.get(redis_final_key);
if (value == null) { //这块是判空
// 缓存未命中，这块没用log输出，可以自定义输出
System.out.println(redis_final_key + "缓存未命中缓存");
// 如果redis没有数据则执行拦截的方法体
result = jp.proceed(args);
//存入json格式字符串到redis里
String result_json_data = JSONObject.toJSONString(result);
System.out.println(result_json_data);
// 序列化结果放入缓存
valueOperations.set(redis_final_key, result_json_data, getExpireTimeSeconds(cacheable), TimeUnit.SECONDS);
} else {
// 缓存命中，这块没用log输出，可以自定义输出
System.out.println(redis_final_key + "命中缓存，得到数据");
// 得到被代理方法的返回值类型
Class returnType = ((MethodSignature) jp.getSignature()).getReturnType();
//拿到数据格式
result = getData(value, returnType);
}
return result;
}
/**
* 根据不同的class返回数据
* @param value
* @param clazz
* @return
*/
publicT getData(String value,> T result = JSONObject.parseObject(value, clazz);
return result;
}
/**
* 获取方法
* @param pjp
* @return
* @throws NoSuchMethodException
*/
public static Method getMethod(ProceedingJoinPoint pjp) throws NoSuchMethodException {
// --------------------------------------------------------------------------
// 获取参数的类型
// --------------------------------------------------------------------------
Object[] args = pjp.getArgs();
Class[] argTypes = new> for (int i = 0; i < args.length; i++) {
argTypes = args.getClass();
}
String methodName = pjp.getSignature().getName();
Class targetClass = pjp.getTarget().getClass();
Method[] methods = targetClass.getMethods();
// --------------------------------------------------------------------------
// 查找Class里函数名称、参数数量、参数类型（相同或子类）都和拦截的method相同的Method
// --------------------------------------------------------------------------
Method method = null;
for (int i = 0; i < methods.length; i++) {
if (methods.getName() == methodName) {
Class[] parameterTypes = methods.getParameterTypes();
boolean isSameMethod = true;
// 如果相比较的两个method的参数长度不一样，则结束本次循环，与下一个method比较
if (args.length != parameterTypes.length) {
continue;
}
// --------------------------------------------------------------------------
// 比较两个method的每个参数，是不是同一类型或者传入对象的类型是形参的子类
// --------------------------------------------------------------------------
for (int j = 0; parameterTypes != null && j < parameterTypes.length; j++) {
if (parameterTypes != argTypes && !parameterTypes.isAssignableFrom(argTypes)) {
isSameMethod = false;
break;
}
}
if (isSameMethod) {
method = methods;
break;
}
}
}
return method;
}
/**
* 计算根据Cacheable注解的expire和DateUnit计算要缓存的秒数
* @param cacheable
* @return
*/
public int getExpireTimeSeconds(RedisCache redisCache) {
int expire = redisCache.expireTime();
TimeUnit unit = redisCache.dateUnit();
if (expire
页:
[1]