spring与redis集成之aop整合方案
java使用redis缓存可以使用jedis框架,jedis操作简单,没有什么复杂的东西需要学习,网上资料很多,随便看看就会了.将spring与redis缓存集成,其实也是使用jedis框架,只不过spring对它进行了一层封装,并将这层封装库命名为spring-data-redis.
下面将要使用spring-data-redis与jedis的jar包,并通过spring的aop功能,将redis缓存无缝无侵入的整合进来.
1.先下载好依赖包
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*]
[*] org.springframework
[*] spring-core
[*] 4.1.1.RELEASE
[*]
[*]
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*]
[*] org.springframework.data
[*] spring-data-redis
[*] 1.4.1.RELEASE
[*]
[*]
[*] redis.clients
[*] jedis
[*] 2.6.0
[*]
2.再配置spring文件
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
[*]
3.开始编写aop代码
3.1 声明两个注解类,用于定义哪些方法将使用缓存
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*] @Retention(RetentionPolicy.RUNTIME)
[*] @Target({ElementType.METHOD})
[*] public @interface Cacheable {
[*]
[*] public enum KeyMode{
[*] DEFAULT, //只有加了@CacheKey的参数,才加入key后缀中
[*] BASIC, //只有基本类型参数,才加入key后缀中,如:String,Integer,Long,Short,Boolean
[*] ALL; //所有参数都加入key后缀
[*] }
[*]
[*] public String key() default ""; //缓存key
[*] public KeyMode keyMode() default KeyMode.DEFAULT; //key的后缀模式
[*] public int expire() default 0; //缓存多少秒,默认无限期
[*] }
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*] @Retention(RetentionPolicy.RUNTIME)
[*] @Target({ElementType.PARAMETER})
[*] public @interface CacheKey {}
3.2 创建一个Aop拦截器的处理类,用于拦截加了@Cacheable的方法
view plaincopyhttps://code.csdn.net/assets/CODE_ico.pnghttps://code.csdn.net/assets/ico_fork.svg
[*] @Aspect
[*] @Component
[*] public class CacheableAop {
[*]
[*] @Autowired private RedisTemplate redisTemplate;
[*]
[*] @Around("@annotation(cache)")
[*] public Object cached(final ProceedingJoinPoint pjp,Cacheable cache) throws Throwable {
[*]
[*] String key=getCacheKey(pjp, cache);
[*] ValueOperations valueOper=redisTemplate.opsForValue();
[*] Object value=valueOper.get(key); //从缓存获取数据
[*] if(value!=null) return value; //如果有数据,则直接返回
[*]
[*] value = pjp.proceed(); //跳过缓存,到后端查询数据
[*] if(cache.expire()0) {
[*] buf.append(".").append(cache.key());
[*] }
[*]
[*] Object[] args=pjp.getArgs();
[*] if(cache.keyMode()==KeyMode.DEFAULT) {
[*] Annotation[][] pas=((MethodSignature)pjp.getSignature()).getMethod().getParameterAnnotations();
[*] for(int i=0;i
页:
[1]