@Transactional TransactionManager 源码分析「建议收藏」

@Transactional TransactionManager 源码分析「建议收藏」先贴一篇好文章,https://www.cnblogs.com/thisiswhy/p/13948055.html部分代码得修改下rollback方法必须传入参数transactionStatus,如果用SelfTransactionMananger单实例中的属性transactionStatus,在多线程中会出现线程不安全的情况。ArrayList线程不安全,elementData[size++]=e是先赋值再size+1,多线程运行到赋值还没+1时,size位置上被覆盖了多次…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全家桶1年46,售后保障稳定

先贴一篇好文章,https://www.cnblogs.com/thisiswhy/p/13948055.html

部分代码得修改下   rollback方法必须传入参数 transactionStatus ,如果用SelfTransactionMananger单实例中的属性transactionStatus,在多线程中会出现线程不安全的情况。

@Transactional TransactionManager 源码分析「建议收藏」

ArrayList 线程不安全,elementData[size++] = e是先赋值再size+1,多线程运行到赋值还没+1时,size位置上被覆盖了多次,然后多次+1,size+1,+2等位置没赋值过,下次就直接从size+n开始赋值,看起来就add了null值一样,此时不会报错,因为add时没有null所以取出时没做考虑就可能报NullPointerException了

@Transactional TransactionManager 源码分析「建议收藏」

工作上有一个需求跟文章里的很像,要求任何一个线程发生错误后,所有主线程和子线程里的数据库操作全部回滚。文章中很聪明的用到了”二次确认”的思想,利用CountDownLatch确保所有线程都执行成功后,统一执行commit,如果有一个失败,则全部rollback。

那么数据库事务是如何触发执行commit和rollback的呢?

事务是线程独立的么?

数据库连接池是什么时候借给程序又是怎么回收的呢?

带着这些疑问我们去研读下代码。

话不多说,直接先上流程图,大家先看看,能看懂多少是多少,这里我们先讲解些基本概念,后面会详细梳理流程。

@Transactional TransactionManager 源码分析「建议收藏」

基本概念

DataSourceConfiguration   创建DataSource

@Transactional TransactionManager 源码分析「建议收藏」

DataSourceTransactionManagerAutoConfiguration    创建TransactionManager manager = new DataSourceTransactionManager(dataSource);

@Transactional TransactionManager 源码分析「建议收藏」
TransactionManager    核心方法是   getTransaction,commit, rollback    都由AbstractPlatformTransactionManager的抽象类实现

@Transactional TransactionManager 源码分析「建议收藏」

TransactionInfo    包含属性TransactionManager   TransactionAttribute   TransactionStatus

protected TransactionInfo createTransactionIfNecessary(@Nullable PlatformTransactionManager tm,@Nullable TransactionAttribute txAttr, final String joinpointIdentification) 

Jetbrains全家桶1年46,售后保障稳定

@Transactional TransactionManager 源码分析「建议收藏」

TransactionDefinition    TransactionAttribute        主要属性 isolationLevel   propagationBehavior

TransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException;

@Transactional TransactionManager 源码分析「建议收藏」

TransactionStaus   主要属性newTransaction   localRollbackOnly   globalRollbackOnly    transaction(一般为DataSourceTransactionObject,可获取connectionHolder  -> 获取connection)

TransactionStatus getTransaction(@Nullable TransactionDefinition definition)  throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;

@Transactional TransactionManager 源码分析「建议收藏」

TransactionInterceptor

@Transactional   spring会将该方法生成cglib代理MethodInvocation,由TransactionInterceptor(MethodInterceptor)执行interceptor.invoke(methodInvocation)   从而实现方法增强

@Transactional TransactionManager 源码分析「建议收藏」

流程梳理

理解了些基础概念后,我们将参照之前的流程图跟着代码走一遍

TransactionAspectSupport.invokeWithinTransaction

核心中的核心,就是这个方法实现了对代理cglib方法的增强

createTransactionIfNecessary    创建txInfo

invocation.proceedWithInvocation   执行interceptor链路,最终执行代理方法

completeTransactionAfterThrowing   如果有异常且该异常满足回滚条件,则执行回滚操作

commitTransactionAfterReturning   如果没异常,但是rollbackOnly=true,也回滚;反之,则执行提交操作

    @Nullable
	protected Object invokeWithinTransaction(Method method, @Nullable Class<?> targetClass,
			final InvocationCallback invocation) throws Throwable {
        //...
        //创建transaction   实际调用 transaction.getTransaction(definition)
			TransactionInfo txInfo = createTransactionIfNecessary(ptm, txAttr, joinpointIdentification);

			Object retVal;
			try {
				// This is an around advice: Invoke the next interceptor in the chain.
				// This will normally result in a target object being invoked.
				retVal = invocation.proceedWithInvocation();
			}
			catch (Throwable ex) {
				// 执行rollback
				completeTransactionAfterThrowing(txInfo, ex);
				throw ex;
			}
			finally {
				cleanupTransactionInfo(txInfo);
			}

			if (retVal != null && vavrPresent && VavrDelegate.isVavrTry(retVal)) {
				// Set rollback-only in case of Vavr failure matching our rollback rules...
				TransactionStatus status = txInfo.getTransactionStatus();
				if (status != null && txAttr != null) {
					retVal = VavrDelegate.evaluateTryFailure(retVal, txAttr, status);
				}
			}
            // 执行commit
			commitTransactionAfterReturning(txInfo);
			return retVal;
        //...
}

