环境：Spring5.3.23
Spring事务超时是指一个事务在执行中最长的允许时间。如果事务在超时时间内未能完成，则会自动回滚。超时时间可以通过设置来控制，以确保事务在规定的时间内完成或回滚，避免数据一致性问题。
在工作中你有配置事务的超时时间吗？如何进行配置事务超时时间？
注解方式：
// 这里单位是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种方式读可以进行事务超时的设置，什么情况下才能算是事务超时呢？
准备一张2000w数据的表
图片
表字段信息如下：
图片
此表除主键外没有任何的索引。
图片
统计查询表的数据量，将该操作放到一个事务中，同时设置事务的超时时间。
// 将超时时间设置为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执行的超时，是由我们的驱动程序抛出的异常。
模拟其它非数据库操作耗时，而这个是在执行数据库操作之前
@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框架抛出的。
模拟其它非数据库操作耗时，而这个是在执行数据库操作之后，适当调整上面的代码顺序
@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毫秒程序正常运行
在测试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异常。
在开始一个事务时会在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
上一篇： 如何搭建高性能广告技术需求方平台
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号