经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Spring » 查看文章
Spring声明式事务注解之@EnableTransactionManagement解析
来源:jb51  时间:2021/8/9 13:56:33  对本文有异议

Spring声明式事务注解之@EnableTransactionManagement

1. 说明

@EnableTransactionManagement声明在主配置类上,表示开启声明式事务,其原理是通过@Import导入TransactionManagementConfigurationSelector组件,然后又通过TransactionManagementConfigurationSelector导入组件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;

2. 原理分析

@EnableTransactionManagement代码实现如下:

  1. @Target(ElementType.TYPE)
  2. @Retention(RetentionPolicy.RUNTIME)
  3. @Documented
  4. // 通过@Import导入TransactionManagementConfigurationSelector组件
  5. @Import(TransactionManagementConfigurationSelector.class)
  6. public @interface EnableTransactionManagement {
  7. boolean proxyTargetClass() default false;
  8. AdviceMode mode() default AdviceMode.PROXY;
  9. int order() default Ordered.LOWEST_PRECEDENCE;
  10. }

@EnableTransactionManagement通过@Import导入TransactionManagementConfigurationSelector;

TransactionManagementConfigurationSelector的实现如下:

  1. public class TransactionManagementConfigurationSelector extends AdviceModeImportSelector<EnableTransactionManagement> {
  2. /**
  3. * {@inheritDoc}
  4. * @return {@link ProxyTransactionManagementConfiguration} or
  5. * {@code AspectJTransactionManagementConfiguration} for {@code PROXY} and
  6. * {@code ASPECTJ} values of {@link EnableTransactionManagement#mode()}, respectively
  7. */
  8. @Override
  9. protected String[] selectImports(AdviceMode adviceMode) {
  10. switch (adviceMode) {
  11. case PROXY:
  12. // 根据@EnableTransactionManagement的固定值PROXY,这里会导入AutoProxyRegistrar组件和ProxyTransactionManagementConfiguration组件
  13. return new String[] {AutoProxyRegistrar.class.getName(), ProxyTransactionManagementConfiguration.class.getName()};
  14. case ASPECTJ:
  15. return new String[] {TransactionManagementConfigUtils.TRANSACTION_ASPECT_CONFIGURATION_CLASS_NAME};
  16. default:
  17. return null;
  18. }
  19. }
  20. }

所以TransactionManagementConfigurationSelector又导入了组件AutoProxyRegistrar和ProxyTransactionManagementConfiguration;

3. AutoProxyRegistrar分析

3.1 AutoProxyRegistrar继承关系

  1. InfrastructureAdvisorAutoProxyCreator
  2. --AbstractAdvisorAutoProxyCreator
  3. --AbstractAdvisorAutoProxyCreator
  4. --ProxyProcessorSupport
  5. --SmartInstantiationAwareBeanPostProcessor // 跟AOP是原理是一样的
  6. --InstantiationAwareBeanPostProcessor
  7. --BeanPostProcessor
  8. --BeanFactoryAware

3.2 AutoProxyRegistrar的所用

AutoProxyRegistrar的作用跟AOP中的AnnotationAwareAspectJAutoProxyCreator是一样的,利用后置处理器机制在对象创建以后,包装对象,返回一个代理对象(增强器),代理对象执行方法利用拦截器链进行调用;InfrastructureAdvisorAutoProxyCreator继承SmartInstantiationAwareBeanPostProcessor,跟AOP的原理是一样的,也是通过@Transactional作为方法拦截的标记,把有事务管理的类作为目标类,生成代理对象,然后增强@Transactional标记的方法,在使用目标方法的时候,从IOC容器中获取的其实是被增强的代理类,且事务方法会被代理,跟AOP原理一样的;

4. ProxyTransactionManagementConfiguration分析

