本文共 13088 字，大约阅读时间需要 43 分钟。
项目使用redis作为缓存数据，但面临着问题，比如，项目A，项目B都用到redis，而且用的redis都是一套集群，这样会带来一些问题。
问题：比如项目A的开发人员，要缓存一些热门数据，想到了redis，于是乎把数据放入到了redis，自定义一个缓存key：hot_data_key，数据格式是项目A自己的数据格式，项目B也遇到了同样的问题，也要缓存热门数据，也是hot_data_key，数据格式是项目B是自己的数据格式，由于用的都是同一套redis集群，这样key就是同一个key，有的数据格式适合项目A，有的数据格式适合项目B，会报错的，我们项目中就遇到这样的一个错误，找不到原因，结果就是两个平台用到了同一key，很懊恼。解决方式：
1、弄一个常量类工程，所有的redis的key都放入到这个工程里，加上各自的平台标识，这样就不错错了2、spring Aop结合redis，再相应的service层，加上注解，key的规范是包名+key名，这样就不错重复了思路：
1、自定义注解，加在需要缓存数据的地方2、spring aop 结合redis实现3、SPEL解析注解参数，用来得到响应的注解信息4、redis的key：包名+key 防止redis的key重复实现如下：
项目准备，由于是maven项目，需要引入相关的包fastjson包spring-data-redis com.alibaba fastjson ${com.alibaba.fastjson} org.springframework.data spring-data-redis ${spring.redis.version} 还有一些必备的就是spring工程相关的包 redis.clients jedis ${jedis.redis.clients.version}
1、自定义注解
import java.lang.annotation.ElementType;import java.lang.annotation.Retention;import java.lang.annotation.RetentionPolicy;import java.lang.annotation.Target;import java.util.concurrent.TimeUnit;/** * 缓存注解 * * @author shangdc * */@Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)public @interface RedisCache { /** * 缓存key的名称 * @return */ String key(); /** * key是否转换成md5值，有的key是整个参数对象，有的大内容的，比如一个大文本，导致redis的key很长 * 需要转换成md5值作为redis的key * @return */ boolean keyTransformMd5() default false; /** * key 过期日期 秒 * @return */ int expireTime() default 60; /** * 时间单位，默认为秒 * @return */ TimeUnit dateUnit() default TimeUnit.SECONDS;} 2、定义切点Pointcut
/** * redis 缓存切面 * * @author shangdc * */public class RedisCacheAspect { //由于每个人的环境，日志用的不一样，怕报错，就直接关掉了此日志输出，如有需要可加上 //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 */ public T getData(String value, Class clazz){ 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 Class[pjp.getArgs().length]; for (int i = 0; i < args.length; i++) { argTypes[i] = args[i].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[i].getName() == methodName) { Class [] parameterTypes = methods[i].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[j] != argTypes[j] && !parameterTypes[j].isAssignableFrom(argTypes[j])) { isSameMethod = false; break; } } if (isSameMethod) { method = methods[i]; break; } } } return method; } /** * 计算根据Cacheable注解的expire和DateUnit计算要缓存的秒数 * @param cacheable * @return */ public int getExpireTimeSeconds(RedisCache redisCache) { int expire = redisCache.expireTime(); TimeUnit unit = redisCache.dateUnit(); if (expire <= 0) {//传入非法值，默认一分钟,60秒 return 60; } if (unit == TimeUnit.MINUTES) { return expire * 60; } else if(unit == TimeUnit.HOURS) { return expire * 60 * 60; } else if(unit == TimeUnit.DAYS) { return expire * 60 * 60 * 24; }else {//什么都不是，默认一分钟,60秒 return 60; } }} 3、spring相关配置