03【Spring AOP、CGBLIB代理】

news2024/11/24 12:24:29

文章目录

  • 03【Spring AOP、CGBLIB代理】
  • 一、AOP前奏
    • 1.1 案例
      • 1.1.1 需求设计
      • 1.1.2 需求修改
      • 1.1.3 需求增加
      • 1.1.4 分析存在的问题
    • 1.2 动态代理
      • 1.2.1 定义接口:
      • 1.2.2 日志代理类
      • 1.2.3 缓存代理类:
      • 1.2.4 测试类
  • 二、AOP
    • 2.1 AOP 概述
      • 2.1.1 纵向编程
      • 2.1.2 纵横配合的编程
    • 2.2 AOP相关语术
      • 2.2.1 Joinpoint(连接点):
      • 2.2.2 Pointcut(切入点):
      • 2.2.3 Advice(通知):
      • 2.2.4 target(目标对象):
      • 2.2.5 Weaving(织入):
      • 2.2.6 Proxy(代理):
      • 2.2.7 Aspect(切面):
  • 三、Spring中的AOP
    • 3.1 AspectJ
    • 3.2 切入点表达式
    • 3.3 基于XML配置AOP
      • 3.1.1 搭建环境
      • 3.1.2 目标对象
      • 3.1.3 切面类
      • 3.1.4 Spring配置
      • 3.1.5 通知执行顺序
      • 3.1.6 AOP相关API
        • 1)ProceedingJoinPoint类
        • 2)Signature类
    • 3.4 使用注解配置切面
        • 1)xml和注解搭配使用
        • 2)纯注解配置
    • 3.5 多切面配置
    • 3.6 使用AOP完成案例
  • 四、CGLIB代理
    • 4.1 CGLIB代理的使用
    • 4.2 AOP与GBLIB代理

03【Spring AOP、CGBLIB代理】

一、AOP前奏

1.1 案例

1.1.1 需求设计

  • 需求:设计一个用户类,提供增删改查功能,在每次增删改查前后都需要记录日志
package com.dfbz.dao;

import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class UserDao {

    public void save() {
        System.out.println("执行【save】操作 begin...,时间:【" + new Date() + "】");
        System.out.println("新增用户成功...");
        System.out.println("执行【save】操作 end...,时间:【" + new Date() + "】");
    }

    public void delete() {
        System.out.println("执行【delete】操作 begin...,时间:【" + new Date() + "】");
        System.out.println("删除用户成功...");
        System.out.println("执行【delete】操作 end...,时间:【" + new Date() + "】");
    }

    public void update() {
        System.out.println("执行【update】操作 begin...,时间:【" + new Date() + "】");
        System.out.println("修改用户成功...");
        System.out.println("执行【update】操作 end...,时间:【" + new Date() + "】");
    }

    public void query() {
        System.out.println("执行【query】操作 begin...,时间:【" + new Date() + "】");
        System.out.println("查询用户成功...");
        System.out.println("执行【query】操作 end...,时间:【" + new Date() + "】");
    }
}
  • 执行测试:
package com.dfbz.test;

import com.dfbz.dao.UserDao;
import org.junit.Test;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class Demo01 {

    @Test
    public void test1() {
        UserDao userDao=new UserDao();
        userDao.save();
    }
}

执行效果:

在这里插入图片描述

1.1.2 需求修改

需求修改如下:修改日志时间格式为yyyy-MM-dd hh:mm:ss

  • UserDao:
