当前位置：首页 > 科技 > 软件

Spring事务超时到底是怎么回事？

来源：责编：时间：2023-10-13 14:36:35 189观看

导读环境：Spring5.3.23 Spring事务超时是指一个事务在执行中最长的允许时间。如果事务在超时时间内未能完成，则会自动回滚。超时时间可以通过设置来控制，以确保事务在规定的时间内完成或回滚，避免数据一致性问题。在工作中你

环境：Spring5.3.23

Spring事务超时是指一个事务在执行中最长的允许时间。如果事务在超时时间内未能完成，则会自动回滚。超时时间可以通过设置来控制，以确保事务在规定的时间内完成或回滚，避免数据一致性问题。

在工作中你有配置事务的超时时间吗？如何进行配置事务超时时间？

1. 配置事务超时时间

注解方式：

// 这里单位是s@Transactional(timeout = 2)public void save() {}

编程方式1：

@Resourceprivate PlatformTransactionManager tm ;DefaultTransactionDefinition definition = new DefaultTransactionDefinition();definition.setTimeout(2) ;

编程方式2：

@Resourceprivate PlatformTransactionManager tm ;public void update() {  TransactionTemplate template = new TransactionTemplate(tm) ;  template.setTimeout(2) ;  template.execute(new TransactionCallback<Object>() {    @Override    public Object doInTransaction(TransactionStatus status) {      // ...      return null ;    }  }) ;}

以上3种方式读可以进行事务超时的设置，什么情况下才能算是事务超时呢？

2. 准备环境

准备一张2000w数据的表

图片

表字段信息如下：

图片

此表除主键外没有任何的索引。

图片

3. 模拟事务超时

测试1

统计查询表的数据量，将该操作放到一个事务中，同时设置事务的超时时间。

// 将超时时间设置为20s@Transactional(timeout = 20)public void query() {  long start = System.currentTimeMillis() ;  jdbcTemplate.execute("select count(*) from p_user") ;  System.out.println("耗时：" + (System.currentTimeMillis() - start) + "毫秒") ;}

执行结果：

耗时：3198毫秒

接下来将超时时间改成3s

执行结果如下：

13:56:01.425 [main] WARN  c.zaxxer.hikari.pool.ProxyConnection - HikariPool-1 - Connection com.mysql.cj.jdbc.ConnectionImpl@504ecd marked as broken because of SQLSTATE(null), ErrorCode(0)com.mysql.cj.jdbc.exceptions.MySQLTimeoutException: Statement cancelled due to timeout or client request  at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:113)  at com.mysql.cj.jdbc.StatementImpl.checkCancelTimeout(StatementImpl.java:2167)

从异常信息看到抛出了超时异常。这里的超时是sql执行的超时，是由我们的驱动程序抛出的异常。

测试2

模拟其它非数据库操作耗时，而这个是在执行数据库操作之前

@Transactional(timeout = 2)public void query() {  long start = System.currentTimeMillis() ;  try {    TimeUnit.SECONDS.sleep(3) ;  } catch (InterruptedException e) {    e.printStackTrace();  }  // 执行非常简单的操作  jdbcTemplate.execute("select 1") ;  System.out.println("耗时：" + (System.currentTimeMillis() - start) + "毫秒") ;}

执行结果：

14:08:44.000 [main] DEBUG o.s.jdbc.core.JdbcTemplate - Executing SQL statement [select 1]Exception in thread "main" org.springframework.transaction.TransactionTimedOutException: Transaction timed out: deadline was Wed Oct 11 14:08:42 CST 2023  at org.springframework.transaction.support.ResourceHolderSupport.checkTransactionTimeout(ResourceHolderSupport.java:155)

抛出了超时异常，而这个异常是由Spring框架抛出的。

测试3

模拟其它非数据库操作耗时，而这个是在执行数据库操作之后，适当调整上面的代码顺序

@Transactional(timeout = 2)public void query() {  long start = System.currentTimeMillis() ;  jdbcTemplate.execute("select 1") ;  try {    TimeUnit.SECONDS.sleep(3) ;  } catch (InterruptedException e) {    e.printStackTrace();  }  System.out.println("耗时：" + (System.currentTimeMillis() - start) + "毫秒") ;}

执行结果：

耗时：3015毫秒

程序正常运行

测试4

在测试3的基础上，最后再次执行数据库相关的操作

@Transactional(timeout = 2)public void query() {  long start = System.currentTimeMillis() ;  jdbcTemplate.execute("select 1") ;  try {    TimeUnit.SECONDS.sleep(3) ;  } catch (InterruptedException e) {    e.printStackTrace();  }  System.out.println("耗时：" + (System.currentTimeMillis() - start) + "毫秒") ;  // 再次执行数据库相关操作  jdbcTemplate.execute("select 1") ;}

执行结果：

耗时：3024毫秒14:14:38.257 [main] DEBUG o.s.jdbc.core.JdbcTemplate - Executing SQL statement [select 1]Exception in thread "main" org.springframework.transaction.TransactionTimedOutException: Transaction timed out: deadline was Wed Oct 11 14:14:37 CST 2023  at org.springframework.transaction.support.ResourceHolderSupport.checkTransactionTimeout(ResourceHolderSupport.java:155)

第一个数据库操作，没有抛出异常，直到第二个执行时抛出了异常。

总结：事务方法开始执行时就开始计时，在执行到数据库操作时判断当前的执行时间点是否已经超过了设置的超时时间，如果是则抛出Timeout异常。

4. 事务超时原理

在开始一个事务时会在DataSourceTransactionManager#doBegin方法中设置超时时间

protected void doBegin(Object transaction, TransactionDefinition definition) {  int timeout = determineTimeout(definition);  if (timeout != TransactionDefinition.TIMEOUT_DEFAULT) {    // 如果注解@Transactional中设置了timeout，则设置超时时间    txObject.getConnectionHolder().setTimeoutInSeconds(timeout);  }}protected int determineTimeout(TransactionDefinition definition) {  if (definition.getTimeout() != TransactionDefinition.TIMEOUT_DEFAULT) {    return definition.getTimeout();  }  return getDefaultTimeout();}

当通过JdbcTemplate操作数据库时，还会执行如下操作

public class JdbcTemplate {  private <T> T execute(StatementCallback<T> action, boolean closeResources) {    Statement stmt = null;    try {      stmt = con.createStatement();      // 配置Statement对象，这其中会设置超时时间      applyStatementSettings(stmt);      // ...      return result;    }  }    protected void applyStatementSettings(Statement stmt) throws SQLException {    // ...    // getQueryTimeout方法返回的是当前JdbcTemplate对象中设置d饿超时时间    DataSourceUtils.applyTimeout(stmt, getDataSource(), getQueryTimeout());  }}

DataSourceUtils工具类

public abstract class DataSourceUtils {  public static void applyTimeout(Statement stmt, @Nullable DataSource dataSource, int timeout) throws SQLException {    ConnectionHolder holder = null;    if (dataSource != null) {      holder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);    }    // 如果当前事务执行配置了超时时间    if (holder != null && holder.hasTimeout()) {      // 剩余事务超时将覆盖指定的值。      stmt.setQueryTimeout(holder.getTimeToLiveInSeconds());    }    else if (timeout >= 0) {      // No current transaction timeout -> apply specified value.      stmt.setQueryTimeout(timeout);    }  }  }

ResourceHolderSupport类

public abstract class ResourceHolderSupport implements ResourceHolder {   public int getTimeToLiveInSeconds() {    double diff = ((double) getTimeToLiveInMillis()) / 1000;    int secs = (int) Math.ceil(diff);    // 检查超时时间    checkTransactionTimeout(secs <= 0);    return secs;  }  private void checkTransactionTimeout(boolean deadlineReached) throws TransactionTimedOutException {    if (deadlineReached) {      // 设置事务回滚      setRollbackOnly();      // 抛出异常      throw new TransactionTimedOutException("Transaction timed out: deadline was " + this.deadline);    }  }}

完毕！！！

本文链接：http://www.28at.com/showinfo-26-13520-0.htmlSpring事务超时到底是怎么回事？

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：如何搭建高性能广告技术需求方平台

下一篇：程序员必会之最详细的ThreadPoolExecutor 线程池七大参数含义

标签：

热门焦点

Redmi Buds 4开箱简评：才199还有降噪可以无脑入

在上个月举办的Redmi Note11T Pro系列新机发布会上，除了两款手机新品之外，Redmi还带来了两款TWS真无线蓝牙耳机产品，Redmi Buds 4和Redmi Buds 4 Pro，此前我们在Redmi Note11T
6月安卓手机性能榜：vivo/iQOO霸占旗舰排行榜前三

2023年上半年已经正式过去了，我们也迎来了安兔兔V10版本，在新的骁龙8Gen3和天玑9300发布之前，性能榜的榜单大体会以骁龙8Gen2和天玑9200+为主，至于那颗3.36GHz的骁龙8Gen2领先
女孩租房开2小时空调用完100元电费引热议：5级能耗惹不起月薪过万电费也交不起

近日，江苏苏州一女孩租房当天充值了100元电费，开着空调不到2小时发现电费已用完。对于为什么这个快，房东表示，电表坏了这种情况很多，之前也遇到过，给租客换
28个SpringBoot项目中常用注解，日常开发、求职面试不再懵圈

前言在使用SpringBoot开发中或者在求职面试中都会使用到很多注解或者问到注解相关的知识。本文主要对一些常用的注解进行了总结，同时也会举出具体例子，供大家学习和参考。注解
一个注解实现接口幂等，这样才优雅！

场景码猿慢病云管理系统中其实高并发的场景不是很多，没有必要每个接口都去考虑并发高的场景，比如添加住院患者的这个接口，具体的业务代码就不贴了，业务伪代码如下：图片上述代码有
当家的盒马，加速谋生

来源 | 价值星球Planet作者 | 归去来自己“当家”的盒马，开始加速谋生了。据盒马官微消息，盒马计划今年开放生鲜供应链，将其生鲜商品送往食堂。目前，盒马在上海已经与
AI芯片初创公司Tenstorrent获三星和现代1亿美元投资

Tenstorrent是一家由芯片行业资深人士Jim Keller领导的加拿大初创公司，专注于开发人工智能芯片，该公司周三表示，已经从现代汽车集团和三星投资基金等
机构称Q2全球智能手机出货量同比下滑11% 苹果份额依旧第2

7月20日消息，据外媒报道，研究机构的报告显示，由于需求下滑，今年二季度全球智能手机的出货量，同比下滑了11%，三星、苹果等主要厂商的销量，较去年同期均有下
SN570 NVMe SSD固态硬盘价格与性能兼具

SN570 NVMe SSD固态硬盘是西部数据发布的最新一代WD Blue系列的固态硬盘，不仅闪存技术更为精进，性能也得到了进一步的跃升。WD Blue SN570 NVMe SSD的包装外