spring更新后 外层事务查不到_再深一点:面试工作两不误,源码级理解Spring事务...

c1fe981d6cc967384fd2c8cd4560f072.gif

原创:小姐姐味道(微信公众号ID:xjjdog),欢迎分享,转载请保留出处。

Spring有5种隔离级别,7种传播行为。这是面试常问的内容,也是代码中经常碰到的知识点。这些知识枯燥而且乏味,其中有些非常的绕。如果栽在这上面,就实在是太可惜了。

edca1aab67e7937b1c9953628e4efcbe.png

xjjdog在一些事务的基础上,再探讨几个容易淡忘的概念,从源码层面找原因,加深我们的理解,问题大概包括:

  1. Spring的事务和数据库的事务隔离是一个概念么?

  2. Spring是如何实现事务的?

  3. 事务隔离机制都有哪些?

  4. 事务传播机制都有哪些?

  5. 查询语句需要开事务么?

  6. private方法加事务注解有用么?

1、Spring的事务和数据库的事务隔离是一个概念么?

先来第一个问题,Spring的事务隔离级别和数据的事务隔离级别,是一回事么?

其实,数据库一般只有4种隔离机制,Spring抽象出一种default,根据数据设置来变动。

4928baeebedc50a92a29b0282961b563.png

  • read uncommitted(未提交读)

  • read committed(提交读、不可重复读)

  • repeatable read(可重复读)

  • serializable(可串行化)

  • default (PlatformTransactionManager默认的隔离级别,使用的就是数据库默认的)

这是因为,Spring只提供统一事务管理接口,具体实现都是由各数据库自己实现(如MySQL)。Spring会在事务开始时,根据当前环境中设置的隔离级别,调整数据库隔离级别,由此保持一致。

DataSourceUtils文件中,代码详细的输出了这个过程。

// Apply specific isolation level, if any.
Integer previousIsolationLevel = null;
if (definition != null && definition.getIsolationLevel() != TransactionDefinition.ISOLATION_DEFAULT) {
if (logger.isDebugEnabled()) {
logger.debug("Changing isolation level of JDBC Connection [" + con + "] to " +
definition.getIsolationLevel());
}
int currentIsolation = con.getTransactionIsolation();
if (currentIsolation != definition.getIsolationLevel()) {
previousIsolationLevel = currentIsolation;
con.setTransactionIsolation(definition.getIsolationLevel());
}
}

结论:三种情况,如果Spring没有指定事务隔离级别,则会采用数据库默认的事务隔离级别;当Spring指定了事务隔离级别,则会在代码里将事务隔离级别修改为指定值;当数据库不支持这种隔离级别,效果则以数据库的为准(比如采用了MyISAM引擎)。

我们会使用如下的方式进行声明。如果不是有性能和需求问题,就不要瞎改。事务处理弄不好是会锁表的,而锁表在大并发的情况下是会死人的。

@Transactional(isolation = Isolation.READ_UNCOMMITTED)

2、Spring事务的7种传播机制

只要写代码,代码总会存在嵌套,或者循环,造成了事务的嵌套或者循环。那么事务在这些情况下,根据配置会有不同的反应。

aede33d29a9f9a071c36adfefe875147.png

  • REQUIRED 这是默认的。表示当前方法必须在一个具有事务的上下文中运行,如有客户端有事务在进行,那么被调用端将在该事务中运行,否则的话重新开启一个事务。(如果被调用端发生异常,那么调用端和被调用端事务都将回滚)

  • REQUIRE_NEW 表示当前方法必须运行在它自己的事务中。如果存在当前事务,在该方法执行期间,当前事务会被挂起

  • NESTED  如果当前方法正有一个事务在运行中,则该方法应该运行在一个嵌套事务中,被嵌套的事务可以独立于被封装的事务中进行提交或者回滚。如果封装事务存在,并且外层事务抛出异常回滚,那么内层事务必须回滚,反之,内层事务并不影响外层事务。如果封装事务不存在,则同required的一样

  • SUPPORTS 表示当前方法不必需要具有一个事务上下文,但是如果有一个事务的话,它也可以在这个事务中运行

  • NOT_SUPPORTED 表示该方法不应该在一个事务中运行。如果有一个事务正在运行,他将在运行期被挂起,直到这个事务提交或者回滚才恢复执行

  • MANDATORY 表示当前方法必须在一个事务中运行,如果没有事务,将抛出异常

  • NEVER 表示当方法务不应该在一个事务中运行,如果存在一个事务,则抛出异常

