Spring的AOP与动态代理「建议收藏」

全栈程序员站长

发布于 2022-08-04 16:42:23

72500

代码可运行

文章被收录于专栏：全栈程序员必看全栈程序员必看

运行总次数：0

代码可运行

大家好，又见面了，我是你们的朋友全栈君。

Aspect Oriented Programming（AOP） “面向切面编程”。在Spring中提供了面向切面编程的丰富支持，允许通过分离应用的业务逻辑与系统级服务（例如审计（auditing）和事务（transaction）管理）进行内聚性的开发。应用对象只实现它们应该做的——完成业务逻辑——仅此而已。主要功能日志记录，性能统计，安全控制，事务处理，异常处理等等通过动态代理，可以在不修改源码的前提下，实现功能的注入

AOP概念和7个专业术语

1.增强（Advice）　　　　增强就很好理解了，AOP（切面编程）是用来给某一类特殊的连接点，添加一些特殊的功能，那么我们添加的功能也就是增强啦~ 　　　　比如：添加日志、管理事务。　　　　不过增强不仅仅包含需要增加的功能代码而已，它还包含了方位信息。　　　　那什么是方位信息呢？　　　　方位信息就是相对于方法的位置信息，如：方法前、方法后、方法环绕　　　　为什么要方位信息呢？切点不是确定了需要增强的位置了吗？　　　　切点定位的是“在什么类的什么方法上”，也就是说，切点只是定位到了方法本身（也叫执行点，特殊的连接点），但是我们增强的内容是放在该方法的前面呢、后面呢？还是前后都要呢？这些切点却没有告诉我们，那么我们该如何确定具体位置呢？　　　　所以，我们才需要用到方位信息，进一步的定位到具体的增强代码放置的位置。　　　　咦？增强即包含了【功能】又包含了【方位】，那我是不是不用切点就可以匹配哪些方法，并添加功能了呢？　　　　恩，确实如此，因为通过方位信息，虽然只是简单的描述了【功能】需要放在方法前、后、还是前后都要等信息，但是我们还是可以通过方位定位到位置。只不过，是匹配到所有类的所有方法！因为方位只是说明在方法前还是方法后，并没有要求是哪些类？哪　　　　些方法？ — So，我们可以直接使用增强来生成一个切面，而不需要切点，但这并不怎么推荐，因为它是匹配所有方法的。所以，我们才需要用切点来进一步确认位置。
2.切点（Pointcut）　　　　一个项目中有很多的类，一个类有很多个连接点，当我们需要在某个方法前插入一段增强（advice）代码时，我们就需要使用切点信息来确定，要在哪些连接点上添加增强。　　　　那么切点是什么？　　　　如果把连接点当做数据库中的记录，那么切点就是查找该记录的查询条件。　　　　所以，一般我们要实现一个切点时，那么我们需要判断哪些连接点是符合我们的条件的，如：方法名是否匹配、类是否是某个类、以及子类等。
3.连接点(Joinpoint) 　　　　连接点就是程序执行的某个特定的位置，如：类开始初始化前、类初始化后、类的某个方法调用前、类的某个方法调用后、方法抛出异常后等。Spring 只支持类的方法前、后、抛出异常后的连接点。
4.切面(Aspect) 　　　　切面由切点和增强(或引介)组成，或者只由增强（或引介）实现。
5.目标对象（Target）　　　　目标对象就是我们需要对它进行增强的业务类~ 　　　　如果没有AOP，那么该业务类就得自己实现需要的功能。
6.AOP代理(AOP proxy) 　　　　一个类被AOP织入后生成出了一个结果类，它是融合了原类和增强逻辑的代理类。
7.织入(Weaving) 　　　　织入就是将增强添加到目标类具体连接点上的过程。　　　　编译期织入，这要求使用特殊java编译器　　　　类装载期织入，这要求使用特殊的类装载器　　　　动态代理织入，在运行期为目标类添加增强生成子类的方式　　　　Spring采用的是动态代理织入，而AspectJ采用编译期织入和类装载期织入。

原生的动态代理

pom.xml

