当前位置：首页 > news >正文

Spring的xml方式声明式事务控制

news 2026/5/11 20:33:03

Spring的xml方式声明式事务控制

一、概述

前面我们讲了Spring的AOP配置，但是这种直接配置在开发中使用得较少，一般是事务控制使用得较多，在事务控制中利用的也是AOP的原理，只不过把事务是当作AOP当中的通知，且这个通知由Spring来产生，我们只负责配置，下面就事务的一些知识和xml方式声明式事务控制进行讲解：

二、实验

以转账来进行实验，如果让加钱和减钱各自一个事务的话，那么当出现异常情况时，可能是减钱了，但是另一个账户没有加钱的情况：所以要将加钱和减钱组成一个事务：

<?xml version="1.0"encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd "><!--组件扫描--><context:component-scan base-package="com.itheima"/><!--加载properties文件--><context:property-placeholder location="classpath:jdbc.properties"/><!--配置数据源信息--><bean id="dataSource"class="com.alibaba.druid.pool.DruidDataSource"><property name="driverClassName"value="${jdbc.driver}"></property><property name="url"value="${jdbc.url}"></property><property name="username"value="${jdbc.username}"></property><property name="password"value="${jdbc.password}"></property></bean><!--配置SqlSessionFactoryBean，作用将SqlSessionFactory存储到spring容器--><beanclass="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource"ref="dataSource"></property></bean><!--MapperScannerConfigurer,作用扫描指定的包，产生Mapper对象存储到Spring容器--><beanclass="org.mybatis.spring.mapper.MapperScannerConfigurer"><property name="basePackage"value="com.itheima.mapper"></property></bean><!--还要配置事物管理器，在编程式事务中讲过事物管理器具有回滚、获得、提交事务对象的功能，不同框架的事务管理器不同--><!--底层是mybatis，mybatis底层是jdbc,jdbc需要connection，所以要数据源--><beanclass="org.springframework.jdbc.datasource.DataSourceTransactionManager"id="transactionManager"><property name="dataSource"ref="dataSource"/></bean><!--然后是要配置通知，因为这个通知是Spring提供的，所以需要用到tx标签--><tx:advice id="txadvice"transaction-manager="transactionManager"><tx:attributes><tx:method name="*"/></tx:attributes></tx:advice><!--使用advisor配置AOP--><aop:config><aop:pointcut id="txPointcut"expression="execution(* com.itheima.service.impl.*.*(..))"/><!--配置织入--><aop:advisor advice-ref="txadvice"pointcut-ref="txPointcut"/></aop:config></beans>

先是从下往上配要用Spring的事务的话（也就是通知）就需要使用advisor配置织入，而且配置通知时需要使用tx标签，其中事务中又要配transaction-manager事务管理器，一般要配置事务管理器的话都要实现，它的继承关系如下：

在这里Dao层使用的框架是mybatis，mybatis底层是jdbc,jdbc需要connection，所以要数据源，配置的是DataSourceTransactionManager，且要指定数据源。同时在通知中还要指定method。这样加钱和减钱组成一个事务，出现异常加钱和减钱都不能完成了：