ProxyTransactionManagementConfiguration是一个配置类,想IOC容器中导入事务增强器(BeanFactoryTransactionAttributeSourceAdvisor),事务注解@Transactional的解析器(AnnotationTransactionAttributeSource)和事务方法拦截器(TransactionInterceptor);

  1. package org.springframework.transaction.annotation;
  2. import org.springframework.beans.factory.config.BeanDefinition;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.context.annotation.Role;
  6. import org.springframework.transaction.config.TransactionManagementConfigUtils;
  7. import org.springframework.transaction.interceptor.BeanFactoryTransactionAttributeSourceAdvisor;
  8. import org.springframework.transaction.interceptor.TransactionAttributeSource;
  9. import org.springframework.transaction.interceptor.TransactionInterceptor;
  10. @Configuration
  11. public class ProxyTransactionManagementConfiguration extends AbstractTransactionManagementConfiguration {
  12. /**
  13. 事务增强器(Advisor),在事务类创建的时候,被AutoProxyRegistrar导入的组件InfrastructureAdvisorAutoProxyCreator拦截,
  14. InfrastructureAdvisorAutoProxyCreator拦截的逻就是增强事务类的事务方法, 而BeanFactoryTransactionAttributeSourceAdvisor作为增强器,
  15. 与需要增强的方法(这里是指被@Transactional标记的方法)进行匹配,匹配成功的增强器,最后转成拦截器(MethodInterceptor,
  16. 就是下面的TransactionInterceptor),然后与目标方法一起在拦截器链中被执行,达到方法增强的效果;
  17. BeanFactoryTransactionAttributeSourceAdvisor的继承关系如下:
  18. BeanFactoryTransactionAttributeSourceAdvisor
  19. --AbstractBeanFactoryPointcutAdvisor
  20. --AbstractPointcutAdvisor
  21. --PointcutAdvisor
  22. --Advisor
  23. AOP中AspectJPointcutAdvisor的继承关系如下,与AbstractPointcutAdvisor一样,都实现PointcutAdvisor
  24. --AspectJPointcutAdvisor
  25. --PointcutAdvisor
  26. --Advisor
  27. */
  28. @Bean(name = TransactionManagementConfigUtils.TRANSACTION_ADVISOR_BEAN_NAME)
  29. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  30. public BeanFactoryTransactionAttributeSourceAdvisor transactionAdvisor() {
  31. BeanFactoryTransactionAttributeSourceAdvisor advisor = new BeanFactoryTransactionAttributeSourceAdvisor();
  32. advisor.setTransactionAttributeSource(transactionAttributeSource());
  33. advisor.setAdvice(transactionInterceptor());
  34. advisor.setOrder(this.enableTx.<Integer>getNumber("order"));
  35. return advisor;
  36. }
  37. /**
  38. @Transactional注解的解析类;负责解析事务方法上@Transactional中的各个参数配置,解析的时机是在创建事务类之后被增强的时候,
  39. 匹配事务方法的时候一起被解析了
  40. AnnotationTransactionAttributeSource的继承关系如下:
  41. AnnotationTransactionAttributeSource
  42. --AbstractFallbackTransactionAttributeSource
  43. --TransactionAttributeSource
  44. 通过方法org.springframework.transaction.interceptor.AbstractFallbackTransactionAttributeSource.getTransactionAttribute(Method, Class<?>)
  45. 解析出事务信息TransactionAttribute;
  46. AnnotationTransactionAttributeSource在方法findTransactionAttribute(Class<?>)中依赖于SpringTransactionAnnotationParser在解析事务类时,
  47. 绑定事务方法与增强器的时候进行@Transactional注解解析;
  48. */
  49. @Bean
  50. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  51. public TransactionAttributeSource transactionAttributeSource() {
  52. return new AnnotationTransactionAttributeSource();
  53. }
  54. /**
  55. 被@Transactional标记的事务方法的拦截器,实际是一个MethodInterceptor
  56. 保存了事务属性信息,事务管理器;
  57. 在目标方法执行的时候;执行拦截器链;
  58. */
  59. @Bean
  60. @Role(BeanDefinition.ROLE_INFRASTRUCTURE)
  61. public TransactionInterceptor transactionInterceptor() {
  62. TransactionInterceptor interceptor = new TransactionInterceptor();
  63. interceptor.setTransactionAttributeSource(transactionAttributeSource());
  64. if (this.txManager != null) {
  65. interceptor.setTransactionManager(this.txManager);
  66. }
  67. return interceptor;
  68. }
  69. }