<?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>groupId</groupId>
    <artifactId>dome03</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.5.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>commons-logging</groupId>
            <artifactId>commons-logging</artifactId>
            <version>1.2</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.1.5.RELEASE</version>
        </dependency>
        <!-- https://mvnrepository.com/artifact/cglib/cglib -->
        <!--基于子类的动态代理 t2的测试类使用-->
        <dependency>
            <groupId>cglib</groupId>
            <artifactId>cglib</artifactId>
            <version>3.1</version>
        </dependency>
    </dependencies>
    
</project>

UserDao.java

package com.xbj.dao;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
 public interface UserDao { 
   
    void addUser();
    void delUser();
}

UserDaoImpl.java

package com.xbj.dao.impl;

import com.xbj.dao.UserDao;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
public class UserDAOImpl implements UserDao { 
   
    public void addUser() { 
   
        System.out.println("addUser");
    }

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

    //定义初始化方法
    public void myInit(){ 
   
        System.out.println("init...");

    }
    //定义销毁方法
    public void dest(){ 
   
        System.out.println("dest...");
    }

}

MyAdvice.java

package com.xbj;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
public class MyAdvice { 
   //通知
        public void before(){ 
   
            System.out.println("开启事务");
        }

        public void after(){ 
   
            System.out.println("关闭事务");
        }

}

test测试类：

import com.xbj.MyAdvice;
import com.xbj.dao.UserDao;
import com.xbj.dao.impl.UserDAOImpl;
import org.junit.Test;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
public class test { 
   
    @Test
    public void  t1(){ 
   
        //目标类
        final UserDAOImpl userDAO = new UserDAOImpl();
        //通知（植入的功能）
        final MyAdvice advice = new MyAdvice();

        InvocationHandler handler = new InvocationHandler() { 
   
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { 
   
                if (method.equals("delUser")){ 
   
                    advice.before();
                }
                Object object=method.invoke(userDAO,args);

                if (method.getName().equals("addUser")){ 
   
                    advice.after();
                }
                return object;
            }
        };
        //Proxy.newProxyInstance(类加载器, 接口ming.,回调函数;
        UserDao proxyClass = (UserDao) Proxy.newProxyInstance(userDAO.getClass().getClassLoader(), userDAO.getClass().getInterfaces(),handler);
        proxyClass.addUser();
        System.out.println("------------------");
        proxyClass.delUser();

    }
}

控制台输出：

addUser
关闭事务
------------------
delUser

基于子类的动态代理

代码同上 test测试类添加了t2测试方法：

import com.xbj.MyAdvice;
import com.xbj.dao.UserDao;
import com.xbj.dao.impl.UserDAOImpl;
import net.sf.cglib.proxy.Callback;
import net.sf.cglib.proxy.Enhancer;
import net.sf.cglib.proxy.MethodInterceptor;
import net.sf.cglib.proxy.MethodProxy;
import org.junit.Test;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
public class test { 
   
    @Test
    public void  t1(){ 
   
        //目标类
        final UserDAOImpl userDAO = new UserDAOImpl();
        //通知（植入的功能）
        final MyAdvice advice = new MyAdvice();

        InvocationHandler handler = new InvocationHandler() { 
   
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { 
   
                if (method.equals("delUser")){ 
   
                    advice.before();
                }
                Object object=method.invoke(userDAO,args);

                if (method.getName().equals("addUser")){ 
   
                    advice.after();
                }
                return object;
            }
        };
        //Proxy.newProxyInstance(类加载器, 接口ming.,回调函数;
        UserDao proxyClass = (UserDao) Proxy.newProxyInstance(userDAO.getClass().getClassLoader(), userDAO.getClass().getInterfaces(),handler);
        proxyClass.addUser();
        System.out.println("------------------");
        proxyClass.delUser();

    }
    @Test
    public void t2(){ 
   
        //目标类
        final UserDAOImpl userDAOimpl=new UserDAOImpl();
        //通知(植入的功能)
        final MyAdvice advice=new MyAdvice();
        Callback callback=new MethodInterceptor() { 
   
            public Object intercept(Object o, Method method, Object[] objects, MethodProxy methodProxy) throws Throwable { 
   
                advice.before();
                Object obj=method.invoke(userDAOimpl,objects);
                advice.after();
                return obj;
            }
        };
        //superclass callback
        UserDao proxyClass= (UserDao) Enhancer.create(userDAOimpl.getClass(),callback);
        proxyClass.delUser();
    }
}

