详解Spring中AOP

AOP (Aspect Orient Programming),直译过来就是 面向切面编程。AOP 是一种编程思想,是面向对象编程(OOP)的一种补充。面向对象编程将程序抽象成各个层次的对象,而面向切面编程是将程序抽象成各个切面。

在Spring中AOP包含两个概念,一是Spring官方基于JDK动态代理和CGLIB实现的Spring AOP;二是集成面向切面编程神器AspectJ。Spring AOP和AspectJ不是竞争关系,基于代理的框架的Spring AOP和成熟框架AspectJ都是有价值的,它们是互补的。

Spring无缝地将Spring AOP、IoC与AspectJ集成在一起,从而达到AOP的所有能力。Spring AOP默认将标准JDK动态代理用于AOP代理,可以代理任何接口。但如果没有面向接口编程,只有业务类,则使用CGLIB。当然也可以全部强制使用CGLIB,只要设置proxy-target-class=”true”。

AOP中的术语

通知(Advice)

Spring切面可以应用5种类型的通知:

前置通知(Before):在目标方法被调用之前调用通知功能;

后置通知(After):在目标方法完成之后调用通知,此时不会关心方法的输出是什么;

返回通知(After-returning):在目标方法成功执行之后调用通知;

异常通知(After-throwing):在目标方法抛出异常后调用通知;

环绕通知(Around):通知包裹了被通知的方法,在被通知的方法调用之前和调用之后执行自定义的行为。

连接点(Join point)

切点(Poincut)

切面(Aspect)

引入(Introduction)

织入(Weaving)

这些术语的解释,其他博文中很多,这里就不再赘述。

用2个例子来说明Spring AOP和AspectJ的用法

现在有这样一个场景,页面传入参数当前页page和每页展示多少条数据rows,我们需要写个拦截器将page、limit参数转换成MySQL的分页语句offset、rows。

先看Spring AOP实现

1、实现MethodInterceptor,拦截方法

public class MethodParamInterceptor implements MethodInterceptor {

@Override

@SuppressWarnings("unchecked")

public Object invoke(MethodInvocation invocation) throws Throwable {

Object[] params = invocation.getArguments();

if (ArrayUtils.isEmpty(params)) {

return invocation.proceed();

}

for (Object param : params) {

//如果参数类型是Map

if (param instanceof Map) {

Map paramMap = (Map) param;

processPage(paramMap);

break;

}

}

return invocation.proceed();

}

/**

*

* @param paramMap

*/

private void processPage(Map paramMap) {

if (!paramMap.containsKey("page") && !paramMap.containsKey("limit")) {

return;

}

int page = 1;

int rows = 10;

for (Map.Entry entry : paramMap.entrySet()) {

String key = entry.getKey();

String value = entry.getValue().toString();

if ("page".equals(key)) {

page = NumberUtils.toInt(value, page);

} else if ("limit".equals(key)) {

rows = NumberUtils.toInt(value, rows);

}else {

//TODO

}

}

int offset = (page - 1) * rows;

paramMap.put("offset", offset);

paramMap.put("rows", rows);

}

}

2、定义后置处理器,将方法拦截件加入到advisor中。我们通过注解@Controller拦截所有的Controller,@RestController继承于Controller,所以统一拦截了。

public class RequestParamPostProcessor extends AbstractBeanFactoryAwareAdvisingPostProcessor

implements InitializingBean {

private Class validatedAnnotationType = Controller.class;

@Override

public void afterPropertiesSet() throws Exception {

Pointcut pointcut = new AnnotationMatchingPointcut(this.validatedAnnotationType, true);

this.advisor = new DefaultPointcutAdvisor(pointcut, new MethodParamInterceptor());

}

}

3、万事俱备只欠东风,Processor也写好了,只需要让Processor生效。

@Configuration

