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

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

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

导读环境：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 线程池七大参数含义

标签：

热门焦点

卢伟冰长文解析K60至尊版对Redmi有着里程碑式的意义

在今天的Redmi后性能时代战略发布会结束之后，Redmi总经理卢伟冰又带来了一篇长文，详解了为什么 Redmi 要开启后性能时代？为什么选择和 MediaTek、Pixelworks 深度合作？以及后性
Flowable工作流引擎的科普与实践

一.引言当我们在日常工作和业务中需要进行各种审批流程时，可能会面临一系列技术和业务上的挑战。手动处理这些审批流程可能会导致开发成本的增加以及业务复杂度的上升。在这
如何通过Python线程池实现异步编程？

线程池的概念和基本原理线程池是一种并发处理机制，它可以在程序启动时创建一组线程，并将它们置于等待任务的状态。当任务到达时，线程池中的某个线程会被唤醒并执行任务，执行完任
微信语音大揭秘：为什么禁止转发？

大家好，我是你们的小米。今天，我要和大家聊一个有趣的话题：为什么微信语音不可以转发？这是一个我们经常在日常使用中遇到的问题，也是一个让很多人好奇的问题。让我们一起来揭开这
自动化在DevOps中的力量：简化软件开发和交付

自动化在DevOps中扮演着重要角色，它提升了DevOps的效能。通过自动化工具和方法，DevOps团队可以实现以下目标：消除手动和重复性任务。简化流程。在整个软件开发生命周期中实现更
Temu起诉SHEIN，跨境电商战事升级

来源 | 伯虎财经（bohuFN）作者 | 陈平安日前据外媒报道，拼多多旗下跨境电商平台Temu正对竞争对手SHEIN提起新诉讼，诉状称Shein“利用市场支配力量强迫服装厂商与之签订独家
共享单车的故事讲到哪了？

来源丨海克财经与共享充电宝相差不多，共享单车已很久没有被国内热点新闻关照到了。除了一再涨价和用户直呼用不起了。近日多家媒体再发报道称，成都、天津、郑州等地多个共享单
10天营收超1亿美元，《星铁》比《原神》差在哪？

来源：伯虎财经作者：陈平安即便你没玩过《原神》，你一定听说过的它的大名。恨它的人把《原神》开服那天称作是中国游戏史上最黑暗的一天，有粉丝因为索尼在PS平台上线《原神》，怒而
苹果、三星、惠普等暂停向印度出口笔记本和平板电脑

集微网消息，据彭博社报道，在8月3日印度突然禁止在没有许可证的情况下向印度进口电脑/平板及显示器等产品后，苹果、三星电子和惠普等大公司暂停向印度

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

1. 配置事务超时时间

2. 准备环境

3. 模拟事务超时

4. 事务超时原理

卢伟冰长文解析K60至尊版对Redmi有着里程碑式的意义

Flowable工作流引擎的科普与实践

如何通过Python线程池实现异步编程？

微信语音大揭秘：为什么禁止转发？

自动化在DevOps中的力量：简化软件开发和交付

Temu起诉SHEIN，跨境电商战事升级

共享单车的故事讲到哪了？

10天营收超1亿美元，《星铁》比《原神》差在哪？

苹果、三星、惠普等暂停向印度出口笔记本和平板电脑

最新推荐

猜你喜欢

热门推荐

相关资讯