运行t2测试方法，控制台输出：

开启事务
delUser
关闭事务

Spring 自动代理

@Component @Controller @Repository @Service 都是将bean放入Ioc容器中，只是为了代码的可读性而去区别开 @Autowired 是从Ioc容器拿对象

流程：

<!--1. 扫描：发现Bean  哪里的Bean你想被我管理-->
    <!--2. 在被扫描的目录去做标注，哪些具体的类要被管理-->
    <!--3.配置AOP 动态代理
     1. 哪里增强（切入点）
     2. 增强什么（advice）-->
    <!-- 4.切入点：方法 void  包.类.方法(args) -->

applicationContext.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:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation=" 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 http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd">

    <context:component-scan base-package="com.xbj"/>
    
    <!--配置 自动代理-->
    <aop:config proxy-target-class="true">
        <!--<aop:pointcut id="myPointcut" expression="execution(* com.xbj.service.impl.*.*(..))" />-->
        <!--<aop:advisor advice-ref="myAspect" pointcut-ref="myPointcut" />-->
        <aop:advisor advice-ref="myAspect" pointcut="execution(* com.xbj.service.impl.*.*(..))" />
    </aop:config>
</beans>

UserController.java

package com.xbj.controller;

import com.xbj.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
/* @Controller @Repository @Component @Service 都是将bean放入Ioc容器中，只是为了代码的可读性而去区别开 * @Autowired 是从Ioc容器拿对象 * */
@Controller
public class UserController { 
   

    @Autowired
    private UserService userService;

    public void addUser(){ 
   
        userService.addUser();
    }
}

UserDao.java

package com.xbj.dao;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
 public interface UserDao { 
   
    void addUser();
    void delUser();
}

UserDaoImpl.java

package com.xbj.dao.impl;

import com.xbj.dao.UserDao;
import org.junit.runner.RunWith;
import org.springframework.stereotype.Repository;
import org.springframework.stereotype.Service;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
@Repository
public class UserDaoImpl implements UserDao { 
   
    public void addUser() { 
   
        System.out.println("addUser");
    }

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

    //定义初始化方法
    public void myInit(){ 
   
        System.out.println("init...");

    }
    //定义销毁方法
    public void dest(){ 
   
        System.out.println("dest...");
    }

}

UserService.java

package com.xbj.service;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
public interface UserService { 
   
    void addUser();
    void delUser();
}

UserServiceImpl.java

package com.xbj.service.impl;

import com.xbj.dao.UserDao;
import com.xbj.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
@Service
public class UserServiceImpl implements UserService { 
   
    @Autowired
    private UserDao userDao;
    public void addUser() { 
   
       userDao.addUser();
    }

    public void delUser() { 
   
        userDao.delUser();
    }
}

MyAspect.java

package com.xbj;

import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Controller;

/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
/* * 注意包名：org.aopalliance.intercept.MethodInterceptor;MyAspect * */
//切面
@Component
public class MyAspect implements MethodInterceptor { 
   
    public Object invoke(MethodInvocation invocation) throws Throwable { 
   
        System.out.println("前置增强");
        Object obj=invocation.proceed();   //invocation 调用
        System.out.println("后置增强");
        return obj;
    }

}

test.java

import com.xbj.controller.UserController;
import com.xbj.dao.UserDao;
import net.sf.cglib.proxy.Callback;
import net.sf.cglib.proxy.Enhancer;
import net.sf.cglib.proxy.MethodInterceptor;
import net.sf.cglib.proxy.MethodProxy;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;


/** * @Author:晓宇码匠 * @Date：2019/6/15 0015 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { 
   "classpath:applicationContext.xml"})
public class test { 
   
    @Autowired
    private UserController controller;
    @Test
    public void t1() { 
   
        controller.addUser();
    }


}

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/106639.html原文链接：https://javaforall.cn

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022年4月2，如有侵权请联系 cloudcommunity@tencent.com 删除

java