|
|
51CTO旗下网站
|
|
移步端
创造专栏

深入了解Spring中的AOP

提起AOP,大家都晓得是面向切面编程,但你真的询问Spring中的AOP吗?Spring AOP、JDK动态代理、CGLIB、AspectJ之间又有什么关系和区别?

笔者:舟谱数据首席架构师汤定一| 2019-11-29 16:21

提起AOP,大家都晓得是面向切面编程,但你真的询问Spring中的AOP吗?Spring AOP、JDK动态代理、CGLIB、AspectJ之间又有什么关系和区别?

在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,阻碍方法

      
  1. public class MethodParamInterceptor implements MethodInterceptor { 
  2.  
  3. @Override 
  4.  
  5. @SuppressWarnings("unchecked"
  6.  
  7. public Object invoke(MethodInvocation invocation) throws Throwable { 
  8.  
  9. Object[] params = invocation.getArguments(); 
  10.  
  11. if (ArrayUtils.isEmpty(params)) { 
  12.  
  13. return invocation.proceed(); 
  14.  
  15.  
  16. for (Object param : params) { 
  17.  
  18. //如果参数类型是Map 
  19.  
  20. if (param instanceof Map) { 
  21.  
  22. Map paramMap = (Map) param; 
  23.  
  24. processPage(paramMap); 
  25.  
  26. break; 
  27.  
  28.  
  29.  
  30. return invocation.proceed(); 
  31.  
  32.  
  33. /** 
  34.  
  35.  
  36. * @param paramMap 
  37.  
  38. */ 
  39.  
  40. private void processPage(Map paramMap) { 
  41.  
  42. if (!paramMap.containsKey("page") && !paramMap.containsKey("limit")) { 
  43.  
  44. return
  45.  
  46.  
  47. int page = 1; 
  48.  
  49. int rows = 10; 
  50.  
  51. for (Map.Entry entry : paramMap.entrySet()) { 
  52.  
  53. String key = entry.getKey(); 
  54.  
  55. String value = entry.getValue().toString(); 
  56.  
  57. if ("page".equals(key)) { 
  58.  
  59. page = NumberUtils.toInt(value, page); 
  60.  
  61. else if ("limit".equals(key)) { 
  62.  
  63. rows = NumberUtils.toInt(value, rows); 
  64.  
  65. }else { 
  66.  
  67. //TODO 
  68.  
  69.  
  70.  
  71. int offset = (page - 1) * rows
  72.  
  73. paramMap.put("offset", offset); 
  74.  
  75. paramMap.put("rows"rows); 
  76.  
  77.  

2、定义后置处理器,名将方法拦截件加入到advisor官方。咱们通过注解@Controller阻碍所有的Controller,@RestController连续于Controller,故此统一拦截了。

      
  1. public class RequestParamPostProcessor extends AbstractBeanFactoryAwareAdvisingPostProcessor 
  2.  
  3. implements InitializingBean { 
  4.  
  5. private Class validatedAnnotationType = Controller.class; 
  6.  
  7. @Override 
  8.  
  9. public void afterPropertiesSet() throws Exception { 
  10.  
  11. Pointcut pointcut = new AnnotationMatchingPointcut(this.validatedAnnotationType, true); 
  12.  
  13. this.advisor = new DefaultPointcutAdvisor(pointcut, new MethodParamInterceptor()); 
  14.  
  15.  

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

      
  1. @Configuration 
  2.  
  3. public class MethodInterceptorConfig { 
  4.  
  5. @Bean 
  6.  
  7. public RequestParamPostProcessor converter() { 
  8.  
  9. return new RequestParamPostProcessor(); 
  10.  
  11.  
  12. }` 

此地有个坑需要注意一下,如果在安排类中注入业务Bean。

      
  1. @Configuration 
  2.  
  3. public class MethodInterceptorConfig { 
  4.  
  5. @Autowired 
  6.  
  7. private UserService userService; 
  8.  
  9. @Bean 
  10.  
  11. public RequestParamPostProcessor converter() { 
  12.  
  13. return new RequestParamPostProcessor(); 
  14.  
  15.  

起先时,会出现:

      
  1. 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) 
  2.  
  3. 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) 
  4.  
  5. 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) 
  6.  
  7. 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办法实现切面

      
  1. @Component@Aspect@Slf4jpublic class MethodParamInterceptor { 
  2.  
  3.     @Pointcut("@annotation(org.springframework.web.bind.annotation.PostMapping)"
  4.     public void paramAspect() { 
  5.  
  6.     } 
  7.  
  8.  
  9.     @Before("paramAspect()"
  10.     public void beforeDataSource(JoinPoint joinPoint) { 
  11.         Arrays.stream(joinPoint.getArgs()).forEach(paramObject -> { 
  12.             if (paramObject instanceof Map) { 
  13.                 Map parameter = (Map) paramObject; 
  14.                 processPage(parameter); 
  15.             } 
  16.         }); 
  17.  
  18.     } 
  19.  
  20.     private void processPage(Map<String, Object> paramMap) { 
  21.         if (null == paramMap) { 
  22.             return
  23.         } 
  24.         if (!paramMap.containsKey("page") && !paramMap.containsKey("limit")) { 
  25.             return
  26.         } 
  27.         int page = 1; 
  28.         int rows = 10; 
  29.         for (Map.Entry<String, Object> entry : paramMap.entrySet()) { 
  30.             String key = entry.getKey(); 
  31.             String value = entry.getValue().toString(); 
  32.             if ("page".equals(key)) { 
  33.                 page = NumberUtils.toInt(value, page); 
  34.             } else if ("limit".equals(key)) { 
  35.                 rows = NumberUtils.toInt(value, rows); 
  36.             } 
  37.         } 
  38.         int offset = (page - 1) * rows
  39.         paramMap.put("offset", offset); 
  40.         paramMap.put("rows"rows); 
  41.     } 
  42.  
  43.  
  44.     @After("paramAspect()"
  45.     public void afterDataSource(JoinPoint joinPoint) { 
  46.  
  47.     } 

副上面两个比喻可以对比出SpringAOP和AspectJ的两种不同用法,但达到的力量是一样的。

Sping AOP在集体、空泛代码场景中更加适合,AspectJ用于单纯的平面来促成某项意义更加简洁。

【本文是51CTO专栏机构“舟谱数据”的原创文章,微信公众号“舟谱数据( id: zhoupudata)”】

戳这里,瞧该作者更多好文

【编纂推荐】

  1. 2019机器学习框架之争:与Tensorflow竞争白热化,进击的PyTorch赢在哪儿?
  2. 吐血整理!14个编写Spring MVC玉器的适用小技巧
【义务编辑: 华轩 TEL:(010)68476606】

点赞 0
  • Spring  框架  合并
  • 分享:
    大家都在看
    猜你喜欢
  • 
       
    &lt;optgroup id="bac9ebdf"&gt;&lt;/optgroup&gt;