深入了解Spring中的AOP

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

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

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

 

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

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

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

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

启动时，会出现：

 
 
 
 
    
  
  
  
  
  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. 
  
  
  
  
  2.  
    3. 
  
  
  
  
  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. 
  
  
  
  
  4.  
    5. 
  
  
  
  
  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. 
  
  
  
  
  6.  
    7. 
  
  
  
  
  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) 
    8.

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

AspectJ方式实现切面 

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

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

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

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

本文标题：深入了解Spring中的AOP
分享地址：http://www.gawzjz.com/qtweb2/news10/5160.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

App开发知识

同城分类信息

微信小程序开发　　 　高端网站建设　　 　网站建设改版　　 　广汉锦华建材　　 　成都网站排名　　 　成都logo设计公司　　 　网络推广　　 　led无边发光字　　 　工业净化空调　　 　背发光字　　 　手机网站　　 　眉山网站建设　　 　产品包装设计　　 　成都网站优化　　 　主机租用　　 　成都网站制作　　 　简阳服务器托管　　 　电信内江机房　　 　乐山做网站　　 　成都SEO公司