Spring 事务源码分析

在实际工作中,会经常碰到如下代码,以前对这些只知道底层由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

开启事务

执行目标实例函数

提交事务

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,547评论 6 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,399评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,428评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,599评论 1 274
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,612评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,577评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,941评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,603评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,852评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,605评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,693评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,375评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,955评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,936评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,172评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,970评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,414评论 2 342

推荐阅读更多精彩内容