package com.dfbz.dao;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class UserDao {
    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    public void save() {
        System.out.println("执行【save】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("新增用户成功...");
        System.out.println("执行【save】操作 end...,时间:【" + sdf.format(new Date()) + "】");
    }

    public void delete() {
        System.out.println("执行【delete】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("删除用户成功...");
        System.out.println("执行【delete】操作 end...,时间:【" + sdf.format(new Date()) + "】");
    }

    public void update() {
        System.out.println("执行【update】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("修改用户成功...");
        System.out.println("执行【update】操作 end...,时间:【" + sdf.format(new Date()) + "】");
    }

    public void query() {
        System.out.println("执行【query】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("查询用户成功...");
        System.out.println("执行【query】操作 end...,时间:【" + sdf.format(new Date()) + "】");
    }
}

执行测试类:

在这里插入图片描述

1.1.3 需求增加

需求增加:在查询操作执行之后存入缓存,增、删、改操作时清除缓存;

  • UserDao:
package com.dfbz.dao;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class UserDao {
    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    public void save() {
        System.out.println("执行【save】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("新增用户成功...");
        System.out.println("执行【save】操作 end...,时间:【" + sdf.format(new Date()) + "】");

        System.out.println("清除缓存成功...");
    }

    public void delete() {
        System.out.println("执行【delete】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("删除用户成功...");
        System.out.println("执行【delete】操作 end...,时间:【" + sdf.format(new Date()) + "】");

        System.out.println("清除缓存成功...");
    }

    public void update() {
        System.out.println("执行【update】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("修改用户成功...");
        System.out.println("执行【update】操作 end...,时间:【" + sdf.format(new Date()) + "】");

        System.out.println("清除缓存成功...");
    }

    public void query() {
        System.out.println("执行【query】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
        System.out.println("查询用户成功...");
        System.out.println("执行【query】操作 end...,时间:【" + sdf.format(new Date()) + "】");

        System.out.println("存入缓存成功...");
    }
}

执行测试类:

在这里插入图片描述

1.1.4 分析存在的问题

  • 职责不明确:我们仔细观察会发现,我们的某个方法执行的功能非常多(耦合性高,内聚性低),不相关的功能也存在方法中,甚至不相关的功能代码多余核心代码;

在这里插入图片描述

  • 代码非常冗余:以日志需求为例,只是为了满足这个单一需求,就不得不在多个模块(方法)里多次重复相同的日志代码。如果日志需求发生变化,必须修改所有模块。

在这里插入图片描述

1.2 动态代理

针对上面的问题,我们可以使用之前学过的动态代理来解决这个问题;

1.2.1 定义接口:

  • UserDaoInterface:
package com.dfbz.dao;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public interface UserDaoInterface {

    // 新增
    void save();

    // 删除
    void delete();

    // 修改
    void update();

    // 查询
    void query();
}

UserDao实现UserDaoInterface接口:

在这里插入图片描述

1.2.2 日志代理类

  • LoggerHandler:
package handler;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro: 日志处理器,执行增删改查操作时记录日志
 */
public class LoggerHandler implements InvocationHandler {


    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    // 目标对象
    private Object target;

    public LoggerHandler (Object target){
        this.target=target;
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

        System.out.println("执行【" + method.getName() + "】操作 begin...,时间:【" + sdf.format(new Date()) + "】");

        // 执行目标方法并获取目标方法的返回值
        Object returnVal = method.invoke(target, args);

        System.out.println("执行【" + method.getName() + "】操作 end...,时间:【" + sdf.format(new Date()) + "】");
        return returnVal;
    }
}

1.2.3 缓存代理类:

package handler;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro: 缓存处理器: 当执行query方法时存入缓存;执行save/update/delete方法时清除缓存;
 */
public class CacheHandler implements InvocationHandler {


    // 目标对象
    private Object target;

    public CacheHandler(Object target) {
        this.target = target;
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

        // 执行目标方法并获取目标方法的返回值
        Object returnVal = method.invoke(target, args);

        // 获取要执行的方法名称
        String methodName = method.getName();
        if (
                "save".equals(methodName) ||
                        "update".equals(methodName) ||
                        "delete".equals(methodName)

        ) {
            System.out.println("清除缓存成功...");
        } else if ("query".equals(methodName)) {
            System.out.println("存入缓存成功...");
        }

        return returnVal;
    }
}

1.2.4 测试类

@Test
public void test2() {

    // 针对日志功能的增强(具备日志功能)
    UserDaoInterface userDaoLoggerProxy = (UserDaoInterface) Proxy.newProxyInstance(
            Demo01.class.getClassLoader(),
            UserDao.class.getInterfaces(),
            new LoggerHandler(new UserDao())
    );

    // 具备日志功能,不具备缓存功能
    userDaoLoggerProxy.query();

    System.out.println("-----------------");
    // 针对缓存功能的增强
    UserDaoInterface userDaoCacheProxy = (UserDaoInterface) Proxy.newProxyInstance(
            Demo01.class.getClassLoader(),
            UserDao.class.getInterfaces(),
            new CacheHandler(userDaoLoggerProxy)        // 传入已经进行日志增强的代理类,继续代理加强缓存相关功能
    );

    // 具备日志和缓存功能
    userDaoCacheProxy.query();
}

执行效果:

在这里插入图片描述

二、AOP

2.1 AOP 概述

AOP(Aspect Oriented Programming),即面向切面编程。通过预编译方式和运行期动态代理实现程序功能的统一维护的一种技术。AOP是OOP的延续,是软件系统开发中的一个热点,也是Spring框架的一个重点。利用AOP可以实现业务逻辑各个部分的隔离,从而使得业务逻辑各个部分的耦合性降低,提高程序的可重用性,同时提高开发效率。

2.1.1 纵向编程

在这里插入图片描述

2.1.2 纵横配合的编程

面向切面的意思简单来说就是:纵向重复,横向抽取,在我们的业务中间切一刀来填充我们的增强代码;

在这里插入图片描述

AOP编程操作的主要对象是切面(aspect),而切面模块化横切关注点(需要增强的方法)。

2.2 AOP相关语术

2.2.1 Joinpoint(连接点):

  • 连接点:在程序执行过程中,需要拦截的方法;
  • 根据规则,可以指定拦截的方法,我们将每一个被拦截的方法称为连接点。如:UserService中的save()方法就是连接点

2.2.2 Pointcut(切入点):

  • 切入点:就是拦截方法设置的规则,连接点的一系列集合
  • 所谓切入点是指我们要对哪些Joinpoint进行拦截的定义,比如我们刚刚的的案例中,save/delete/update/query这些都是我们需要增强的方法,这些方法也是我们刚刚说的连接点,我们需要通过一个表达式把这些需要增强的方法找出来,通过这个表达式查找出来的一批方法就称为切入点;

2.2.3 Advice(通知):

  • 通知:增强连接点的实现代码(就是需要为连接点绑定的方法)
  • 所谓通知是指拦截到Joinpoint之后所要做的事情(增强的代码)就是通知

由于执行代码的时机不同,比如我们刚刚的日志增强代码在执行目标对象方法前后都需要执行,缓存代码则是在执行目标对象之后才执行。因此通知也被化分为了很多种类型:

  • 前置通知(Before):执行连接点方法之前执行
  • 环绕通知(Around):环绕连接点方法执行
  • 后置通知(After):执行连接点方法之后执行
  • 返回通知(After Running):在连接点方法返回结果之后执行,如果方法出现异常则不会执行此通知(通常是最后执行)
  • 异常通知(After Throwing):在连接点方法抛出异常之后执行

2.2.4 target(目标对象):

  • 目标对象:被代理对象,连接点的所属方法,也就是需要增强的方法

2.2.5 Weaving(织入):

  • 织入:与前面的语术不一样,织入是个动词,指的是将通知(增强的代码)应用到切入点(需要增强的方法)形成切面的过程,在具体应用中作用不大,我们了解即可;

2.2.6 Proxy(代理):

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

2.2.7 Aspect(切面):

  • 切面:我们的拦截处理类;由于处理类里面需要执行所有拦截到的目标方法,也就是切入点,还包括我们增强的功能代码,也就是通知,因此我们一般称切面(Aspect)=切入点(Pointcut)+通知(Advice)

三、Spring中的AOP

3.1 AspectJ

AspectJ是一个面向切面的框架,它扩展了Java语言。AspectJ定义了AOP语法,是Java社区中最完整最流行的AOP框架

在Spring2.0以上版本中,可以使用基于AspectJ注解或基于XML配置的AOP。

Tips:我们本次课程并不是使用原生的AspectJ,而是使用Spring对AspectJ的封装

3.2 切入点表达式

切入点就是能够增强的方法的一系列集合,我们要通过表达式的方式定位一个或多个具体的连接点,这些所有的连接点被称为切入点;

  • 语法:
execution( [权限修饰符] [返回值类型] [简单类名/全类名] [方法名] ([参数列表]) )

示例一:

execution(* com.dfbz.dao.UserDao.*(..))
    
说明: com.dfbz.dao包下的UserDao接口中声明的所有方法

// 解释:任意权限修饰符、任意方法返回值、com.dfbz.dao.UserDao接口、任意方法名、任意参数列表
    
第一个"*"代表任意修饰符及任意返回值。
第二个"*"代表任意方法。
".."匹配任意数量、任意类型的参数。
若目标类、接口与该切面类在同一个包中可以省略包名。

示例二:

execution(public * UserDao.*(..))
    
说明: UserDao接口的所有公有方法 

// 必须public修饰、任意返回值、UserDao接口、任意方法名、任意参数列表

示例三:

execution(public String UserDao.*(..))
    
说明: UserDao中所有返回值为String类型的共有方法方法

// 必须public修饰、方法返回值必须String、UserDao接口(一级目录)、任意方法名、任意参数列表

示例四:

execution(private * UserDao.*(Integer, ..))
    
说明: 第一个参数为Integer类型的private修饰的方法。
    
// 必须是private修饰、任意方法返回值、UserDao接口(一级目录)、任意方法名、第一个参数必须是Integer,后面可以匹配任意参数(包含0个)
".." 匹配任意数量、任意类型的参数。

示例五:

execution(public double UserDao.*(double, double))
    
说明: 修饰符为public,返回值为double,UserDao中的两个参数都为double的方法
// 必须是public修饰符、返回值类型是double、UserDao接口(一级目录)、任意方法名、第一个参数为double、第二个参数为double

示例六:

execution(public void *.UserDao.*(..))
    
说明: 修饰符为public,返回值为void,任意一级包下的UserDao的任意方法
// 必须是public修饰符、返回值为void、任意一级包下的UserDao的任意方法、任意方法名、任意参数列表
注意:是任意一级包下的UserDao类,如果是多级包则不行,如:com.dfbz.dao.UserDao,必须写成public void *.*.*.UserDao.*(..)

示例七:

execution (* *.save(User,..)) || execution(* *.delete(Integer,..))

说明: 
	任意修饰符和返回值,任意包下的任意类,第一个参数为User的save方法
    或者
    任意修饰符和返回值,任意包下的任意类,第一个参数为Integer的delete方法

Tips:当权限修饰符设置为*时,方法的返回值也必须为*,而且不必使用*显示的写出

例如这样就是一种错误的写法:execution(* String UserDao.*(..))execution(* * UserDao.*(..))

可以这样:execution(* UserDao.*(..))

3.3 基于XML配置AOP

3.1.1 搭建环境

  • Maven依赖:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dfbz</groupId>
    <artifactId>01_Spring</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <!--spring环境依赖-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>

        <!--spring整合aspectj的依赖-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>

        <!--spring整合Junit的依赖-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.2.9.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
    </dependencies>
</project>

3.1.2 目标对象

package com.dfbz.dao;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class UserDao {

    public void save() {
        System.out.println("新增用户成功...");
    }

    public void delete(Integer id) {
        System.out.println("删除用户【" + id + "】成功...");
    }

    public void update() {
        System.out.println("修改用户成功...");
    }

    public String query() {
        System.out.println("查询用户成功...");
        return "success";
    }
}

3.1.3 切面类

package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;

/**
 * @author lscl
 * @version 1.0
 * @intro: 针对UserDao进行增强的切面类
 */
public class MyAspect {

    public void before(){
        System.out.println("前置通知...");
    }

    public Object around(ProceedingJoinPoint around) throws Throwable {         //环绕通知

        System.out.println("环绕通知之前...");
        
        // 执行下一个切面的通知,如果没有下一个切面那么执行目标方法
        Object proceed = around.proceed();          
        
        System.out.println("环绕通知之后...");
        return proceed;                             //将目标方法的返回值返回
    }
    
    public void after(){
        System.out.println("后置通知...");
    }

    public void afterReturning(){
        System.out.println("返回通知...");
    }

    public void afterThrowing(){
        System.out.println("异常通知...");
    }
}

3.1.4 Spring配置

切面相关配置:

  • <aop:aspectj-autoproxy />:开启AOP代理,当Spring IOC容器侦测到bean配置文件中的<aop:aspectj-autoproxy>元素时,会自动为与AspectJ切面匹配的bean创建代理

  • <aop:config>:aop核心配置,在此标签内配置切点、切面等

    • <aop:pointcut>:配置切入点
    • <aop:aspect ref="myAspect">:配置切面,并指定切面
      • <aop:before method="" pointcut-ref="">:前置通知,指定前置通知方法和采用哪个切点
      • <aop:around method="" pointcut-ref="">:环绕通知
      • <aop:after method="" pointcut-ref="">:后置通知
      • <aop:after-returning method="" pointcut-ref="">:后置返回通知
      • <aop:after-throwing method="" pointcut-ref="">:异常通知
  • spring.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">


    <bean class="com.dfbz.dao.UserDao"></bean>

    <!--
        开启AOP自动代理
         proxy-target-class: 是否采用GBLIB代理
            true: 采用CGlib代理
            false: 采用JDK动态代理(必须要有接口的时候才可以选择为false,如果没有接口会默认采用GBLIB)
    -->
    <aop:aspectj-autoproxy />

    <!--配置切面类-->
    <bean id="myAspect" class="com.dfbz.aspect.MyAspect"></bean>

    <!--aop核心配置-->
    <aop:config>
        <!--
            配置切点
                id:切点名称
                expression:切点表达式
        -->
        <aop:pointcut id="myPoint" expression="execution(public void com.dfbz.dao.UserDao.save(..))"/>

        <!--
            配置切面
            before:前置通知
            after-returning:返回通知
            around:环绕通知
            after:后置通知
            after-throwing:异常通知
        -->
        <aop:aspect ref="myAspect">
            <!--【前置通知】-->
            <aop:before method="before" pointcut-ref="myPoint"/>
            <!--【环绕通知】-->
            <aop:around method="around" pointcut-ref="myPoint"/>
            <!--【返回通知】-->
            <aop:after-returning method="afterReturning" pointcut-ref="myPoint"/>
            <!--【后置通知】-->
            <aop:after method="after" pointcut-ref="myPoint"/>
            <!--【异常通知】-->
            <aop:after-throwing method="afterThrowing" pointcut-ref="myPoint"/>
        </aop:aspect>
    </aop:config>
</beans>
  • 测试代码:
package com.dfbz.demo;

import com.dfbz.dao.UserDao;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@RunWith(SpringRunner.class)
@ContextConfiguration("classpath:spring.xml")
public class Demo01 {

    @Autowired
    private UserDao userDao;

    @Test
    public void test1()throws Exception{
        userDao.save();
    }
}

执行效果:

在这里插入图片描述

执行目标方法出现异常的执行情况:

在这里插入图片描述

3.1.5 通知执行顺序

关于通知的执行顺序,每个版本都有很大的改动,并且配置顺序不一样也会导致通知执行顺序不一致,再者注解方式和配置文件方式的执行运行也会有些不同,因此我们不需要死记各个通知的执行顺序;通常情况下,通知执行的顺序是:

  • 正常情况:前置通知—>环绕通知—>目标方法—>环绕通知—>返回通知—>后置通知

  • 出现异常情况:前置通知—>环绕通知—>目标方法—>环绕通知—>后置通知—>异常通知

在这里插入图片描述

但是如果更改了切面中配置通知的顺序,则执行的顺序会有所改变,并且没有什么规律;我们一般不用太在意通知的执行顺序,因为前置通知和后置通知一定在目标方法执行前后;

Tips:当执行目标方法出现异常时,不会有目标对象不会有返回值,因此返回通知不会被执行;

3.1.6 AOP相关API

1)ProceedingJoinPoint类

ProceedingJoinPoint类是AOP编程中用于获取目标对象/方法信息的一个类;提供的方法如下:

  • getStaticPart():获取切入点表达式
  • getTarget():获取目标对象
  • getThis():获取当前对象(代理对象)
  • getArgs():获取代理对象在调用方法时传递的参数
  • getSignature():获取签名
  • proceed():执行目标方法

2)Signature类

Signature主要是描述目标对象的类;其提供的常用方法如下:

  • getDeclaringType():获取目标对象
  • getDeclaringTypeName():获取目标对象全类名
  • getName():获取目标方法名称

测试代码:

public Object around(ProceedingJoinPoint joinPoint) throws Throwable {           // 需要执行目标方法

    // 切入点表达式(execution(void com.dfbz.dao.UserDao.query()))
    System.out.println(joinPoint.getStaticPart());

    // 目标对象(class com.dfbz.dao.UserDao)
    System.out.println(joinPoint.getTarget().getClass());

    // 获取到代理对象(class com.dfbz.dao.UserDao$$EnhancerBySpringCGLIB$$4354d856)
    System.out.println(joinPoint.getThis().getClass());

    // 代理对象在调用方法时传递的参数
    System.out.println(Arrays.toString(joinPoint.getArgs()));

    System.out.println("----------------------");


    // 获取方法签名
    Signature signature = joinPoint.getSignature();

    // 获取目标对象(class com.dfbz.dao.UserDao)
    System.out.println(signature.getDeclaringType());

    // 获取目标对象全类名(com.dfbz.dao.UserDao)
    System.out.println(signature.getDeclaringTypeName());

    // 获取执行目标方法的名称(query)
    System.out.println(signature.getName());                       

    // 执行下一个切面的通知,如果没有下一个切面那么执行目标方法,并获取目标方法的返回值
    Object result = joinPoint.proceed();

    // 将目标方法的返回值原封不动的返回了给了方法的调用者
    return result;
}

执行结果如下:

在这里插入图片描述

3.4 使用注解配置切面

1)xml和注解搭配使用

  • spring.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd">

    <!--包扫描-->
    <context:component-scan base-package="com.dfbz" />

    <!-- 开启AOP自动代理 -->
    <aop:aspectj-autoproxy />

</beans>
  • 切面类:
package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

/**
 * @author lscl
 * @version 1.0
 * @intro: 针对UserDao进行增强的切面类
 */
@Aspect     // 标注这是一个配置类
@Component    // 交给IOC管理
public class MyAspect {

    // 定义切点
    @Pointcut("execution(* com.dfbz.dao.UserDao.save())")
    public void pt(){}

    //    @Before("execution(* com.dfbz.dao.UserDao.*())")      // 单独定义切点
    @Before("pt()")                     // 引用定义的切点
    public void before(){
        System.out.println("前置通知...");
    }

    @Around("pt()")
    public Object around(ProceedingJoinPoint around) throws Throwable {         //环绕通知

        System.out.println("环绕通知之前...");
        Object proceed = around.proceed();          //执行目标方法
        System.out.println("环绕通知之后...");
        return proceed;                             //将目标方法的返回值返回
    }

    @After("pt()")
    public void after(){
        System.out.println("后置通知...");
    }

    @AfterReturning("pt()")
    public void afterReturning(){
        System.out.println("返回通知...");
    }

    @AfterThrowing("pt()")
    public void afterThrowing(){
        System.out.println("异常通知...");
    }
}

在注解情况下,通知的顺序如下:

在这里插入图片描述

Tips:在注解配置情况下,执行完后置通知又回到环绕通知了;所以环绕通知中我们一般不执行代码,只执行目标对象的方法;

2)纯注解配置

分析:主要就是<aop:aspectj-autoproxy />改为注解配置

配置类:

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@ContextConfiguration
@ComponentScan("com.dfbz")
@EnableAspectJAutoProxy         // 开启AOP自动代理(是否启用CGLIB代理)
public class SpringConfig {
    
    
}

3.5 多切面配置

多个切面执行顺序可以由@Order()注解来配置,数字越小,越先执行,多个切面执行顺序如下:

在这里插入图片描述

  • 定义切面1:
package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@Aspect
@Component
@Order(1)           // 切面执行顺序,数字越小优先级越高
public class MyAspect_01 {

    // 定义切点
    @Pointcut("execution(* com.dfbz.dao.UserDao.save())")
    public void pt() {
    }

    @Before("pt()")
    public void before() {
        System.out.println("【MyAspect_01】前置通知...");
    }

    @Around("pt()")
    public Object around(ProceedingJoinPoint around) throws Throwable {
        Object proceed = around.proceed();
        return proceed;
    }

    @After("pt()")
    public void after() {
        System.out.println("【MyAspect_01】后置通知...");
    }

    @AfterReturning("pt()")
    public void afterReturning() {
        System.out.println("【MyAspect_01】返回通知...");
    }

    @AfterThrowing("pt()")
    public void afterThrowing() {
        System.out.println("【MyAspect_01】异常通知...");
    }
}
  • 定义切面2:
package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@Aspect
@Component
@Order(10)              // 切面执行顺序,数字越小优先级越高
public class MyAspect_02 {

    // 定义切点
    @Pointcut("execution(* com.dfbz.dao.UserDao.save())")
    public void pt() {
    }

    @Before("pt()")
    public void before() {
        System.out.println("【MyAspect_02】前置通知...");
    }

    @Around("pt()")
    public Object around(ProceedingJoinPoint around) throws Throwable {
        Object proceed = around.proceed();
        return proceed;
    }

    @After("pt()")
    public void after() {
        System.out.println("【MyAspect_02】后置通知...");
    }

    @AfterReturning("pt()")
    public void afterReturning() {
        System.out.println("【MyAspect_02】返回通知...");
    }

    @AfterThrowing("pt()")
    public void afterThrowing() {
        System.out.println("【MyAspect_02】异常通知...");
    }
}
  • 目标对象:
package com.dfbz.dao;

import org.springframework.stereotype.Repository;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@Repository
public class UserDao {

    public void save() {
        System.out.println("新增用户成功...");
    }

    public void delete(Integer id) {
        System.out.println("删除用户【" + id + "】成功...");
    }

    public void update() {
        System.out.println("修改用户成功...");
    }

    public String query() {
        System.out.println("查询用户成功...");
        return "success";
    }
}
  • 配置类:
package com.dfbz;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.test.context.ContextConfiguration;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@ContextConfiguration
@ComponentScan("com.dfbz")      // 扫包
@EnableAspectJAutoProxy         // 开启Aop自动代理
public class SpringConfig {
}
  • 测试代码:
package com.dfbz.demo;

import com.dfbz.SpringConfig;
import com.dfbz.dao.UserDao;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = SpringConfig.class)
public class Demo01 {

    @Autowired
    private UserDao userDao;

    @Test
    public void test1()throws Exception{
        userDao.save();
    }
}
  • 执行效果:

在这里插入图片描述

3.6 使用AOP完成案例

【案例】我们使用我们学习的AOP完成前面的案例需求;

我们需要定义两个切面类:分别是日志处理切面类,缓存处理切面类;

根据多个切面的执行顺序,我们选择缓存切面类执行顺序为1,日志切面类执行顺序为2(后执行);

  • 定义缓存切面类:
package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

/**
 * @author lscl
 * @version 1.0
 * @intro: 缓存功能切面类
 */
@Aspect
@Component
@Order(1)          // 多个切面执行的顺序,数字越小越先执行
public class CacheAspect {


    @Pointcut("execution(* com.dfbz.dao.UserDao.*(..))")
    public void pt() {
    }


    private ProceedingJoinPoint pjp;

    @Around("pt()")
    public Object around(ProceedingJoinPoint pjp) throws Throwable{

        this.pjp=pjp;
        return pjp.proceed();           // 执行目标方法
    }

    @AfterReturning("pt()")         // 返回通知(环绕通知执行完毕之后执行)
    public void afterReturning() {

        String methodName = pjp.getSignature().getName();

        if (
                "save".equals(methodName) ||
                        "update".equals(methodName) ||
                        "delete".equals(methodName)

        ) {
            System.out.println("清除缓存成功...");
        } else if ("query".equals(methodName)) {
            System.out.println("存入缓存成功...");
        }
    }

}
  • 定义日志切面类:
package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.*;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
@Aspect
@Component
@Order(2)
public class LoggerAspect {


    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

    @Pointcut("execution(* com.dfbz.dao.UserDao.*(..))")
    public void pt(){};

    private ProceedingJoinPoint pjp;


    @Before("pt()")
    public void before(){

        // 目标方法的名称
        String methodName = pjp.getSignature().getName();
        System.out.println("执行【" +methodName+ "】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
    }

    @Around("pt()")
    public Object around(ProceedingJoinPoint pjp) throws Throwable{

        this.pjp=pjp;
        // 执行目标方法
        Object returnVal = pjp.proceed();

        return returnVal;
    }


    @AfterReturning("pt()")
    public void afterReturning(){			// 返回通知

        // 目标方法的名称
        String methodName = pjp.getSignature().getName();
        System.out.println("执行【" +methodName+ "】操作 begin...,时间:【" + sdf.format(new Date()) + "】");
    }
}

执行测试类:

在这里插入图片描述

四、CGLIB代理

4.1 CGLIB代理的使用

我们之前学习过JDK动态代理,要求目标对象一定要实现接口,否则不能用动态代理。如果目标对象就是没有实现接口,还想对目标对象某个方法进行扩展,那么JDK的动态代理就不行了;

Cglib代理,也叫作子类代理,它是在内存中构建一个子类对象从而实现对目标对象功能的扩展;

Cglib是一个强大的高性能的代码生成包,它可以在运行期扩展java类与实现java接口。它广泛的被许多AOP的框架使用,为他们提供方法的interception(拦截),Spring-Core核心已经包含CGLIB功能。

  • UserDao:
package com.dfbz.dao;

import org.springframework.stereotype.Repository;

/**
 * @author lscl
 * @version 1.0
 * @intro:  目标对象
 */
@Repository
public class UserDao implements UserDaoInterface {

    public void save(){
        System.out.println("save..");
    }

    public void delete(){
        System.out.println("delete..");
    }

    public void update(){
        System.out.println("update..");
    }

    public void query(){
        System.out.println("query..");
    }
}
  • 使用CGLIB代理UserDao:
package com.dfbz.test;

import com.dfbz.dao.UserDao;
import org.junit.Test;
import org.springframework.cglib.proxy.Enhancer;
import org.springframework.cglib.proxy.MethodInterceptor;
import org.springframework.cglib.proxy.MethodProxy;

import java.lang.reflect.Method;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public class Demo04 {

    @Test
    public void test1() {
        //返回一个service的子类
        UserDao proxy = (UserDao) Enhancer.create(UserDao.class, new MethodInterceptor() {
            /*
             *
             *   proxy:代理对象
             *   method:要执行的方法对象
             *   args:要执行的方法的参数
             *   methodProxy:代理对象的方法对象
             * */
            @Override
            public Object intercept(Object proxy, Method method, Object[] args, MethodProxy methodProxy) throws Throwable {
                
                System.out.println("增强的代码");
                Object invoke = method.invoke(new UserDao());
                 /*
                methodProxy:
                    代理对象的方法类,因为cglib代理对目标对象进行继承派生出子类,因此代理对象是目标对象的子类
                    此代理对象方法类也可以执行本代理对象方法
                 */
//                Object invoke = methodProxy.invoke(new UserDao(), args);
                System.out.println("增强的代码");
                return invoke;
            }
        });

        proxy.save();
    }

}

Tips:cgblib代理类时,这个类不能被final修饰;

4.2 AOP与GBLIB代理

刚刚我们学的AOP默认采用的是JDK动态代理,也就是说Spring会帮我们使用JDK动态代理出来一个UserDaoInterface的子类注入到UserDaoInterface中,如果我们改成了UserDao来接收,那么则会报错;因为JDK的动态代理是不能针对类进行代理的;

但需要注意的是:如果目标类没有实现任何接口的话,即使设置为false,还是会采用GBLIB代理

修改代理方式:

<!--
    proxy-target-class: 采用GBLIB代理还是JDK的代理
        true: 采用GBLIB代理
        false: 不开启CGLIB代理,采用JDK代理(默认值),如果该类没有实现任何接口的话,还是会采用GBLIB代理
-->
<aop:aspectj-autoproxy proxy-target-class="false"></aop:aspectj-autoproxy>

编写一个切面:

package com.dfbz.aspect;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.stereotype.Component;

/**
 * @author lscl
 * @version 1.0
 * @intro: 编写切面(切面 = 切入点 + 通知)
 */
@Component
@Aspect
public class MyAspect {

    // 配置切入点
    @Pointcut("execution(* com.dfbz.dao.UserDao.*(..))")
    public void pt(){}

    @Around("pt()")
    public Object around(ProceedingJoinPoint pjp) throws Throwable {           // 需要执行目标方法
        // 执行目标方法
        Object result = pjp.proceed();
        return result;
    }
}

编写接口:

package com.dfbz.dao;

/**
 * @author lscl
 * @version 1.0
 * @intro:
 */
public interface UserDaoInterface {

    public void save();

    public void delete();

    public void update();

    public void query();
}

让UserDao实现该接口;

修改为false(采用JDK代理):

在这里插入图片描述

修改为true(采用GBLIB代理):

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/47357.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【Java进阶篇】第六章 IO流

文章目录一、IO流的概述1、流2、流的分类3、Java IO流的四大块4、流的两大特性5、java.io包下的16个常用流二、文件专属流1、java.io.FileInputStream2、java.io.FileOutputStream3、java.io.FileReader4、java.io.FileWriter三、缓冲流与转换流1、java.io.BufferedReader2、ja…

【面试题】深度解析Java多线程中的 run() 与 start() 有什么区别?

【面试题】深度解析Java多线程中的 run() 与 start() 有什么区别&#xff1f; 大多数人的回答 start() run() 深入底层源码的解析 run() 与 start() 为什么我们不能直接调用 run() 方法&#xff1f; 如何证明 start() 会调用 run() 方法&#xff1f; JVM -> OS执行全…

Nodejs -- 数据库基本概念的介绍及在Express中操作数据库

文章目录1. 数据库的基本概念1.1 什么是数据库1.2 常见的数据库及分类1.3 传统型数据库的数据组织结构1.3.1 Excel的数据组织结构1.3.2 传统型数据库的数据组织结构1.3.3 实际开发中库、表、行、字段的关系2. 在Express中操作MySQL2.1 在项目中操作数据库的步骤2.2 安装与配置m…

Java编程案例:买飞机票

编程案例&#xff1a; 一、目的 复习前半段课程学习的Java编程知识&#xff0c;能够使用所学的知识解决问题&#xff0c;提升同学们的编程能力。 二、涉及到的知识点 变量、数组。运算符&#xff1a;基本运算符、关系运算符、逻辑运算符…程序流程控制&#xff1a;if、switc…

np.meshgrid()函数

文章目录(1)自己理解(2)官方解释(3)参数:3.1 x1, x2,…, xn:array_like3.2 sparse:bool, optional 默认false3.3 copy:bool, optional(1)自己理解 np.meshgrid(a, b,indexing "xy") 函数会返回 b.shape() 行 &#xff0c;a.shape() 列的二维数组。 因此 i, j 都是 …

【序列召回推荐】(task6)多兴趣召回Comirec-SA

note Comirec-SA基于attention的多兴趣建模&#xff0c;论文中先通过attention提取单一兴趣&#xff0c;再推广到多兴趣建模。另外使用贪心算法优化带有准确度多样性的目标函数。DR把MIND的attention换成argmax&#xff08;还有初始化方式不同、序列胶囊到兴趣胶囊用可学习权重…

2.线性代数基础

1.矩阵 2. 特殊矩阵 正交矩阵 AATE&#xff08;E为单位矩阵&#xff0c;AT表示“矩阵A的转置矩阵”。&#xff09;或ATAE&#xff0c;则n阶实矩阵A称为正交矩阵 正交矩阵有如下性质&#xff1a; A是正交矩阵&#xff0c;AT也是正交矩阵A的各行是单位向量且两两正交&#xff0…

html实现ezuikit.js萤石云直播监控,ezuikit.js实时监控实现,萤石云实时监控简单实现

效果图 实现 下面的播放url获取&#xff1a;登录萤石云->控制台->我的资源->设备列表->列表中&#xff1a;查看通道->监控地址 appKey和appSecret获取&#xff1a;登录萤石云->控制台->我的账号->应用信息->右侧&#xff1a;应用密钥 下载ezuikit…

(服务器客户端)网络通信是怎么实现的?7000字爆肝----原来java网络编程技术功不可没(多线程,URL,InetAddressm,TCP,UDP)集结

&#x1f468;‍&#x1f4bb;个人主页&#xff1a;元宇宙-秩沅 hallo 欢迎 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! 本文由 秩沅 原创 收录于专栏 java ⭐java网络编程技术⭐ 文章目录⭐java网络编程技术⭐&#x1f468;‍&#x1f4bb;一&#xff0c;URL类…

[附源码]Python计算机毕业设计Django的4s店车辆管理系统

项目运行 环境配置&#xff1a; Pychram社区版 python3.7.7 Mysql5.7 HBuilderXlist pipNavicat11Djangonodejs。 项目技术&#xff1a; django python Vue 等等组成&#xff0c;B/S模式 pychram管理等等。 环境需要 1.运行环境&#xff1a;最好是python3.7.7&#xff0c;…

虎牙、斗鱼同道同命:共同御寒

配图来自Canva可画 回顾游戏直播行业过去十年&#xff0c;先是直播行业野蛮发展玩家快速跑马圈地&#xff0c;而后历经千播大战形成斗鱼、虎牙分天下的市场格局&#xff0c;现在头部平台进入精细化、多元化运作阶段&#xff0c;市场竞争愈加激烈。 也就是说&#xff0c;游戏直…

4G DTU能装4G物联网卡吗?

科技的发展日新月异&#xff0c;我们国家的发展战略也是支持高新科技公司的发展&#xff0c;所以越来越多的高新科技公司出现&#xff0c;但凡是高新科技公司&#xff0c;在设备的联网中&#xff0c;都会用到物联卡&#xff0c;所以物联卡的市场也愈发火爆&#xff0c;那么今天…

食物链【并查集+不知道1是A,B,C哪一类的?用x,x+n,x+n+n分别表示A,B,C中有个1】【并查集中用距离表示关系】【压缩路径】

欢迎观看我的博客&#xff0c;如有问题交流&#xff0c;欢迎评论区留言&#xff0c;一定尽快回复&#xff01;&#xff08;大家可以去看我的专栏&#xff0c;是所有文章的目录&#xff09; 文章字体风格&#xff1a; 红色文字表示&#xff1a;重难点 蓝色文字表示&#xff1a;思…

jenkins项目构建类型 -----Pipeline流水线项目构建

壹&#xff0c;概念 pipeline 是一套运行在jenkins上得工作流框架&#xff0c;将原本运行于单个或者多个节点得任务连接起来&#xff0c;用来实现单个任务难以完成得复杂流程编排和可视化得工作。 贰 优点 代码持久可停止多功能可扩展 叁 如何创建Jenkins Pipeline pipeli…

计算机物联网控制|5.5常规控制方案 5.6先进控制方案

11.16日课堂作业 1.已知模拟PID算式为 试推导差分增量算式。 2.PID参数Kc、Ti、Td对系统动态特性和稳态特性有何影响&#xff1f; 目录 11.16日…

[附源码]计算机毕业设计springboot高校实验室仪器设备管理系统

项目运行 环境配置&#xff1a; Jdk1.8 Tomcat7.0 Mysql HBuilderX&#xff08;Webstorm也行&#xff09; Eclispe&#xff08;IntelliJ IDEA,Eclispe,MyEclispe,Sts都支持&#xff09;。 项目技术&#xff1a; SSM mybatis Maven Vue 等等组成&#xff0c;B/S模式 M…

Telemetry原理

Telemetry是一种网络设备监控技术&#xff0c;提供周期采样网络设备内的统计数据和状态数据的能力。 一、Telemetry概述 1.1、技术背景&#xff1a; 网络设备的统一监控和性能管理是运维平台的重要功能&#xff0c;设备的监控数据包括数据、控制和管理平面数据。 获取设备监…

学习Python的8天

1、异常处理机制 Python 中&#xff0c;用try except语句块捕获并处理异常&#xff0c;其基本语法结构如下所示&#xff1a; try:可能产生异常的代码块 except [ (Error1, Error2, ... ) [as e] ]:#(e是别名&#xff0c;可以自己起)处理异常的代码块1 except [ (Error3, Error…

【强化学习论文合集 | 2020年合集】一. ICML-2020 强化学习论文

强化学习(Reinforcement Learning, RL),又称再励学习、评价学习或增强学习,是机器学习的范式和方法论之一,用于描述和解决智能体(agent)在与环境的交互过程中通过学习策略以达成回报最大化或实现特定目标的问题。 本专栏整理了近几年国际顶级会议中,涉及强化学习(Rein…

Workfine使用Oracle Express Edition数据库

Workfine 应用环境和工具 Win10 专业版操作系统Windows Terminaldocker desktop 4.10.1 安装设置Oracle Express Edition数据库 1、获取Oracle XE 18.4.0 docker 镜像&#xff0c;在 Windows Terminal 终端里执行如下命令 docker pull gvenzl/oracle-xe:18.4.0 2、下载成功…