packagecom.itheima.service.impl;importcom.itheima.mapper.AccountMapper;importcom.itheima.service.AccountService;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service;importorg.springframework.transaction.annotation.Isolation;importorg.springframework.transaction.annotation.Propagation;importorg.springframework.transaction.annotation.Transactional;@Service("accountService")@Transactional(isolation=Isolation.READ_COMMITTED,propagation=Propagation.REQUIRED)publicclassAccountServiceImpl2implementsAccountService{@AutowiredprivateAccountMapperaccountMapper;@OverridepublicvoidtransferMoney(StringoutAccount,StringinAccount,Integermoney){// 如果是编程类事务的话：先开一个事务，然后try catch以下有异常就回滚accountMapper.decrMoney(outAccount,money);inti=1/0;accountMapper.incrMoney(inAccount,money);}publicvoidregistAccount(){}}

packagecom.itheima;importcom.itheima.config.SpringConfig;importcom.itheima.service.AccountService;importorg.springframework.context.ApplicationContext;importorg.springframework.context.annotation.AnnotationConfigApplicationContext;importorg.springframework.context.support.ClassPathXmlApplicationContext;publicclassAccountTest{publicstaticvoidmain(String[]args){ApplicationContextapp=newClassPathXmlApplicationContext("applicationContext.xml");//ApplicationContext app = new AnnotationConfigApplicationContext(SpringConfig.class);AccountServiceaccountService=app.getBean(AccountService.class);accountService.transferMoney("tom","lucy",500);}}

结果：

钱是没有转成功的。

在这里值得注意的是tx的attributes属性：

name：方法名称 *代表通配符添加操作 addUser、addAccount、addOrders 可统一配置为 add *
isolation：事务的隔离级别，用于解决事务并发问题
timeout：超时时间，默认值为-1，单位是s
read-only：是否为只读模式，查询操作建议设置为只读
propagation：事务的传播行为，用于解决业务方法调用业务方法时出现的事务嵌套问题
要是没有设置这些属性。会应用数据库默认的，但是必须加上<tx:method name=“*”/>，在项目中常常是这样设置（各大功能一个，留一个保底的）：

<tx:method name="add*"/><tx:method name="update*"/><tx:method name="delete*"/><tx:method name="select*"/><tx:method name="*"/>

一般是REQUIRED和SUPPORTS使用得多需要记住。

三、原理解析

tx:advice是通过xml配置的当然是找它的handler了：

http\://www.springframework.org/schema/tx=org.springframework.transaction.config.TxNamespaceHandler

进入TxNamespaceHandler：

//// Source code recreated from a .class file by IntelliJ IDEA// (powered by FernFlower decompiler)//packageorg.springframework.transaction.config;importorg.springframework.beans.factory.xml.NamespaceHandlerSupport;importorg.w3c.dom.Element;publicclassTxNamespaceHandlerextendsNamespaceHandlerSupport{staticfinalStringTRANSACTION_MANAGER_ATTRIBUTE="transaction-manager";staticfinalStringDEFAULT_TRANSACTION_MANAGER_BEAN_NAME="transactionManager";publicTxNamespaceHandler(){}staticStringgetTransactionManagerName(Elementelement){returnelement.hasAttribute("transaction-manager")?element.getAttribute("transaction-manager"):"transactionManager";}publicvoidinit(){this.registerBeanDefinitionParser("advice",newTxAdviceBeanDefinitionParser());this.registerBeanDefinitionParser("annotation-driven",newAnnotationDrivenBeanDefinitionParser());this.registerBeanDefinitionParser("jta-transaction-manager",newJtaTransactionManagerBeanDefinitionParser());}}

进入TxAdviceBeanDefinitionParser()，既然是Parser肯定有Parser方法，不在本类就在父类和爷爷类，这个是在爷爷类：

publicabstractclassAbstractBeanDefinitionParserimplementsBeanDefinitionParser{publicstaticfinalStringID_ATTRIBUTE="id";publicstaticfinalStringNAME_ATTRIBUTE="name";publicAbstractBeanDefinitionParser(){}@NullablepublicfinalBeanDefinitionparse(Elementelement,ParserContextparserContext){AbstractBeanDefinitiondefinition=this.parseInternal(element,parserContext);if(definition!=null&&!parserContext.isNested()){try{Stringid=this.resolveId(element,definition,parserContext);if(!StringUtils.hasText(id)){parserContext.getReaderContext().error("Id is required for element '"+parserContext.getDelegate().getLocalName(element)+"' when used as a top-level tag",element);}String[]aliases=null;if(this.shouldParseNameAsAliases()){Stringname=element.getAttribute("name");if(StringUtils.hasLength(name)){aliases=StringUtils.trimArrayElements(StringUtils.commaDelimitedListToStringArray(name));}}BeanDefinitionHolderholder=newBeanDefinitionHolder(definition,id,aliases);this.registerBeanDefinition(holder,parserContext.getRegistry());if(this.shouldFireEvents()){BeanComponentDefinitioncomponentDefinition=newBeanComponentDefinition(holder);this.postProcessComponentDefinition(componentDefinition);parserContext.registerComponent(componentDefinition);}}catch(BeanDefinitionStoreExceptionex){Stringmsg=ex.getMessage();parserContext.getReaderContext().error(msg!=null?msg:ex.toString(),element);returnnull;}}returndefinition;}

让端点到达tx:advice：

然后往下看还有一段：

BeanDefinitionHolderholder=newBeanDefinitionHolder(definition,id,aliases);this.registerBeanDefinition(holder,parserContext.getRegistry());

这是注册BeanDefinition，看对应的holder：

可以看到这是名为txadvice，值为TransactionInterceptor的类。

那么我们就分析TransactionInterceptor：

publicclassTransactionInterceptorextendsTransactionAspectSupportimplementsMethodInterceptor,Serializable{publicTransactionInterceptor(){}

发现它实现了MethodInterceptor接口，依据之前学过的Advisor配置AOP织入可以知道这相当于配置环绕通知，是通过它的invoke方法来配置的：

@NullablepublicObjectinvoke(MethodInvocationinvocation)throwsThrowable{Class<?>targetClass=invocation.getThis()!=null?AopUtils.getTargetClass(invocation.getThis()):null;Methodvar10001=invocation.getMethod();invocation.getClass();returnthis.invokeWithinTransaction(var10001,targetClass,invocation::proceed);}

targetClass：

进入invokeWithinTransaction：

}}else{TransactionInfotxInfo=this.createTransactionIfNecessary(ptm,txAttr,joinpointIdentification);ObjectretVal;try{retVal=invocation.proceedWithInvocation();}catch(Throwableex){

该有的都返回了，createTransactionIfNecessary就是开事务了，看到createTransactionIfNecessary，进入：

status=tm.getTransaction(txAttr);

去看tm是谁：

protectedTransactionInfocreateTransactionIfNecessary(@NullablePlatformTransactionManagertm,@NullableTransactionAttributetxAttr,finalStringjoinpointIdentification){

tm是PlatformTransactionManager，平台事务管理器

同时我们也看到了createTransactionIfNecessary中的参数ptm，那么它是什么呢？

PlatformTransactionManagerptm=this.asPlatformTransactionManager(tm);

tm又是：

TransactionManagertm=this.determineTransactionManager(txAttr);

到此为止，后面是最终是通过解析xml文件获取的。

再来看status = tm.getTransaction(txAttr);，进入getTransaction()：

publicfinalTransactionStatusgetTransaction(@NullableTransactionDefinitiondefinition)throwsTransactionException{

TransactionStatus事务管理器状态，编程式事务的一种，（PlatformTransactionManager也是其中一种）

同时又看到这一句：

returnthis.startTransaction(def,transaction,debugEnabled,suspendedResources);

这是开启事务，就执行完了createTransactionIfNecessary，所以是在执行createTransactionIfNecessary时内部已经开事务了，

往createTransactionIfNecessary下又可以看到：

this.commitTransactionAfterReturning(txInfo);

就是提交事务了。

而开启事务和提交事务又是在invoke方法执行的，所以而这个invoke方法又是属于TransactionInterceptor（实现了 MethodInterceptor），所以我们在配置的时候就通过Advisor来配置TransactionInterceptor，实际上声明式事务本质上就是AOP。

查看全文

http://www.jsqmd.com/news/453527/