一般用得比较多的是REQUIREDREQUIRES_NEW,用到其他的,你就要小心了,搞懂再用。

最怕如果这俩字了,它会将事情搞的很复杂,尤其是代码量大的时候,你永远不知道你写的service会被谁用到。这就很尴尬了。

我们会采用下面的方式进行声明。鉴于Spring的事务传播非常的绕,如果功能满足需求,那么就用默认的就好,否则会引起不必要的麻烦。

@Transactional(propagation=Propagation.REQUIRED)

3、事务传播机制是怎么实现的?

事务传播机制看似神奇,实际上是使用简单的ThreadLocal的机制实现的。所以,如果调用的方法是在新线程调用的,事务传播实际上是会失效的。这不同于我们以前讲到的透传,Spring并没有做这样的处理。

参考:你的也是我的。3例ko多线程,局部变量透传

所以事务传播机制,只有翻一遍源代码,才能印象深刻。仅靠文字去传播,很多东西会变得不可描述。

f30549a4c91c172b41966c25d1a16552.png


如图,PlatformTransactionManager只有简单的三个抽象接口,定义了包含JDBC在内的Spring所有的事务操作。

28cf08fff0ca45411eda594b659cdc07.png

我们平常说的JDBC,只是占到其中一部分。

实现的方式,依然是使用AOP来实现的,具体的实现类是由TransactionAspectSupport来实现的。可以看到,代码定义了一个叫做transactionInfoHolder的ThreadLocal变量,当用到它的时候,就能够确保在同一个线程下,获取的变量是一致的。

/**
* Holder to support the {@code currentTransactionStatus()} method,
* and to support communication between different cooperating advices
* (e.g. before and after advice) if the aspect involves more than a
* single method (as will be the case for around advice).
*/
private static final ThreadLocal transactionInfoHolder =new NamedThreadLocal<>("Current aspect-driven transaction");

具体的业务逻辑,是在invokeWithinTransaction中实现的。如果你继续向下跟踪的话,会找到AbstractPlatformTransactionManager类中的getTransaction方法。

@Override
public final TransactionStatus getTransaction(@Nullable TransactionDefinition definition)throws TransactionException {


// Use defaults if no transaction definition given.
TransactionDefinition def = (definition != null ? definition : TransactionDefinition.withDefaults());


Object transaction = doGetTransaction();
boolean debugEnabled = logger.isDebugEnabled();


if (isExistingTransaction(transaction)) {
// Existing transaction found -> check propagation behavior to find out how to behave.
return handleExistingTransaction(def, transaction, debugEnabled);
}


// Check definition settings for new transaction.
if (def.getTimeout() < TransactionDefinition.TIMEOUT_DEFAULT) {
throw new InvalidTimeoutException("Invalid transaction timeout", def.getTimeout());
}


// No existing transaction found -> check propagation behavior to find out how to proceed.
if (def.getPropagationBehavior() == TransactionDefinition.PROPAGATION_MANDATORY) {
throw new IllegalTransactionStateException(
"No existing transaction found for transaction marked with propagation 'mandatory'");
}
else if (def.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRED ||
def.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRES_NEW ||
def.getPropagationBehavior() == TransactionDefinition.PROPAGATION_NESTED) {
SuspendedResourcesHolder suspendedResources = suspend(null);
if (debugEnabled) {
logger.debug("Creating new transaction with name [" + def.getName() + "]: " + def);
}
try {
return startTransaction(def, transaction, debugEnabled, suspendedResources);
}
catch (RuntimeException | Error ex) {
resume(null, suspendedResources);
throw ex;
}
}
else {
// Create "empty" transaction: no actual transaction, but potentially synchronization.
if (def.getIsolationLevel() != TransactionDefinition.ISOLATION_DEFAULT && logger.isWarnEnabled()) {
logger.warn("Custom isolation level specified but no actual transaction initiated; " +
"isolation level will effectively be ignored: " + def);
}
boolean newSynchronization = (getTransactionSynchronization() == SYNCHRONIZATION_ALWAYS);
return prepareTransactionStatus(def, null, true, newSynchronization, debugEnabled, null);
}
}

