SpringAOP

什么是Aop编程

Aop面向切面编程，在方法之前和之后实现处理 应用场景在于：日志打印、事务实现、安全等。

因为AOP可以解决我们程序上的代码冗余问题

Spring的AOP

前置通知

后置通知

环绕通知

运行通知

异常通知

Aop编程底层的原理

动态代理技术

• 基于Jdk实现InvocationHandler 底层使用反射技术
• 基于CGLIB实现 字节码技术

基于注解方式启动Aop

日志AOP

@Aspect**//定义切面类** @Component**//注入spring容器** @EnableAspectJAutoProxy**//开启AOP** public class LogAop { //定义切入点,表示开始拦截的入口 @Pointcut("execution (* com.xuyu.service..*.*(..))") public void logAop(){

1}
2@Before("logAop()")
3public void doBefor(){
4    System.out.println("前置通知....在调用方法之前拦截");
5}
6@After("logAop()")
7public void doAfter(){
8    System.out.println("后置通知....在调用方法之后拦截");
9}

}

Config

@Configuration @ComponentScan(basePackages = {"com.xuyu.service","com.xuyu.aop"}) public class MyConfig { }

service

@Component public class OrderService {

1public void addOrder(){
2    System.out.println("执行目标方法....");
3}

}

启动类

public class App { public static void main(String[] args) { AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(MyConfig.class); OrderService orderService = applicationContext.getBean("orderService", OrderService.class); orderService.addOrder(); } }

执行结果

前置通知....在调用方法之前拦截
执行目标方法....
后置通知....在调用方法之后拦截

我们开始分析下源码

所以我们可以直接使用@Import注解把AspectJAutoProxyRegistrar这个类注入IOC容器中

@Import(AspectJAutoProxyRegistrar.class)

等价于这个注解

@EnableAspectJAutoProxy//开启AOP

完整的五个通知

@Aspect//定义切面类 @Component//注入spring容器 @EnableAspectJAutoProxy//开启AOP public class LogAop { //定义切入点,表示开始拦截的入口 @Pointcut("execution (* com.xuyu.service..*.*(..))") public void logAop(){

1}
2@Before("logAop()")
3public void doBefore(){
4    System.out.println("前置通知....在调用方法之前拦截");
5}
6@After("logAop()")
7public void doAfter(){
8    System.out.println("后置通知....在调用方法之后拦截");
9}
10@AfterReturning("logAop()")
11public void  around(JoinPoint joinpoint) throws Throwable {
12    String name = joinpoint.getSignature().getName();
13    System.out.println("返回通知...."+name);
14}
15@AfterThrowing("logAop()")
16public void afterThrowing(JoinPoint joinPoint) {
17    System.out.println("异常通知....");
18}
19@Around("logAop()")
20public void doAround(ProceedingJoinPoint joinPoint) throws Throwable {
21    System.out.println("环绕通知，在目标方法之前处理....");
22    joinPoint.proceed();//执行目标方法
23    System.out.println("环绕通知，在目标方法之后处理....");
24}

}

打印结果

环绕通知，在目标方法之前处理....
前置通知....在调用方法之前拦截
目标方法执行....
环绕通知，在目标方法之后处理....
后置通知....在调用方法之后拦截
返回通知....addOrder

springBoot手动事务实现方式

手动begin commit rollback

@Component public class TransactionalUtils { //TransactionAspectSupport currentTransactionStatus().setRollbackOnly(); /** * 获取当前事务管理器 */ @Autowired private DataSourceTransactionManager dataSourceTransactionManager;

1public TransactionStatus begin() {
2    TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
3    System.out.println("获取当前的事务>>>>>");
4    return transaction;
5}
6/\*\*
7 \* 提交事务
8 \*/
9public void commit(TransactionStatus transactionStatus) {
10    System.out.println("提交当前的事务>>>>>");
11    dataSourceTransactionManager.commit(transactionStatus);
12}
13public void rollback(TransactionStatus transactionStatus) {
14    System.out.println("回滚当前的事务>>>>>");
15    dataSourceTransactionManager.rollback(transactionStatus);
16}

}

@Service public class OrderService { @Autowired private OrderInfoMapper orderInfoMapper; @Autowired private TransactionalUtils transactionalUtils;

1    public int addOrderInfo(int j) {
2    TransactionStatus begin = transactionalUtils.begin();
3    try {
4        int i = orderInfoMapper.addOrderInfo();
5        int result = 1 / j;
6        transactionalUtils.commit(begin);
7    } catch (Exception e) {
8        e.printStackTrace();
9        transactionalUtils.rollback(begin);
10    }
11    return 1;
12}

手动begin commit rollback代码会冗余，所以我们使用AOP重构下手动事务

使用SpringAop实现重构实现声明式事务

@Aspect @Component @Scope("prototype")//单例会有问题，这里设置为多例 public class TransactionalAop { //Aspect 定义切点类 @Autowired private TransactionalUtils transactionalUtils; /** * @Pointcut 定义切入点 */ @Pointcut("execution (* com.mayikt.service..*.*(..))") public void transactionalAop() { } @Around("transactionalAop()") public Object around(ProceedingJoinPoint joinPoint) throws Throwable { // 获取方法名称 String methodName = joinPoint.getSignature().getName(); // 获取目标对象 Class<?> classTarget = joinPoint.getTarget().getClass(); // 获取目标对象类型 Class<?>[] par = ((MethodSignature) joinPoint.getSignature()).getParameterTypes(); // 获取目标对象方法 Method objMethod = classTarget.getMethod(methodName, par); // 判断该目标方法上是否有加上自定义事务注解 ExtTransactional extTransactional = objMethod.getDeclaredAnnotation(ExtTransactional.class); if (extTransactional == null) { return joinPoint.proceed();// 执行目标方法 } TransactionStatus begin = transactionalUtils.begin(); try { System.out.println(">>>>环绕通知之前执行...>>>>>>"); Object proceed = joinPoint.proceed();// 执行目标方案 System.out.println(">>>>环绕通知之后执行...>>>>>>"); transactionalUtils.commit(begin); return proceed; } catch (Exception e) { // 目标方法抛出异常的情况下 回滚当前事务 transactionalUtils.rollback(begin); return 0; } } }

@Target({ElementType.METHOD, ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface ExtTransactional { }

@ExtTransactional public int addOrderInfo(int j) { int i = orderInfoMapper.addOrderInfo(); return i; }

注意的问题 如果在service 层 抛出异常的情况下 最好使用 TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

本文参考：

蚂蚁课堂：http://www.mayikt.com/