在实际工作中，会经常碰到如下代码，以前对这些只知道底层由spring事务去管理的。多年后打开源码心中的疑惑也解开了。故写此文章对学习的一个总结，让准备或在学的小伙伴少走弯路，快速前进，升职加薪！
一 事务代码配置
1 db.properties配置
db.main.driver=com.mysql.cj.jdbc.Driver
db.main.url=jdbc:mysql://localhost:3306/?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT
db.main.username=root
db.main.password=
2 配置文件application.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:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd"
default-lazy-init="false">
<context:property-placeholder location="classpath:db.properties" ignore-unresolvable="true"/>
<context:component-scan base-package="test"/>
<bean id="mainDataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
<property name="driverClassName">
<value>${db.main.driver}</value>
</property>
<property name="url">
<value>${db.main.url}</value>
</property>
<property name="username">
<value>${db.main.username}</value>
</property>
<property name="password">
<value>${db.main.password}</value>
</property>
</bean>
<!-- myBatis文件 -->
<bean id="mainSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="mainDataSource"/>
<!-- 自动扫描entity目录, 省掉Configuration.xml里的手工配置 -->
<property name="mapperLocations" value="classpath:/mapper/*.xml"/>
</bean>
<!-- DAO接口所在，Spring会自动查找类-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="test.mapper"/>
<property name="sqlSessionFactoryBeanName" value="mainSqlSessionFactory"/>
</bean>
<!-- 配置事务管理器 -->
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="mainDataSource"/>
</bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>
3 业务类
package test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import test.mapper.UserMapper;
@Service
public class TestTransactionalService {
@Autowired
private UserMapper userMapper;
@Transactional(rollbackFor = Exception.class)
// @Transactional()
public void add(){
User user = new User();
int i=1/0;
user.setNickName("lake1");
userMapper.insertUser(user);
}
}
二 以一为例分析Spring事务源码
0 创建XmlBeanDefinitionReader实例加载application.xml配置文件。
1 注册解析标签<tx:annotation-driven/>解析器。
1.1 执行 获取配置文件事务空间地址，根据地址获取TxNamespaceHandler类实例，调用init函数，注册TxAdviceBeanDefinitionParser实例和AnnotationDrivenBeanDefinitionParser实例。
2 根据解析标签<tx:annotation-driven/>属性值，注册事务相关beanDefinition。
2.1 执行函数parseCustomElement，获取标签解析器，开始解析，创建TransactionInterceptor,AnnotationTransactionAttributeSource,BeanFactoryTransactionAttributeSourceAdvisor对应beanDefinition并注册到bean定义中心。
解析标签创建实例
3 循环获取beanname创建实例，检验类是否需要创建代理类。
3.1 执行getBean(beanname),创建实例，填充属性，调用自定义初始化函数。
3.2 在initializeBean函数中，循环执行后置处理器实例的函数postProcessAfterInitialization，当后置处理器为InfrastructureAdviorAutoProxyCreator实例执行函数wrapIfNecessary，反射获取类Method实例，再校验Method实例是否有加Tranction注解，有加则返回增强实例BeanFactoryTransactionAttributeSourceAdvisor，创建代理类存于单例缓冲池。
创建符合代理的目标类实例
4 根据beanname获取容器中业务代理类实例，执行代理业务函数，开启事务，执行目标函数，提交事务。
4.1 执行代理类实例业务函数时，先执行CglibAopProxy类的函数intercpter，获取增强器集合链,目标类实例，执行CglibMethodInvocation实例函数proceed()，取出责任链的TransactionInterceptor实例并执行invoke函数，执行TransactionAspectSupport实例invokeWithinTransaction函数创建TransactionAttribute，TransactionAttribute实例，开启事务，执行目标函数invocation.proceedWithInvocation()，提交事务执行函数commitTransactionAfterReturning。
获取事务增强器集合链,
执行TranctionIntecepter实例函数invoke
开启事务
执行目标实例函数
提交事务
网友评论