• 基于Advisor实现AOP

    Spring aop使用非常广泛就不说了。除了常见的使用@Aspect注解作为切面配合自定义注解作为切点实现AOP拦截外，还可以使用本文介绍的Advisor实现AOP。

    本文介绍基于Spring-aop依赖包下的Advisor接口实现AOP的方式。首先概述一下,这种实现方式主要是创建Advisor接口实例，并指定Advice和Pointcut，其中Advice接口实例扮演Advice通知的角色，Pointcut接口实例扮演切入点的角色，然后把Advisor实例注入到Spring中就可以实现AOP了。

    PointcutAdvisor接口

    PointcutAdvisor接口是Advisor的子接口，Advisor是Spring AOP的顶层抽象，用来管理Advice和Pointcut，所以毫无疑问PointcutAdvisor接口也是用来管理Advice和Pointcut的。

    Pointcut接口

    Pointcut接口有两个接口方法，分别用于加载ClassFilter和MethodMatcher接口实例，并通过这两个实例实现切入点的逻辑功能。

    1. public interface Pointcut {
    2.     Pointcut TRUE = TruePointcut.INSTANCE;
    3. 	//加载ClassFilter实例
    4.     ClassFilter getClassFilter();
    5. 	//加载MethodMatcher实例
    6.     MethodMatcher getMethodMatcher();
    7. }

     ClassFilter接口

    ClassFilter的matches方法定义判断某个类是否需要被纳入切面

    1. public interface ClassFilter {
    2. 	boolean matches(Class clazz);
    3. 	
    4. 	ClassFilter TRUE = TrueClassFilter.INSTANCE;
    5. }

    MethodMatcher接口 

     MethodMatcher的matches方法则是定义判断某个方法是否需要被纳入切面。

    1. public interface MethodMatcher {
    2. 	boolean isRuntime();
    3. 	
    4. 	//静态检查给定方法是否匹配
    5. 	boolean matches(Method method, Class targetClass);
    6.  
    7. 	//检查此方法是否存在运行时（动态）匹配
    8. 	boolean matches(Method method, Class targetClass, Object... args);
    9.  
    10. 	MethodMatcher TRUE = TrueMethodMatcher.INSTANCE;
    11. }

    MethodInterceptor接口

    这个接口spring-aop依赖下org.aopalliance.intercept.Interceptor接口的子接口,而Interceptor接口又是Advice接口的子接口，所以MethodInterceptor接口也是Advice接口的子接口。(有点啰嗦)
    MethodInterceptor接口主要提供一个invoke方法,用于定义通知逻辑，即对切点执行的逻辑代码。

    1. public interface MethodInterceptor extends Interceptor {
    2. 	
    3. 	Object invoke(MethodInvocation invocation) throws Throwable;
    4.  
    5. }

    上面把各个接口都介绍完了。现在整理一下流程做一下总结：

    1. 使用PointcutAdvisor接口实例(切面)把Pointcut接口实例(切点)和Advice接口实例(通知逻辑)整合起来并注入到Spring中,这样就能项目启动过程中实现AOP。
    2. 项目启动时会调用PointcutAdvisor接口的getPointcut和getAdvice方法，得到预先定义的切面逻辑实例(Pointcut接口实例)和织入方法逻辑实例（MethodInterceptor接口实例），得到实例后立即执行Pointcut接口实例中ClassFilter和MethodMatcher的match方法判断那些类或方法需要被纳入切面范围,实现动态构建切点信息。
    3. MethodInterceptor接口(Advice的子接口)的invoke方法则是通知逻辑，只需要被PointcutAdvisor接口加载即可，通知逻辑会在代码运行过程中对切点拦截后执行处理。

    上面第2点流程代码体现在org.springframework.aop.support.AopUtils#canApply 方法中

    1. public static boolean canApply(Pointcut pc, Class targetClass, boolean hasIntroductions) {
    2. 		Assert.notNull(pc, "Pointcut must not be null");
    3. 		if (!pc.getClassFilter().matches(targetClass)) {
    4. 			return false;
    5. 		}
    6.  
    7. 		MethodMatcher methodMatcher = pc.getMethodMatcher();
    8. 		if (methodMatcher == MethodMatcher.TRUE) {
    9. 			// No need to iterate the methods if we're matching any method anyway...
    10. 			return true;
    11. 		}
    12.  
    13. 		IntroductionAwareMethodMatcher introductionAwareMethodMatcher = null;
    14. 		if (methodMatcher instanceof IntroductionAwareMethodMatcher) {
    15. 			introductionAwareMethodMatcher = (IntroductionAwareMethodMatcher) methodMatcher;
    16. 		}
    17.  
    18. 		Set> classes = new LinkedHashSet>(ClassUtils.getAllInterfacesForClassAsSet(targetClass));
    19. 		classes.add(targetClass);
    20. 		for (Class clazz : classes) {
    21. 			Method[] methods = ReflectionUtils.getAllDeclaredMethods(clazz);
    22. 			for (Method method : methods) {
    23. 				if ((introductionAwareMethodMatcher != null &&
    24. 						introductionAwareMethodMatcher.matches(method, targetClass, hasIntroductions)) ||
    25. 						methodMatcher.matches(method, targetClass)) {
    26. 					return true;
    27. 				}
    28. 			}
    29. 		}
    30.  
    31. 		return false;
    32. 	}

    项目中集成基于Advisor实现AOP功能

    方式一：使用aspectj execution（切点） +自定义MethodInterceptor通知逻辑整合为默认的切面织入（DefaultPointcutAdvisor）

    Spring中给PointcutAdvisor接口提供一个一个默认的实现类DefaultPointcutAdvisor和Pointcut接口默认实现类AspectJExpressionPointcut，如果不想自己在定义切面和切点实现类可以直接使用默认实现。

    1. @Configuration
    2. public class PointcutAdvisorConfig {
    3.  
    4.     public static final String traceExecution = "execution(* cn.demo.service..*.*(..))";
    5.  
    6.     @Bean
    7.     public DefaultPointcutAdvisor defaultPointcutAdvisor1() {
    8. 		//使用默认的切面advisor实例
    9.         DefaultPointcutAdvisor advisor = new DefaultPointcutAdvisor();
    10. 		//使用默认的切点实例
    11.         AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
    12.         pointcut.setExpression(traceExecution);
    13.         advisor.setPointcut(pointcut);
    14. 		//配置自定义的通知实例
    15.         MyInterceptor interceptor = new MyInterceptor();
    16.         advisor.setAdvice(interceptor);
    17.         return advisor;
    18.     }
    19. }
    20. //只需额外自定义通知实现类即可
    21. public class MyInterceptor implements MethodInterceptor {
    22.  
    23.     @Override
    24.     public Object invoke(MethodInvocation invocation) throws Throwable {
    25.         System.out.println(invocation.getMethod() + "==方法执行前==");
    26.         Object proceed = invocation.proceed();
    27.         System.out.println(invocation.getArguments() + "--方法执行后--");
    28.         return proceed;
    29.     }
    30.  
    31. }

    方式二：使用自定义切点Pointcut+自定义MethodInterceptor通知逻辑整合默认的切面织入（DefaultPointcutAdvisor）或自定义PointcutAdvisor切面织入实例

    1. //定义切面类
    2. public class MapperMethodAdviceBean implements PointcutAdvisor, EnvironmentAware, ApplicationContextAware {
    3.     private Environment environment;
    4.     private ApplicationContext applicationContext;
    5.  
    6.     public MapperMethodAdviceBean() {
    7.     }
    8.  
    9.     public void setEnvironment(Environment environment) {
    10.         this.environment = environment;
    11.     }
    12.  
    13.     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    14.         this.applicationContext = applicationContext;
    15.     }
    16.  
    17.     public Pointcut getPointcut() {
    18.         return new MapperMethodPointCut();
    19.     }
    20.  
    21.     public Advice getAdvice() {
    22.         return new MapperMethodAdvise(this.environment, this.applicationContext);
    23.     }
    24.  
    25.     public boolean isPerInstance() {
    26.         return true;
    27.     }
    28. }
    29.  
    30. //定义切点类
    31. public class MapperMethodPointCut implements Pointcut {
    32.     public MapperMethodPointCut() {
    33.     }
    34.  
    35.     public ClassFilter getClassFilter() {
    36.         return new MyClassFilter();
    37.     }
    38.  
    39.     public MethodMatcher getMethodMatcher() {
    40.         return new MyMethodMatcher();
    41.     }
    42.  
    43.  
    44.     public boolean isRuntime() {
    45.         return false;
    46.     }
    47.  
    48. 	//定义ClassFilter接口实例类并定义切点判断逻辑
    49. 	class MyClassFilter implements ClassFilter{
    50. 		  @Override
    51.            public boolean matches(Class clazz) {
    52.                 // 如果mapper包下的包含Mapper注解就返回true 作为切点
    53.                 if (clazz != null && StringUtils.contains(clazz.getName(), "cn.demo.mapper")) {
    54. 					return aClass.getSuperclass().getName().equals(Proxy.class.getName()) && aClass.getInterfaces()[0].isAnnotationPresent(Mapper.class);
    55.                 }
    56.                 return false;
    57.             }
    58. 	}
    59. 	//定义MethodMatcher接口实例类并定义切点判断逻辑
    60. 	class MyMethodMatcher implements MethodMatcher{
    61. 	
    62.             //判断方法是否匹配
    63.             @Override
    64.             public boolean matches(Method method, Class targetClass, Object... args) {
    65.                 return true;
    66.             }
    67.  
    68.            //判断方法是否匹配
    69.             @Override
    70.             public boolean matches(Method method, Class targetClass) {
    71.                 return true;
    72.             }
    73.  
    74.             @Override
    75.             public boolean isRuntime() {
    76.                 return false;
    77.             }
    78. 	}
    79. }
    80.  
    81. //定义通知逻辑
    82. public class MapperMethodAdvise implements MethodInterceptor {
    83.     private Environment environment;
    84.     private ApplicationContext applicationContext;
    85.  
    86.     public MapperMethodAdvise(Environment environment, ApplicationContext applicationContext) {
    87.         this.environment = environment;
    88.         this.applicationContext = applicationContext;
    89.     }
    90.  
    91.     public Object invoke(MethodInvocation methodInvocation) throws Throwable {
    92.         return methodInvocation.proceed();
    93.     }
    94.  
    95. }

     

    如果切面织入即PointcutAdvisor接口类也自己定义，则需要借助BeanDefinitionRegistryPostProcessor扩展接口把切面实例注入到Spring中才生效。

    1. //定义BeanDefinitionRegistryPostProcessor注册PointcutAdvisor实例的BD
    2. public class MapperMethodPropertyProcessor implements PriorityOrdered, BeanDefinitionRegistryPostProcessor {
    3.     public MapperMethodPropertyProcessor() {
    4.     }
    5.  
    6.     public int getOrder() {
    7.         return 0;
    8.     }
    9.  
    10.     public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistry) throws BeansException {
    11.         BeanDefinition beanDefinition = BeanDefinitionBuilder.genericBeanDefinition(MapperMethodAdviceBean.class).getBeanDefinition();
    12.         beanDefinitionRegistry.registerBeanDefinition(MapperMethodAdviceBean.class.getName(), beanDefinition);
    13.     }
    14.  
    15.     public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {
    16.     }
    17. }
    18.  
    19. //配置自定义的BeanDefinitionRegistryPostProcessor注册到Spring容器
    20. @Configuration
    21. public class MapperMethodProxyAutoConfiguration {
    22.     public MapperMethodProxyAutoConfiguration() {
    23.     }
    24.  
    25.     @Bean
    26.     public MapperMethodPropertyProcessor mapperMethodPropertyProcessor() {
    27.         return new MapperMethodPropertyProcessor();
    28.     }
    29. }

  • 相关阅读:
    Nacos入门
    程序员的数学课15 递归：如何计算汉诺塔问题的移动步数？
    通过SSH远程登录华为设备
    PyQt5 QDialog对话框(QMessageBox,QInputDialog,QFontDialog,QFileDialog,QColorDialog)
    Java并发编程的艺术笔记-Java并发编程基础
    pycharm2020无法打开，点击无反应
    C++-Mongoose(1)-http-server
    化工行业供应商协同管理系统：助力企业打造良好营商环境，提升运营效率
    浅谈JVM(面试常考)
    codeforces每日5题(均1700)-第六天
  • 原文地址：https://blog.csdn.net/qq_29569183/article/details/126441749