spring03

作者: 冷森森 | 来源:发表于2020-12-12 20:22 被阅读0次

基于动态代理改造上限案例

掌握Spring AOP 基于配置文件方式

掌握Spring AOP 基于注解方式

重点掌握:Spring AOP 基于XML和注解方式

全称是Aspect Oriented Programming即:面向切面编程

1.1.2 AOP的作用及优势

作用:

在程序运行期间,不修改源码对已有方法进行增强。

优势:

减少重复代码

提高开发效率

维护方便

我们可以想办法让上面4个链接对象合并成一个链接对象,然后类似JDBC代码一样,手动控制事务,实现让业务层来控制事务的提交和回滚。

创建ConnectionUtil,用于实现数据库连接管理

public class ConnectionUtil {

    //线程本地变量

    private  ThreadLocal<Connection> tl = new ThreadLocal<Connection>();

    private DataSource dataSource;

    //注入DataSource

    public void setDataSource(DataSource dataSource) {

        this.dataSource = dataSource;

    }

    /**

    * 获取当前线程上绑定的连接

    * @return

    */

    public Connection getThreadConnection() {

        try {

            //1.先看看线程上是否绑了

            Connection conn = tl.get();

            if(conn == null) {

                //2.从数据源中获取一个连接

                conn = dataSource.getConnection();

                //3.和线程局部变量绑定

                tl.set(conn);

            }

            //4.返回线程上的连接

            return tl.get();

        } catch (SQLException e) {

            throw new RuntimeException(e);

        }

    }

    /**

    * 把连接和当前线程解绑

    */

    public void remove() {

        tl.remove();

    }

}

创建TransactionManager,实现事务的管理控制

public class TransactionManager {

    private ConnectionUtil connectionUtil;

    //数据库连接管理注入

    public void setConnectionUtil(ConnectionUtil connectionUtil) {

        this.connectionUtil = connectionUtil;

    }

    //开启事务