在SpringTransactionAnnotationParser中parseTransactionAnnotation方法来解析@Transactional中的各个参数,其具体代码如下:

  1. protected TransactionAttribute parseTransactionAnnotation(AnnotationAttributes attributes) {
  2. RuleBasedTransactionAttribute rbta = new RuleBasedTransactionAttribute();
  3. Propagation propagation = attributes.getEnum("propagation");
  4. rbta.setPropagationBehavior(propagation.value());
  5. Isolation isolation = attributes.getEnum("isolation");
  6. rbta.setIsolationLevel(isolation.value());
  7. rbta.setTimeout(attributes.getNumber("timeout").intValue());
  8. rbta.setReadOnly(attributes.getBoolean("readOnly"));
  9. rbta.setQualifier(attributes.getString("value"));
  10. ArrayList<RollbackRuleAttribute> rollBackRules = new ArrayList<RollbackRuleAttribute>();
  11. Class<?>[] rbf = attributes.getClassArray("rollbackFor");
  12. for (Class<?> rbRule : rbf) {
  13. RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule);
  14. rollBackRules.add(rule);
  15. }
  16. String[] rbfc = attributes.getStringArray("rollbackForClassName");
  17. for (String rbRule : rbfc) {
  18. RollbackRuleAttribute rule = new RollbackRuleAttribute(rbRule);
  19. rollBackRules.add(rule);
  20. }
  21. Class<?>[] nrbf = attributes.getClassArray("noRollbackFor");
  22. for (Class<?> rbRule : nrbf) {
  23. NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule);
  24. rollBackRules.add(rule);
  25. }
  26. String[] nrbfc = attributes.getStringArray("noRollbackForClassName");
  27. for (String rbRule : nrbfc) {
  28. NoRollbackRuleAttribute rule = new NoRollbackRuleAttribute(rbRule);
  29. rollBackRules.add(rule);
  30. }
  31. rbta.getRollbackRules().addAll(rollBackRules);
  32. return rbta;
  33. }

spring 事务 @EnableTransactionManagement原理

@EnableXXX原理:注解上有个XXXRegistrar,或通过XXXSelector引入XXXRegistrar,XXXRegistrar实现了ImportBeanDefinitionRegistrar的registerBeanDefinitions方法,给容器注册XXXCreator。

这个Creator实现了后置处理器,后置处理器在对象创建以后,包装对象,返回一个代理对象,代理对象执行方法利用拦截器链进行调用

1)、@EnableTransactionManagement

利用TransactionManagementConfigurationSelector给容器中会导入组件

导入两个组件

  1. AutoProxyRegistrar
  2. ProxyTransactionManagementConfiguration

2)、AutoProxyRegistrar:

给容器中注册一个 InfrastructureAdvisorAutoProxyCreator 组件;

利用后置处理器机制在对象创建以后,包装对象,返回一个代理对象(增强器),代理对象执行方法利用拦截器链进行调用;

3)、ProxyTransactionManagementConfiguration是个@Configuration

1、给容器中注册事务增强器transactionAdvisor;

1)、事务增强器要用事务注解的信息,AnnotationTransactionAttributeSource解析事务注解

2)、事务拦截器transactionInterceptor:

TransactionInterceptor;保存了事务属性信息,事务管理器;

TransactionInterceptor是一个 MethodInterceptor;

在目标方法执行的时候;

执行拦截器链;

只有事务拦截器:

1)、先获取事务相关的属性

2)、再获取PlatformTransactionManager,如果事先没有添加指定任何transactionmanger 最终会从容器中按照类型获取一个PlatformTransactionManager;

3)、执行目标方法

如果异常,获取到事务管理器,利用事务管理回滚操作;

如果正常,利用事务管理器,提交事务

以上为个人经验,希望能给大家一个参考,也希望大家多多支持w3xue。

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号