不用我做过多解释了吧,一切明显的逻辑,都在代码里。事务就是在这里创建的。

4、查询方法可以不开启事务么?

事务有个readonly,控制了事务的只读属性,和事务是否开启没半毛钱关系。

在以前的一篇文章中,谈到通过设置readonly属性来控制语句的路由:”MySQL官方驱动“主从分离的神秘面纱(扫盲篇),这其中就用到了事务的其中一个属性readonly,它最终是体现在数据库连接层面的。

connection.setReadOnly(true);

在Spring中的使用方式如下:

@Transactional(readOnly=true)

值得注意的是,这个属性设置之后,并不是每个底层的数据库都支持。中间层的ORM或者驱动,也可能会拿这个属性做一些文章,所以与其说这个readonly是功能性的,不如说是一种暗示

拿MySQL来说,有两种提交模式:

  • SET AUTOCOMMIT=0 禁止自动提交

  • SET AUTOCOMMIT=1 开启自动提交

这都是实打实的SQL语句,所以如果开启了事务,AUTOCOMMIT要为false。我们可以看到Spring做了以下几个操作。

con.setAutoCommit(false);

如果是只读事务,还不忘手动设置一下。

if (isEnforceReadOnly() && definition.isReadOnly()) {    try (Statement stmt = con.createStatement()) {
stmt.executeUpdate("SET TRANSACTION READ ONLY");
}
}

这种操作是很昂贵的,如果不加Transaction注解,默认是不开启事务的。单条的查询语句也是没有必要开启事务的,数据库默认的配置就能满足需求。

但如果你一次执行多条查询语句,例如统计查询,报表查询,在这种场景下,多条查询SQL必须保证整体的读一致性,否则,在前条SQL查询之后,后条SQL查询之前,数据被其他用户改变,就会造成数据的前后不一。

也仅有在这种情况下,要开启读事务。

5、private方法加事务注解有用么?

@Transaction注解加在private上,并没有什么卵用。

这倒不是事务处理的代码去写的特性。由于事务的这些功能,是通过AOP方式强加进去的,所以它收到动态代理的控制。

privatefinal修饰的方法,不会被代理。

但是,你却可以把private方法放在带有事务功能的public方法里。这样,它看起来也有了事务的一些功能特性,但它并没有。

End

互联网中,用到的事务并不多,很多都是非常小、速度非常快的接口,对于开发人员来说,事务是个累赘。

但在一些带有金融属性的业务中,或者一些企业级开发应用中,事务确实一个绕不过的坎。一旦深入其中,就会发现这个知识点,露着血盆大口,等君入瓮。

xjjdog从源码层次,聊到了几个面试常问的问题。不要觉得奇怪,有的人确实一直在拿着脏读、幻读这样的名词来面试。

而这些东西,都属于当时看了恍然大悟,第二天就继续懵逼的内容。

什么时候,才能务实一点呢?

18b7e407575a837e47163aaaf3020546.png

近期热门文章

《996的乐趣,你是无法想象的》魔幻现实主义,关爱神经衰弱

《一切荒诞的傲慢,皆来源于认知》不要被标题给骗了,画面感十足的消遣文章

《必看!java后端,亮剑诛仙》后端技术索引,中肯火爆。全网转载上百次。

《学完这100多技术,能当架构师么?(非广告)》精准点评100多框架,帮你选型

作者简介:小姐姐味道  (xjjdog),一个不允许程序员走弯路的公众号。聚焦基础架构和Linux。十年架构,日百亿流量,与你探讨高并发世界,给你不一样的味道。我的个人微信xjjdog0,欢迎添加好友,进一步交流

b0f5ed9f917af787df1b4db34e08efc0.gif

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/502202.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

箭头函数的this指向谁_高阶函数

NodeJS 系列文章&#xff0c;本篇是第一篇&#xff0c;首先&#xff0c;预计将后续高频使用逻辑串一遍&#xff0c;依次是高阶函数&#xff0c;promise以及事件机制。本篇主要是高阶函数。call、bind、applycall、apply 都是改变 this 指向&#xff0c;区别是接受参数的方式不一…

