Spring Transaction Analysize

发表于 | 分类于 | 阅读次数:

Spring Transaction Analysize

问题描述

  1. 前言 20190525-Mybatis OGNL导致的并发安全问题 ，发生问题的mybatis版本为3.2.7，mybatis-spring的版本为1.2.2
  2. 为解决OGNL的并发问题，将mybatis升级是3.4.0版本，mybatis-spring升级至1.3.0版本，但是此时发现稳定报错Transaction time out

排查过程

  1. 在本地invoke method无法重现事务问题

  2. 显示的声明defaultTimeout并不能规避Transaction time out报错

  3. remote debug偶然发现有setDefaultTimeout = 0的操作

    • 堆栈信息发现来自TransactionUtil

    • 查看代码有设置默认timeout为0的操作

      1
      2
      3
      public <T> T transaction(FuncWithException<T> action, Propagation propagation) {
              return transaction(action, propagation, 0);
          }

问题分析

  1. 各种超时的关联

    transaction timeout

  1. TransactionUtil中设置timeout的方法如下

    • timeout的默认值是0

    • 通过transactionManager.setDefaultTimeout(timeout)修改的是单例类的成员变量，这个操作是线程不安全的，修改的是一个共享变量，所以其他线程读取到的defaultTimeout被修改成0，导致transaction time out稳定重现。

    • 那么问题一直存在，为什么现在才被暴露呢？

  1. 在mybatis-spring 1.3.0之前，如果选择DataSourceTransactionManager，事务内所有的sql操作必须通过JdbcTemplate执行才能使timeout设置正常工作，通过myBatis执行的sql操作将无法应用超时设置。原因是通过mybatis执行的sql操作，虽然会设置deadline，但是并不会去校验是否timeout。但是在jdbc操作中，会校验applyTransactionTimeout，所以timeout会传递给jdbc

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    public static void applyTransactionTimeout(Statement stmt, DataSource dataSource) throws SQLException {
    		applyTimeout(stmt, dataSource, 0);
    	}
     
     
    public static void applyTimeout(Statement stmt, DataSource dataSource, int timeout) throws SQLException {
    		Assert.notNull(stmt, "No Statement specified");
    		Assert.notNull(dataSource, "No DataSource specified");
    		ConnectionHolder holder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);
    		if (holder != null && holder.hasTimeout()) {
    			// 设置statment的超时时间
    			stmt.setQueryTimeout(holder.getTimeToLiveInSeconds());
    		}
    		else if (timeout > 0) {
    			// No current transaction timeout -> apply specified value.
    			stmt.setQueryTimeout(timeout);
    		}
    	}

  1. 在mybatis-spring1.3.0版本中，org.mybatis.spring.transaction.SpringManagedTransaction中添加了getTimeout的校验，此时会调用getTimeToLiveInSeconds校验事务是否超时。

    1
    2
    3
    4
    5
    6
    7
    8
    @Override
      public Integer getTimeout() throws SQLException {
        ConnectionHolder holder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);
        if (holder != null && holder.hasTimeout()) {
          return holder.getTimeToLiveInSeconds();
        } 
        return null;
      }
    • 在getTimeToLiveInSeconds方法中，会校验当前事务是否超时
    • 该方法在mybatis-spring1.2.2中getTimeout()并不存在

解决方式

  1. 观测到在注解中声明的timeout并不会修改defaultTimeout值并且作用于spring事务

  2. 查看源码，会优先使用defination中设置的timeout，只有当TransactionDefinition中的timeout未设置或者等于TransactionDefinition.TIMEOUT_DEFAULT的时候，defaultTimeout才会生效

    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    /**
    	 * Determine the actual timeout to use for the given definition.
    	 * Will fall back to this manager's default timeout if the
    	 * transaction definition doesn't specify a non-default value.
    	 * @param definition the transaction definition
    	 * @return the actual timeout to use
    	 * @see org.springframework.transaction.TransactionDefinition#getTimeout()
    	 * @see #setDefaultTimeout
    	 */
    	protected int determineTimeout(TransactionDefinition definition) {
    		if (definition.getTimeout() != TransactionDefinition.TIMEOUT_DEFAULT) {
    			return definition.getTimeout();
    		}
    		return this.defaultTimeout;
    	}

  3. 修改TransactionUtil中的代码，在DefaultTransactionDefinition声明当前事务的超时时间

    1
    2
    3
    4
    5
    6
    7
    8
    9
    DefaultTransactionDefinition def = new DefaultTransactionDefinition();
    if (propagation != null) {
        def.setPropagationBehavior(propagation.value());
    } else {
        def.setPropagationBehavior(Propagation.REQUIRED.value());
    }
    def.setTimeout(timeout);
       
    TransactionStatus status = transactionManager.getTransaction(def);

参考文档

  1. 事务超时) (理解spring、mybais、jdbc、myql各层超时时间的设置与作用)