文档章节

Spring5.0源码深度解析之SpringBean的Aop的使用

须臾之余
 须臾之余
发布于 07/29 14:42
字数 1095
阅读 28
收藏 0

SpringAOP

什么是Aop编程

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

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

Spring的AOP

前置通知

后置通知

环绕通知

运行通知

异常通知

Aop编程底层的原理

动态代理技术

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

基于注解方式启动Aop

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.0.5.RELEASE</version>
    </dependency>
    <dependency>
        <groupId>org.aspectj</groupId>
        <artifactId>aspectjweaver</artifactId>
        <version>1.8.13</version>
    </dependency>
</dependencies>

日志AOP

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

    }
    @Before("logAop()")
    public void doBefor(){
        System.out.println("前置通知....在调用方法之前拦截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在调用方法之后拦截");
    }
}

Config

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

service

@Component
public class OrderService {

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

启动类

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(){

    }
    @Before("logAop()")
    public void doBefore(){
        System.out.println("前置通知....在调用方法之前拦截");
    }
    @After("logAop()")
    public void doAfter(){
        System.out.println("后置通知....在调用方法之后拦截");
    }
    @AfterReturning("logAop()")
    public void  around(JoinPoint joinpoint) throws Throwable {
        String name = joinpoint.getSignature().getName();
        System.out.println("返回通知...."+name);
    }
    @AfterThrowing("logAop()")
    public void afterThrowing(JoinPoint joinPoint) {
        System.out.println("异常通知....");
    }
    @Around("logAop()")
    public void doAround(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("环绕通知,在目标方法之前处理....");
        joinPoint.proceed();//执行目标方法
        System.out.println("环绕通知,在目标方法之后处理....");
    }
}

打印结果

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

springBoot手动事务实现方式

手动begin commit rollback

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

    public TransactionStatus begin() {
        TransactionStatus transaction = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
        System.out.println("获取当前的事务>>>>>");
        return transaction;
    }
    /**
     * 提交事务
     */
    public void commit(TransactionStatus transactionStatus) {
        System.out.println("提交当前的事务>>>>>");
        dataSourceTransactionManager.commit(transactionStatus);
    }
    public void rollback(TransactionStatus transactionStatus) {
        System.out.println("回滚当前的事务>>>>>");
        dataSourceTransactionManager.rollback(transactionStatus);
    }
}
@Service
public class OrderService {
    @Autowired
    private OrderInfoMapper orderInfoMapper;
    @Autowired
    private TransactionalUtils transactionalUtils;


        public int addOrderInfo(int j) {
        TransactionStatus begin = transactionalUtils.begin();
        try {
            int i = orderInfoMapper.addOrderInfo();
            int result = 1 / j;
            transactionalUtils.commit(begin);
        } catch (Exception e) {
            e.printStackTrace();
            transactionalUtils.rollback(begin);
        }
        return 1;
    }

手动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/

© 著作权归作者所有

须臾之余
粉丝 126
博文 68
码字总数 178724
作品 0
吉安
程序员
私信 提问
Spring5对比Spring3.2源码之容器的基本实现

最近看了《Spring源码深度解析》,该书是基于Spring3.2版本的,其中关于第二章容器的基本实现部分,目前spring5的实现方式已有较大改变。 Spring3.2的实现: 容器的基础XmlBeanFactory已经被...

Ilike_Java
2018/10/17
145
0
dubbo源码理解(1)启动初始化与bean加载

今天看了一些博文,都是关于dubbo源码解析方面的。觉得有必要记一下。 问题1:spring 如何注入dubbo 的?或者说怎么集成dubbo 的,或者说 dubbo启动时怎么启动spring的? 1、首先想要实现 在...

明瞐
2018/10/13
232
0
聊聊Dubbo - Dubbo可扩展机制源码解析

摘要: 在Dubbo可扩展机制实战中,我们了解了Dubbo扩展机制的一些概念,初探了Dubbo中LoadBalance的实现,并自己实现了一个LoadBalance。是不是觉得Dubbo的扩展机制很不错呀,接下来,我们就...

阿里云云栖社区
2018/06/05
1K
0
Spring 源码分析(三) —— AOP(二)Spring AOP 整体架构

Spring AOP 架构 先是生成代理对象,然后是拦截器的作用,最后是编织的具体实现。这是AOP实现的三个步骤,当然Spring AOP也是一样。 而从Spring AOP整体架构上看,其核心都是建立在代理上的。...

水门-kay
2016/03/08
2.7K
2
Spring源码分析之AOP解析

作者: 一字马胡 转载标志 【2018-02-02】 更新日志 日期 更新内容 备注 2018-02-02 创建分析文档 Spring源码分析系列文章(三) 前言 本文是Spring源码分析系列的第三篇文章,前两篇文章分别...

一字马胡
2018/01/02
0
0

没有更多内容

加载失败,请刷新页面

加载更多

PCB设计-Allegro软件入门系列-铺铜操作(下)

铺铜是PCB很常见的操作,PCB的敷铜一般都是覆地铜,增大地线面积,有利于地线阻抗降低,使电源和信号传输稳定,在高频的信号线附近敷铜,可大大减少电磁辐射干扰,起屏蔽作用。 本讲讲解啊一...

demyar
4分钟前
1
0
如何通过WASI SDK 在Linux上编译ZXing C++

Mozilla在今年三月份的时候公布了WASI。WASI的目标就是让WebAssembly在任何地方都可以运行,而不仅仅像现在这样只能运行在Node.js和Web浏览器中。WASI目前依然处于初级阶段,这篇文章分享下如...

yushulx
6分钟前
1
0
.Net界面开发神器—DevExpress官方汉化包免费下载!还在等什么?

点击获取DevExpress v19.1.7新版试用下载 DevExpress Localization Service允许您创建一组自定义的附属程序集,要将语言包添加到程序集中,请查看本文中为大家列出的对应版本的汉化包,下载并...

FILA6666
6分钟前
2
0
php生成二维码

        header('Content-Type: image/png');        //清除缓冲区,防止之前面不知道的情况下被加头部信息导致不显示图片内容        ob_clean();        $...

横着走的螃蟹
11分钟前
2
0
伪类和伪元素

伪类和伪元素 伪类和伪元素,对于绝大多数同学来说,都是耳熟能详的名字,但确实又有很多人搞不清楚它们之间的区别,以致于混淆概念。而当概念都混淆的时候,也往往意味着你不会经常使用它,...

不负好时光
14分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部