php怎么加编码,php怎么设置编码格式

php设置编码格式的方法&#xff1a;首先在php脚本中添加【header(“Content-Type: text/html; charsetutf-8")】&#xff1b;然后在静态页面设置编码&#xff1b;最后保证所有文件的编码相同即可。如果要使用gb2312编码&#xff0c;那么php要输出头&#xff1a;(推荐教程&…

java 中文 音序,java 中文字符串数组按照音序排列

java 中文字符串数组按照音序排列复制代码 代码如下:public class SortComparator implements Comparator{public int compare(Object o1,Object o2) {try{byte[] buf1 ((String) o1).getBytes("unicode");byte[] buf2 ((String) o2).getBytes("unicode"…

动感灯箱制作流程培训_广告立体灯箱的特点有哪些?

随着广告业的发展&#xff0c;灯箱广告行业也在突飞猛进。在灯箱广告屏的设计与制作中&#xff0c;为了追求真实感和艺术性&#xff0c;采用彩印或摄影喷绘;也有人用特种纸、塑料板(膜)、灯箱布等进行丝网印刷制作灯箱图片&#xff0c;并根据成本和耐候性要求选择制作方法和灯箱…

supervisor 重启_supervisor_twiddler的使用

点击上方蓝字关注【 北邮郭大宝 】Supervisor可以很好的实现Python的进程管理&#xff0c;但是新增进程时需要配置文件&#xff0c;对于需要动态创建进程的场景不是很友好&#xff0c;supervisor_twiddler插件可以帮助实现上述功能。本文就supervisor_twiddler的使用做简单的de…

matlab的词云,Word Cloud (词云) - JavaScript

在上一篇中已经分享了用 Python 创建词云了。接下来继续总结其他创建词云的方法。&带道术用量确示常构端析以要效开的用&#xff0c;近不gt;> Create Word Cloud via JavaScrip要圈器是天的年编功小还久概据含直这请框结业未商屏页屏随会维气大机域页效实一应控高标tJav…

unique函数_unique函数使用场景(一)

unique函数使用场景(一)前情提示&#xff1a;Microsoft 365(就是原来的office 365)已经推出有一段时间了&#xff0c;去年年审就在项目上使用365更新的一系列动态函数来提高审计效率(大胆一点&#xff0c;就是更好的偷懒)。讲解动态函数的文章不多&#xff0c;且365普及度低&am…

c++gdal如何在大图像中截取小图像并获取其图像信息_【图像处理】OpenCV系列十 --- 边缘检测之Canny算子...

上一篇我们学习了图像处理形态学相关知识点&#xff0c;相信大家学习之后已经对形态学有了足够的理解了&#xff0c;那么接下来&#xff0c;我们一起来学习一下图像处理中的边缘检测吧&#xff01;我们将会重点学习边缘检测各种算子和滤波器 --- Canny算子,Sobel算子,Laplace算…

笔记本屏幕30hz_你真的了解笔记本电池和电源适配器吗?

很多笔记本硬件配置相似&#xff0c;但续航或性能却相差一大截。实际上&#xff0c;笔记本的续航能力在很大程度上取决于电池&#xff1b;而实际性能&#xff0c;则还会受到电源适配器功率的影响。想认识这两个硬件&#xff0c;就需要从它们的基本参数谈起。笔记本电池笔记本的…

java 俄文,俄文字体在word里面是什么

在Word里输入俄语字母,一打字字体就变成宋体了,俄语字母间间距...我不知道你这个俄语输入法补丁的字库用的是什么&#xff0c;如果是汉字库里好像就没办法调了&#xff0c;试一下把字体改成西文的Times New Roman、Arial等字体看有没有变化&#xff0c;如果没有&#xff0c;那就…

excel公式不自动计算_【纯干货】值得收藏的Excel日期计算公式!

点击上面“零壹快学”关注我们小伙伴们好&#xff0c;今天零壹学长给大家整理了一些常用的日期计算公式&#xff0c;赶紧往下看吧&#xff01;01根据身份证号计算出生年月--TEXT(MID(A2,7,8),"0-00-00")02根据身份证号提取性别IF(MOD(MID(A2,15,3),2),"男"…

项目开发流程_绿维文旅:旅游项目开发模式与流程

一、旅游项目开发模式旅游综合开发是立足旅游项目自有资源基础&#xff0c;以旅游产业为主导&#xff0c;以市场为导向&#xff0c;以资本为驱动&#xff0c;以资源整合为核心&#xff0c;通过集中土地、资本、技术、交通、劳动力等生产要素&#xff0c;推进土地开发、交通建设…

Java继承_java练习本(20190617)

公众号回复“1”&#xff0c;小刀拉你进学习交流群哟&#xff0c;妈妈再也不担心我学习没人陪伴啦~昨日翻译昨日翻译“The journey of a thousand miles begins with one step.”——Lao Tzu“千里之行始于足下。”——老子今日名言“Imagination was given to man to compensa…

爬虫 页面元素变化_爬虫 基本知识 萌新

爬虫定义网络爬虫&#xff08;又称为网页蜘蛛&#xff0c;网络机器人&#xff0c;在FOAF社区中间&#xff0c;更经常的称为网页追逐者&#xff09;&#xff0c;是一种按照一定的规则&#xff0c;自动地抓取万维网信息的程序或者脚本。另外一些不常使用的名字还有蚂蚁、自动索引…

gateway sentinel 熔断 不起作用_Sentinel 1.8.0 年度版本发布,熔断降级重构升级

简介&#xff1a;在经过数月的打磨后&#xff0c;Sentinel 1.8.0 版本正式发布&#xff01;该版本是本年度最重要的版本之一&#xff0c;包含大量特性改进与 bug 修复&#xff0c;尤其是针对熔断降级特性的完善升级&#xff08;支持任意统计时长、慢调用比例降级策略、熔断器事…

access设置0字段为null是因为类型转换失败_Apache Pulsar 2.6.1 版本正式发布:2.6.0 加强版,新增 OAuth2 支持

在 Apache Pulsar 2.6.0 版本发布后的 2 个月&#xff0c;2020 年 8 月 21 日&#xff0c;Apache Pulsar 2.6.1 版本正式发布&#xff01;Apache Pulsar 2.6.1 修复了 2.6.0 版本中的诸多问题&#xff0c;改进了一些功能&#xff0c;新增了对 OAuth2 的支持&#xff0c;覆盖 Br…

英特尔显卡linux管理_英特尔 11 代酷睿大揭秘:这次全是大招

英特尔在今年九月份正式推出了第 11 代酷睿移动处理器&#xff0c;这次英特尔将 10 纳米 SuperFin 工艺全面带到移动处理器上&#xff0c;同时还有全新的 Willow Cove 内核、Iris Xe 显卡、全新的酷睿及英特尔标志。这次面向消费级市场的英特尔第 11 代酷睿移动处理器又有哪些变…

lnmp php文件访问不了,记一次lnmp环境下无法执行php文件

lnmp环境搭建好后却无法正常执行php文件&#xff0c;坑爹啊&#xff01;~[错误状况]页面直接打印出php代码内容&#xff1b;php文件无法执行&#xff1f;&#xff1b;查看nginx配置文件&#xff1a;server { listen80;server_name xxxxx.com;access_log/var/log/nginx/xxxxx.ac…

file 选择的图片作为背景图片_酷炫!用Python把桌面变成实时更新的地球图片

如何拥有够酷炫逼格够高的桌面&#xff1f;本文教你轻松定制自己的桌面背景(建议带上耳机听一下地球的声音)最近疯狂迷恋地球卫星图和地球的卫星视频&#xff0c;看上面的视频简直极度舒适。不禁想把这种图片作为桌面背景图。这就产生抓取其背景图片作为桌面的想法。思路其实很…

摇杆怎么映射到键盘_[评测]YAMAHA PSRSX900:雅马哈升级幅度最大的高端编曲键盘键盘中国原创评测...

本文图片均由本人亲自拍摄&#xff0c;转载请注明出处。年前就收到这台国行PSR-SX900了。在这一个月特殊的日子里&#xff0c;不能出门&#xff0c;幸好有sx900的陪伴&#xff0c;让我可以天天弹琴、唱歌打发时间...现在很多地方开始逐渐复工了&#xff0c;我抽时间写下了这一个…