    public void beginTransaction() {

        //从当前线程上获取连接,实现开启事务

        try {

            connectionUtil.getThreadConnection().setAutoCommit(false);

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    //提交事务

    public void commit() {

        try {

            connectionUtil.getThreadConnection().commit();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    //回滚事务

    public void rollback() {

        try {

            connectionUtil.getThreadConnection().rollback();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    //释放连接

    public void release() {

        try {

            //关闭连接(还回池中)

            connectionUtil.getThreadConnection().close();

            //解绑线程:把连接和线程解绑

            connectionUtil.remove();

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

}

public class AccountDaoImpl implements AccountDao {

    //注入进来

    private QueryRunner runner;

    //注入数据库连接对象

    private ConnectionUtil connectionUtil;

    //提供注入

    public void setRunner(QueryRunner runner) {

        this.runner = runner;

    }

    public void setConnectionUtil(ConnectionUtil connectionUtil) {

        this.connectionUtil = connectionUtil;

    }

    /**

    * 修改操作

    * @param account:账号数据

    */

    @Override

    public void update(Account account) {

        try {

            runner.update(connectionUtil.getThreadConnection(),"update account set name=?,money=? where id=?",account.getName(),account.getMoney(),account.getId());

        } catch (SQLException e) {

            e.printStackTrace();

        }

    }

    /***

    * 根据名字查找账号信息

    * @param numberName:账号名字

    * @return

    */

    @Override

    public Account findByName(String numberName) {

        try {

            return runner.query(connectionUtil.getThreadConnection(),"select * from account where name=?",new BeanHandler<Account>(Account.class),numberName);

        } catch (SQLException e) {

            throw new RuntimeException(e);

        }

    }

}

public class AccountServiceImpl implements AccountService {

    //注入AccountDao

    private AccountDao accountDao;

    //注入事务管理器

    private TransactionManager txManager;

    //提供注入

    public void setAccountDao(AccountDao accountDao) {

        this.accountDao = accountDao;

    }

    public void setTxManager(TransactionManager txManager) {

        this.txManager = txManager;

    }

    /***

    * 转账操作

    * @param sourceName:转出账户名

    * @param targetName:转入账户名

    * @param money:转账金额

    */

    @Override

    public void transfer(String sourceName, String targetName, Float money) {

        try {

            //开启事务

            txManager.beginTransaction();

            //根据名称查询两个账户信息

            Account source = accountDao.findByName(sourceName);

            Account target = accountDao.findByName(targetName);

            //转出账户减钱,转入账户加钱

            source.setMoney(source.getMoney()-money);

            target.setMoney(target.getMoney()+money);

            //更新两个账户

            accountDao.update(source);

            accountDao.update(target);

            //提交事务

            txManager.commit();

        } catch (Exception e) {

            //事务回滚

            txManager.rollback();

            e.printStackTrace();

        }finally {

            //关闭资源

            txManager.release();

        }

    }

}

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!--

        Dao

    -->

    <bean id="accountDao" class="com.oppo.dao.impl.AccountDaoImpl">

        <!--注入QueryRunner对象  必须有set方法-->

        <property name="runner" ref="runner" />

        <!--注入数据库连接对象-->

        <property name="connectionUtil" ref="connectionUtil" />

    </bean>

    <!--

        Service

    -->

    <bean id="accountService" class="com.oppo.service.impl.AccountServiceImpl">

        <!--注入dao  必须有set方法-->

        <property name="accountDao" ref="accountDao" />

        <!--注入事务管理器-->

        <property name="txManager" ref="txManager" />

    </bean>

    <!--

        QueryRunner对象

    -->

    <bean id="runner" class="org.apache.commons.dbutils.QueryRunner">

        <!--带参构造函数注入-->

        <constructor-arg name="ds" ref="dataSource" />

    </bean>

    <!--

        创建DataSource

    -->

    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">

        <property name="driverClass" value="com.mysql.jdbc.Driver" />

        <property name="jdbcUrl" value="jdbc:mysql://127.0.0.1:3306/spring5" />

        <property name="user" value="root" />

        <property name="password" value="123456" />

    </bean>

    <!--数据库连接对象-->

    <bean id="connectionUtil" class="com.oppo.util.ConnectionUtil">

        <property name="dataSource" ref="dataSource" />

    </bean>

    <!--事务管理器-->

    <bean id="txManager" class="com.oppo.util.TransactionManager">

        <property name="connectionUtil" ref="connectionUtil" />

    </bean>

</beans>

上一小节的代码,通过对业务层改造,已经可以实现事务控制了,但是由于我们添加了事务控制,也产生了一个新的问题:

业务层方法变得臃肿了,里面充斥着很多重复代码。并且业务层方法和事务控制方法耦合了。

试想一下,如果我们此时提交,回滚,释放资源中任何一个方法名变更,都需要修改业务层的代码,况且这还只是一个业务层实现类,而实际的项目中这种业务层实现类可能有十几个甚至几十个。

 动态代理回顾

1.2.4.1 动态代理的特点

字节码随用随创建,随用随加载。

它与静态代理的区别也在于此。因为静态代理是字节码一上来就创建好,并完成加载。

装饰者模式就是静态代理的一种体现。

动态代理常用的有两种方式

基于接口的动态代理    提供者:JDK官方的Proxy类。    要求:被代理类最少实现一个接口。基于子类的动态代理    提供者:第三方的CGLib,如果报asmxxxx异常,需要导入asm.jar。    要求:被代理类不能用final修饰的类(最终类)。

cglibcglib2.1_3

AOP相关术语

Joinpoint(连接点):

所谓连接点是指那些被拦截到的点。在spring中,这些点指的是方法,因为spring只支持方法类型的连接点。

Pointcut(切入点):

所谓切入点是指我们要对哪些Joinpoint进行拦截的定义。

Advice(通知/增强):

所谓通知是指拦截到Joinpoint之后所要做的事情就是通知。

通知的类型:前置通知,后置通知,异常通知,最终通知,环绕通知。

Introduction(引介):

引介是一种特殊的通知在不修改类代码的前提下, Introduction可以在运行期为类动态地添加一些方法或Field。

Target(目标对象):

代理的目标对象。

Weaving(织入):

是指把增强应用到目标对象来创建新的代理对象的过程。

spring采用动态代理织入,而AspectJ采用编译期织入和类装载期织入。

Proxy(代理):

一个类被AOP织入增强后,就产生一个结果代理类。

Aspect(切面):

是切入点和通知(引介)的结合。

a、开发阶段(我们做的)

编写核心业务代码(开发主线):大部分程序员来做,要求熟悉业务需求。

把公用代码抽取出来,制作成通知。(开发阶段最后再做):AOP编程人员来做。

在配置文件中,声明切入点与通知间的关系,即切面。:AOP编程人员来做。

b、运行阶段(Spring框架完成的)

Spring框架监控切入点方法的执行。一旦监控到切入点方法被运行,使用代理机制,动态创建目标对象的代理对象,根据通知类别,在代理对象的对应位置,将通知对应的功能织入,完成完整的代码逻辑运行。

在spring中,框架会根据目标类是否实现了接口来决定采用哪种动态代理的方式。

示例:我们在学习spring的aop时,采用输出日志作为示例。在业务层方法执行的前后,加入日志的输出。并且把spring的ioc也一起应用进来。

<dependencies>

  <dependency>

  <groupId>org.springframework</groupId>

  <artifactId>spring-context</artifactId>

  <version>5.0.2.RELEASE</version>

  </dependency>

  <dependency>

  <groupId>org.aspectj</groupId>

  <artifactId>aspectjweaver</artifactId>

  <version>1.8.7</version>

  </dependency>

  </dependencies>

<!--

aop的配置步骤:

第一步:把通知类的创建也交给spring来管理

第二步:使用aop:config标签开始aop的配置

第三步:使用aop:aspect标签开始配置切面,写在aop:config标签内部

id属性:给切面提供一个唯一标识

ref属性:用于引用通知bean的id。

第四步:使用对应的标签在aop:aspect标签内部配置通知的类型

使用aop:befored标签配置前置通知,写在aop:aspect标签内部

method属性:用于指定通知类中哪个方法是前置通知

pointcut属性:用于指定切入点表达式。

切入点表达式写法:

关键字:execution(表达式)

表达式内容:

全匹配标准写法:

访问修饰符  返回值  包名.包名.包名...类名.方法名(参数列表)

例如:

public void com.oppo.service.impl.AccountServiceImpl.saveAccount()

-->

<!-- 配置通知类 -->

<bean id="logger" class="com.oppo.utils.Logger"></bean>

<!-- 配置aop -->

<aop:config>

<!-- 配置切面 -->

<aop:aspect id="logAdvice" ref="logger">

<!-- 配置前置通知 -->

<aop:before method="printLog" pointcut="execution( * com.oppo.service.impl.*.*(..))"/>

</aop:aspect>

</aop:config>

<!-- 配置通知类 -->

<bean id="logger" class="com.oppo.utils.Logger"></bean>

<!-- 配置aop -->

<aop:config>

<!-- 配置切面 -->

<aop:aspect id="logAdvice" ref="logger">

<!-- 配置前置通知 -->

<aop:before method="printLog" pointcut="execution( * com.oppo.service.impl.*.*(..))"/>

</aop:aspect>

</aop:config>

execution:匹配方法的执行(常用)

execution(表达式)

表达式语法:execution([修饰符] 返回值类型 包名.类名.方法名(参数))

写法说明:

全匹配方式:

public void com.oppo.service.impl.AccountServiceImpl.saveAccount(com.oppo.domain.Account)

访问修饰符可以省略

void com.oppo.service.impl.AccountServiceImpl.saveAccount(com.oppo.domain.Account)

返回值可以使用*号,表示任意返回值

* com.oppo.service.impl.AccountServiceImpl.saveAccount(com.oppo.domain.Account)

包名可以使用*号,表示任意包,但是有几级包,需要写几个*

* *.*.*.*.AccountServiceImpl.saveAccount(com.oppo.domain.Account)

使用..来表示当前包,及其子包

* com..AccountServiceImpl.saveAccount(com.oppo.domain.Account)

类名可以使用*号,表示任意类

* com..*.saveAccount(com.oppo.domain.Account)

方法名可以使用*号,表示任意方法

* com..*.*( com.oppo.domain.Account)

参数列表可以使用*,表示参数可以是任意数据类型,但是必须有参数

* com..*.*(*)

参数列表可以使用..表示有无参数均可,有参数可以是任意类型

* com..*.*(..)

全通配方式:

* *..*.*(..)

注:

通常情况下,我们都是对业务层的方法进行增强,所以切入点表达式都是切到业务层实现类。

execution(* com.oppo.service.impl.*.*(..))

aop:config:

    作用:用于声明开始aop的配置

<aop:config>

    <!-- 配置的代码都写在此处 -->   

</aop:config>

aop:aspect:

    作用:

      用于配置切面。

    属性:

      id:给切面提供一个唯一标识。

      ref:引用配置好的通知类bean的id。

<aop:aspect id="logAdvice" ref="logger">

      <!--配置通知的类型要写在此处-->

</aop:aspect>

aop:aspect:

    作用:

      用于配置切面。

    属性:

      id:给切面提供一个唯一标识。

      ref:引用配置好的通知类bean的id。

<aop:aspect id="logAdvice" ref="logger">

      <!--配置通知的类型要写在此处-->

</aop:aspect>

aop:pointcut:

作用:

用于配置切入点表达式。就是指定对哪些类的哪些方法进行增强。

属性:

expression:用于定义切入点表达式。

id:用于给切入点表达式提供一个唯一标识

<aop:pointcut expression="execution(* com.itheima.service.impl.*.*(..))" id="pt1"/>

aop:before

作用:

用于配置前置通知。指定增强的方法在切入点方法之前执行

属性:

method:用于指定通知类中的增强方法名称

ponitcut-ref:用于指定切入点的表达式的引用

poinitcut:用于指定切入点表达式

执行时间点:

切入点方法执行之前执行

<aop:before method="beginPrintLog" pointcut-ref="pt1"/>

aop:after-returning

作用:

用于配置后置通知

属性:

method:指定通知中方法的名称。

pointct:定义切入点表达式

pointcut-ref:指定切入点表达式的引用

执行时间点:

切入点方法正常执行之后。它和异常通知只能有一个执行

<aop:after-returning method="afterReturningPrintLog" pointcut-ref="pt1"/>

aop:after-throwing

作用:

用于配置异常通知

属性:

method:指定通知中方法的名称。

pointct:定义切入点表达式

pointcut-ref:指定切入点表达式的引用

执行时间点:

切入点方法执行产生异常后执行。它和后置通知只能执行一个

<aop:after-throwing method="afterThrowingPringLog" pointcut-ref="pt1"/>

aop:after

作用:

用于配置最终通知

属性:

method:指定通知中方法的名称。

pointct:定义切入点表达式

pointcut-ref:指定切入点表达式的引用

执行时间点:

无论切入点方法执行时是否有异常,它都会在其后面执行。

<aop:after method="afterPringLog" pointcut-ref="pt1"/>

环绕通知

配置方式:

<aop:config>

<aop:pointcut expression="execution(* com.itheima.service.impl.*.*(..))" id="pt1"/>

<aop:aspect id="txAdvice" ref="txManager">

<!-- 配置环绕通知 -->

<aop:around method="transactionAround" pointcut-ref="pt1"/>

</aop:aspect>

</aop:config>

aop:around:

作用:

用于配置环绕通知

属性:

method:指定通知中方法的名称。

pointct:定义切入点表达式

pointcut-ref:指定切入点表达式的引用

说明:

它是spring框架为我们提供的一种可以在代码中手动控制增强代码什么时候执行的方式。

注意:

通常情况下,环绕通知都是独立使用的

/**

* 环绕通知

* 问题:

* 当配置完环绕通知之后,没有业务层方法执行(切入点方法执行)

* 分析:

*  通过动态代理的代码分析,我们现在的环绕通知没有明确的切入点方法调用

* 解决:

* spring框架为我们提供了一个接口,该接口可以作为环绕通知的方法参数来使用

* ProceedingJoinPoint。当环绕通知执行时,spring框架会为我们注入该接口的实现类。

*  它有一个方法proceed(),就相当于invoke,明确的业务层方法调用

*  spring的环绕通知:

*  它是spring为我们提供的一种可以在代码中手动控制增强方法何时执行的方式。

*/

public void aroundPrintLog(ProceedingJoinPoint pjp) {

try {

System.out.println("前置Logger类中的aroundPrintLog方法开始记录日志了");

pjp.proceed();//明确的方法调用

System.out.println("后置Logger类中的aroundPrintLog方法开始记录日志了");

} catch (Throwable e) {

System.out.println("异常Logger类中的aroundPrintLog方法开始记录日志了");

e.printStackTrace();

}finally {

System.out.println("最终Logger类中的aroundPrintLog方法开始记录日志了");

}

}

基于注解的AOP配置

把通知类也使用注解配置

/**

* 模拟一个用于记录日志的工具类

*/

@Component("logger")

public class Logger {

}

作用:

把当前类声明为切面类。

/**

* 模拟一个用于记录日志的工具类

*/

@Component("logger")

@Aspect//表示当前类是一个切面类

public class Logger {}

使用注解配置通知类型

@Before

作用:

把当前方法看成是前置通知。

属性:

value:用于指定切入点表达式,还可以指定切入点表达式的引用。

/**

* 前置通知

*/

@Before("execution(* com.oppo.service.impl.*.*(..))")

public void beforePrintLog() {

System.out.println("前置通知:Logger类中的beforePrintLog方法开始记录日志了。。。");

}

@AfterReturning

作用:

把当前方法看成是后置通知。

属性:

value:用于指定切入点表达式,还可以指定切入点表达式的引用

/**

* 后置通知

*/

@AfterReturning("execution(* com.oppo.service.impl.*.*(..))")

public void afterReturningPrintLog() {

System.out.println("后置通知:Logger类中的afterReturningPrintLog方法开始记录日志了。。。");

}

@AfterThrowing

作用:

把当前方法看成是异常通知。

属性:

value:用于指定切入点表达式,还可以指定切入点表达式的引用

/**

* 异常通知

*/

@AfterThrowing("execution(* com.oppo.service.impl.*.*(..))")

public void afterThrowingPrintLog() {

System.out.println("异常通知:Logger类中的afterThrowingPrintLog方法开始记录日志了。。。");

}

@After

作用:

把当前方法看成是最终通知。

属性:

value:用于指定切入点表达式,还可以指定切入点表达式的引用

/**

* 最终通知

*/

@After("execution(* com.oppo.service.impl.*.*(..))")

public void afterPrintLog() {

System.out.println("最终通知:Logger类中的afterPrintLog方法开始记录日志了。。。");

}

2.3.7 第四步:在spring配置文件中开启spring对注解AOP的支持

<!-- 开启spring对注解AOP的支持 -->

<aop:aspectj-autoproxy/>

2.3.8 环绕通知注解配置

@Around

作用:

把当前方法看成是环绕通知。

属性:

value:用于指定切入点表达式,还可以指定切入点表达式的引用。

/**

* 环绕通知

* 问题:

* 当配置完环绕通知之后,没有业务层方法执行(切入点方法执行)

* 分析:

*  通过动态代理的代码分析,我们现在的环绕通知没有明确的切入点方法调用

* 解决:

* spring框架为我们提供了一个接口,该接口可以作为环绕通知的方法参数来使用

* ProceedingJoinPoint。当环绕通知执行时,spring框架会为我们注入该接口的实现类。

*  它有一个方法proceed(),就相当于invoke,明确的业务层方法调用

*  spring的环绕通知:

*  它是spring为我们提供的一种可以在代码中手动控制增强方法何时执行的方式。

*/

@Around("execution(* com.oppo.service.impl.*.*(..))")

public void aroundPrintLog(ProceedingJoinPoint pjp) {

try {

System.out.println("前置Logger类中的aroundPrintLog方法开始记录日志了");

pjp.proceed();//明确的方法调用

System.out.println("后置Logger类中的aroundPrintLog方法开始记录日志了");

} catch (Throwable e) {

System.out.println("异常Logger类中的aroundPrintLog方法开始记录日志了");

e.printStackTrace();

}finally {

System.out.println("最终Logger类中的aroundPrintLog方法开始记录日志了");

}

}

2.3.9 切入点表达式注解

@Pointcut

作用:

指定切入点表达式

属性:

value:指定表达式的内容

@Pointcut("execution(* com.oppo.service.impl.*.*(..))")

private void pt1() {}

引用方式:

/**

* 环绕通知

* @param pjp

* @return

*/

@Around("pt1()")//注意:千万别忘了写括号

public void aroundPrintLog(ProceedingJoinPoint pjp) {

}

2.3.10 不使用XML的配置方式

@Configuration

@ComponentScan(basePackages="com.oppo")

@EnableAspectJAutoProxy

public class SpringConfiguration {

}

相关文章

  • Spring03

    proxy代理 当我们某个功能需要加强的时候我们可以通过proxy代理来加强 案例: 步骤1:在com.hello...

  • spring03

    基于动态代理改造上限案例 掌握Spring AOP 基于配置文件方式 掌握Spring AOP 基于注解方式 重点...

  • spring03

    依赖注入回顾 连接池应用 1. dbcp使用 引入dbcp和驱动jar包。然后在Spring中添加下面配置:

  • Spring03——有关于 Spring AOP 的总结

    本文将为各位带来 Spring 的另一个重点知识点 —— Spring AOP。关注我的公众号「Java面典」,每...

网友评论

      本文标题:spring03

      本文链接:https://www.haomeiwen.com/subject/bssygktx.html