创建txInfo

@Transactional TransactionManager 源码分析「建议收藏」

TransactionInfo txInfo = createTransactionIfNecessary()    创建transaction,实际调用transactionManager.getTransaction(definition);definition 是TransactionDefinition 类,默认事务级别为 PROPAGATION_REQUIRED

再经过DataTransactionalManager的一系列骚操作

@Transactional TransactionManager 源码分析「建议收藏」

dataSource.getConnection()    由具体的dataSource实现类获得,思路都是由连接池里拿一个未使用的连接出来

@Transactional TransactionManager 源码分析「建议收藏」

核心代码来了,TransactionSynchronizationManager.bindResource 将connectionHolder绑定到ThreadLocal,这样就将connection,TransactionStatus和当前线程绑定了起来

@Transactional TransactionManager 源码分析「建议收藏」

@Transactional TransactionManager 源码分析「建议收藏」

执行代理方法

@Transactional TransactionManager 源码分析「建议收藏」

执行后处理

根据执行结果判断是执行rollback还是commit

@Transactional TransactionManager 源码分析「建议收藏」

TransactionAspectSupport.completeTransactionAfterThrowing  如果抛了异常,则判断是否满足回滚条件

@Transactional TransactionManager 源码分析「建议收藏」

AbstractPlatformTransactionManager     执行回滚操作

@Transactional TransactionManager 源码分析「建议收藏」

TransactionAspectSupport.commitTransactionAfterReturning    没异常则执行commit

@Transactional TransactionManager 源码分析「建议收藏」

AbstractPlatformTransactionManager   执行提交操作   但还需要判断是否标记了rollbackOnly,有可能A,B两个方法共用同一个事务,B抛了异常,导致外层的方法A哪怕没错也得一起回滚。

@Transactional TransactionManager 源码分析「建议收藏」

至此,整个链路就分析完成了

 

 

 

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/226796.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • import java.io 是什么意思_Java IO 详解

    import java.io 是什么意思_Java IO 详解JavaIO详解初学java,一直搞不懂java里面的io关系,在网上找了很多大多都是给个结构图草草描述也看的不是很懂。而且没有结合到java7的最新技术,所以自己来整理一下,有错的话请指正,也希望大家提出宝贵意见。首先看个图:(如果你也是初学者,我相信你看了真个人都不好了,想想java设计者真是煞费苦心啊!)这是javaio比较基本的一些处理流,除此之外我们还会提到一些比较深入的基于i…

  • 数据库基础(常用SQL语句)[通俗易懂]

    数据库基础(常用SQL语句)[通俗易懂]一、数据库级及SQL语言简介1、目前主流数据库微软:sqlserver、access瑞典:mysqlibm:db2sybase:sybaseibm:informixoracle:oracle2、SQL语言DQL————-数据查询语言select…From…WhereDML————-数据操纵语言insert、upda…

  • Laravel核心内容:契约,你了解多少?

    Laravel核心内容:契约,你了解多少?

  • zynq 挖矿_FPGA芯片矿机

    zynq 挖矿_FPGA芯片矿机比特币是一种虚拟货币,在过去几年里逐渐流行开来。由此,比特币的追随者通过采购或者“挖矿”比特币的形式,投入其部分资产来支持这种货币。挖矿是指使用计算机硬件为比特币网络执行数学计算的过程。提供服务的比特币矿工可以得到一笔报酬(目前是25比特币)以及任何内含的交易费用。由于网络报酬是按照所有矿工完成的计算量进行分配的,故挖矿的竞争异常激烈。比特币挖矿开始是在CPU和GPU这样的低成本硬件上运行的一个软…

  • 英语b级考试怎么准备(大学英语b级考试技巧)

    英语口语考试一般都会有固定的模式,考核的是基础英语口语,和日常生活联系。那么,英语口语考试难不难呢?下面和沪江英语小编一起来看看吧。一、英语口语考试难不难在考试的时候一定要认真听清楚题目的要求,听清楚题目内容中要求你要说的内容,注意生词的读音,在脑海中重复几次,或者可以用笔记下,如果可以带纸笔进场的话。保持镇静,心理不要过于紧张,要相信自己的口语。就算说错了也没有关系,继续说,不要影响自己后面的题…

  • 自监督学习 对比学习了解

    自监督学习 对比学习了解简介自监督学习是近几年(2020年)流行起来的一种机器学习方法,很多人认为自监督方法未来一段时间将取代现有的监督方法,成为深度学习中占据主导地位的方法。现在已经有不少采用自监督-对比学习的方法取得了领先的效果。目前(2020.10)来说这个领域貌似还比较新,没有找到很系统的讲解介绍资料。首先介绍一下到底什么是SSL,我们知道一般机器学习分为监督学习,非监督学习和强化学习。而self-supervisedlearning是无监督学习里面的一种。自监督学习的思想非常简单,就是输入的是一堆无监督的数据

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号