public class MethodInterceptorConfig {

@Bean

public RequestParamPostProcessor converter() {

return new RequestParamPostProcessor();

}

}`

这里有个坑需要注意一下,如果在配置类中注入业务Bean。

@Configuration

public class MethodInterceptorConfig {

@Autowired

private UserService userService;

@Bean

public RequestParamPostProcessor converter() {

return new RequestParamPostProcessor();

}

}

启动时,会出现:

2019-11-08 14:55:50.954 INFO 51396 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'sqlSessionFactory' of type [org.apache.ibatis.session.defaults.DefaultSqlSessionFactory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

2019-11-08 14:55:50.960 INFO 51396 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'sqlSessionTemplate' of type [org.mybatis.spring.SqlSessionTemplate] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

2019-11-08 14:55:51.109 INFO 51396 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'rememberMapper' of type [com.sun.proxy.$Proxy84] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

2019-11-08 14:55:53.406 INFO 51396 --- [ main] trationDelegate$BeanPostProcessorChecker : Bean 'org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration' of type [org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)

很多切面失效,如事务切面。这是因为注入了自定义的Bean,自定义的Bean优先级最低,由最低优先级的BeanPostProcessor来加载并完成初始化的。但为了加载其中的RequestParamPostProcessor,导致不得不优先装载低优先级Bean,此时事务处理器的AOP等都还没完成加载,注解事务初始化都失败了。但Spring就提示了一个INFO级别的提示,然后剩下的Bean由最低优先级的BeanPostProcessor正常处理。

AspectJ方式实现切面

@Component@Aspect@Slf4jpublic class MethodParamInterceptor {

   @Pointcut("@annotation(org.springframework.web.bind.annotation.PostMapping)")
   public void paramAspect() {

   }


   @Before("paramAspect()")
   public void beforeDataSource(JoinPoint joinPoint) {
       Arrays.stream(joinPoint.getArgs()).forEach(paramObject -> {
           if (paramObject instanceof Map) {
               Map parameter = (Map) paramObject;
               processPage(parameter);
           }
       });

   }

   private void processPage(Map
  
    paramMap) {        
   if (null == paramMap) {            
   ret        }        
   if (!paramMap.containsKey(
   "page") && !paramMap.containsKey(
   "limit")) {            
   return;        }        int page = 1;        int rows = 10;        
   for (Map.Entry
   
     entry : paramMap.entrySet()) {            String key = entry.getKey();            String value = entry.getValue().toString();            
    if (
    "page".equals(key)) {                page = NumberUtils.toInt(value, page);            } 
    else 
    if (
    "limit".equals(key)) {                rows = NumberUtils.toInt(value, rows);            }        }        int offset = (page - 1) * rows;        paramMap.put(
    "offset", offset);        paramMap.put(
    "rows", rows);    }    @After(
    "paramAspect()")    public void afterDataSource(JoinPoint joinPoint) {    } } 
   
  

从上面两个例子可以对比出SpringAOP和AspectJ的两种不同用法,但达到的能力是一样的。

Sping AOP在组织、抽象代码场景中更加适合,AspectJ用于单纯的切面来实现某项功能更加简洁。

原创文章,作者:晴川运维,如若转载,请注明出处:https://baike.qcidc.com/10789.html

(0)
晴川运维晴川运维
上一篇 2025年6月28日
下一篇 2025年6月28日

相关推荐

  • Java基础HashSet使用详解

    HashSet 基于 HashMap 来实现的,是一个不允许有重复元素的集合。HashSet 允许有 null 值。HashSet 是无序的,即不会记录插入的顺序。 一. Hash…

    Linux系统 2025年7月5日
  • Linux下生成高强度密码具体方法

    现在信息泄露越来越严重,而强大的密码是防止个人敏感信息泄露的第一步,本篇文章重点为大家讲解一下Linux下生成高强度密码具体方法。 1. 在 Linux 中使用 OpenSSL 来…

    Linux系统 2025年10月20日
  • 简单介绍一下存储虚拟化技术

    存储虚拟化技术其实不是一个新东西,在很早以前就有了存储虚拟化技术。技术发展到今天,在存储虚拟化技术之上又诞生了其他很多新的概念和技术。 数据在整个计算机系统是最重要的一部分,也是最…

    Linux系统 2025年9月24日
  • 如何使用Cobbler 快速安装系统

    Cobbler 可以用来快速建立 Linux 网络安装环境,它已将 Linux 网络安装的技术门槛,从大专以上文化水平,成功降低到初中以下,连补鞋匠都能学会,本篇文章重点为大家讲解…

    Linux系统 2025年10月5日
  • Linux下查看网卡流量具体方法

    Linux如何查看网卡流量?在工作中,我们经常需要查看服务器的实时网卡流量,本篇文章将重点为大家讲解一下Linux下查看网卡流量具体方法, 有需要的小伙伴可以参考一下。 img 方…

    Linux系统 2025年6月8日
  • 如何使用Python实现多任务版的udp聊天器

    本篇文章将为大家分享一下如何使用Python实现多任务版的udp聊天器,结合具体案例形式分析了Python基于udp的聊天器功能相关实现与使用技巧,有需要的小伙伴可以参考一下。 一…

    Linux系统 2025年6月26日
  • mysql实现高可用架构之MHA

    MHA(Master HA)是一款开源的 MySQL 的高可用程序,它为 MySQL 主从复制架构提供了 automating master failover 功能。MHA 在监控…

    Linux系统 2025年6月10日
  • 详解rsync的使用方法

    rsync 是一个常用的 Linux 应用程序,用于文件同步,它可以在本地计算机与远程计算机之间,或者两个本地目录之间同步文件(但不支持两台远程计算机之间的同步)。它也可以当作文件…

    Linux系统 2025年9月19日
  • Linux部署AutoFs挂载服务

    Autofs非常方便,主要有两点: 1、设置开机不一定要挂载的目录,当用的时候才实现自动挂载。 2、用户不使用自动挂载的目录一段的时间,会自动卸载。(默认时间为5分钟) [root…

    Linux系统 2025年6月8日
  • Shell 脚本演练:日志关键字监控+自动告警

    该程序使用场景说明:主要用于Linux服务器监控程序日志,如出现关键字异常则触发相应的动作或告警操作,通知到邮件联系人。 一、安装邮件服务 1、解压 tar -jxf&n…

    Linux系统 2025年6月14日

发表回复

登录后才能评论