在上文中,咱们尽管在业务层service中实现了代码的实现.然而该代码不具备复用性.如果换了其余的业务则须要从新编辑.
并且因为缓存的代码写在业务层service中,所以代码的耦合性高,不不便当前的扩大.
所以咱们从代码复用以及升高代码的耦合性的方面应用AOP来实现redis缓存.
AOP
AOP即面向切面编程–在不改变原有代码的根底上,对业务进行加强.
AOP = 切入点表达式 + 告诉办法
专业术语:
1.连接点: 在执行失常的业务过程中满足了切入点表达式时进入切面的点.(织入) 多个
2.告诉: 在切面中执行的具体的业务(扩大) 办法
3.切入点: 可能进入切面的一个判断 if判断 一个
4.指标办法: 将要执行的实在的业务逻辑.
告诉办法
分类:
1.前置告诉(@Before): 指标办法执行之前执行
2.后置告诉(@After): 指标办法执行之后执行
3.异样告诉(@AfterThrowing): 指标办法执行之后抛出异样时执行
4.最终告诉(@AfterReturning): 不论什么时候都要执行的办法.
阐明:上述的四大告诉类型不能控制目标办法是否执行.个别应用上述的四大告诉类型,都是用来记录程序的执行状态.
5.盘绕告诉(@Around): 在指标办法执行前后都要执行的告诉办法. 控制目标办法是否执行.并且盘绕告诉的性能最为弱小.
盘绕告诉是最为罕用的.
切入点表达式
分类:
1.bean(bean的id) 类名首字母小写 匹配1个类
2.within(包名.类名) 按包门路匹配类 匹配多个类
上述表达式是粗粒度的管制,按类匹配.
3.execution(返回值类型 包名.类名.办法名(参数列表))
4.@annotation(包名.注解名) 按注解进行拦挡.
上述是细粒度的管制.
bean和@annotation较为罕用
实现Redis缓存
业务剖析
1.自定义注解CacheFind 次要被注解标识的办法,则开启缓存的实现.
2.为了未来辨别业务,须要在注解中标识key属性,由使用者自行填写.
3.为了用户提供数据超时性能.
自定义注解@CacheFind
@Retention(RetentionPolicy.RUNTIME) //该注解运行时无效
@Target({ElementType.METHOD}) //对办法无效
public @interface CacheFind {
String key(); //该属性为必须增加
int seconds() default 0; //设定超时工夫 默认不超时
}编写CacheAOP类
package com.jt.aop;
import com.jt.annotation.CacheFind;
import com.jt.util.ObjectMapperUtil;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import redis.clients.jedis.Jedis;
import java.util.Arrays;
@Component
@Aspect
public class RedisAOP {
//注入缓存reids对象
@Autowired
private Jedis jedis;
//@Pointcut("@annotation(com.jt.annotation.CacheFind)")
//public void doRedisPointCut(){}
/**
* 拦挡@CacheFind注解示意的办法
* 告诉抉择: 缓存的实现应该选用盘绕告诉
* 步骤:
* 1.动静生成key 用户填写的key+用户提交的参数
*/
@Around("@annotation(cacheFind)")
public Object around(ProceedingJoinPoint joinPoint, CacheFind cacheFind){
try {
Object result = null;
//1.如何动静获取用户在注解中填写的数据
String prekey = cacheFind.key();
//2.动静获取指标办法中的参数 将数组转化为字符串
String args = Arrays.toString(joinPoint.getArgs());
String key = prekey + "::" + args; //"ITEM_CAT_PARENTID::[0]"
//3.查问缓存中查问
//4.判断json中是否有值
if (jedis.exists(key)) { //先获取json数据
String json = jedis.get(key);
//动静获取指标办法的返回值类型?? 向上造型 不必强转 向下造型
MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
Class target = methodSignature.getReturnType();
//7.进入代表程序中有值,将json转为对象
result = ObjectMapperUtil.toObject(json, target);
System.out.println("AOP实现缓存查问!!!!");
}else {
//5.若缓存中没有查询数据库
result = joinPoint.proceed(); //执行指标办法,获取返回值后果
System.out.println("AOP执行数据库操作");
//6.将数据存到redis中
//先转为json格局
String json = ObjectMapperUtil.toJSON(result);
if(cacheFind.seconds()>0){ //判断是否须要超时工夫
jedis.setex(key, cacheFind.seconds(), json);
}else {
jedis.set(key, json);
}
}
return result;
}catch (Throwable e){
e.printStackTrace();
throw new RuntimeException(e);
}
}
}留神
对于盘绕告诉参数的阐明:
1.连接点必须位于告诉办法参数的第一位
2.其余四大告诉类型不能够增加ProceedingJoinPoint对象,能够增加JointPoint对象
JoinPoint应用
/**
* 要求: 拦挡注解办法
* 打印:
* 1.打印指标对象的类型
* 2.打印办法的参数
* 3.获取指标对象的名称及办法的名称
* @param joinPoint
*/
@Before("@annotation(com.jt.anno.CacheFind)")
public void before(JoinPoint joinPoint){
Object target = joinPoint.getTarget(); //获取指标对象
Object[] args = joinPoint.getArgs(); //获取办法参数的
String targetName =
joinPoint.getSignature().getDeclaringTypeName(); //获取指标对象的名称
//获取指标对象的类型
Class targetClass = joinPoint.getSignature().getDeclaringType();
//获取指标办法的名称
String methodName = joinPoint.getSignature().getName();
System.out.println(target);
System.out.println(args);
System.out.println(targetName);
System.out.println(targetClass);
System.out.println(methodName);
}
发表回复