TransactionTemplate编程式事务

目录

一、TransactionTemplate相关源码

Spring支持编程式事务和声明式事务；
因为业务
  1.需要细粒度更高的事务控制；
  2.需要频繁与其他系统交互  

      举例：需要从A系统获取数据，根据获取的数据去跟B系统交互。整理处理完之后再与C系统交互。获取回执返回给A系统。与其他系统的交互掺杂在自己的业务代码中，如果用声明式事务对整个方法进行管控容易出现事务失效或者因系统通讯问题导致事务控制时间过长。

    所以工作中使用的是编程式事务（统一了事务种类，没有使用声明式事务）。图中绿框范围内的内容涉及到本地数据修改，需要用事务控制（绿框外的部分以数据传递为主，着重记录流水，这部分不纳入事务控制范围），也是业务重点，实际是以多线程方式与B系统交互，出现异常时用事务进行数据回滚和异常日志记录，并且不再执行后续的任务。
框架使用的是spring4.3.4.release版本。

一、TransactionTemplate相关源码

1.  
   public class TransactionTemplate extends DefaultTransactionDefinition
2.  
   implements TransactionOperations, InitializingBean {
3.  
    
4.  
   // 定义事务控制器
5.  
   private PlatformTransactionManager transactionManager;

1）TransactionTemplate类

有三个主要方法：

        1> afterPropertiesSet  bean实例化->生成对象->属性填充后进行了非空校验

        2> execute 任务执行

        3> rollbackOnException 回滚方法

一个成员变量：

        transactionManager，对应PlatformTransactionManager事务控制器

                ——execute和rollbackOnException方法里的具体事务控制都是调用的PlatformTransactionManager里的接口方法(具体的事务管理受数据源影响)

1.  
   public interface PlatformTransactionManager {
2.  
   //根据事务定义TransactionDefinition，获取事务
3.  
   TransactionStatus getTransaction(TransactionDefinition definition);
4.  
   //提交事务
5.  
   void commit(TransactionStatus status);
6.  
   //回滚事务
7.  
   void rollback(TransactionStatus status);
8.  
   }

补充：由于扩展DefaultTransactionDefinition方法（DefaultTransactionDefinition实现了TransactionDefinition接口），因此TransactionTemplate可以设置事务传播属性、隔离级别信息。

  a) 核心方法execute(TransactionCallback<T> action) ，（实现TransactionOperations接口）。

1.  
   public <T> T execute(TransactionCallback<T> action) throws TransactionException {
2.  
   if (this.transactionManager instanceof CallbackPreferringPlatformTransactionManager) {
3.  
   return ((CallbackPreferringPlatformTransactionManager)this.transactionManager).execute(this, action);
4.  
   } else {
5.  
   TransactionStatus status = this.transactionManager.getTransaction(this);
6.  
    
7.  
   Object result;
8.  
   try {
9.  
   result = action.doInTransaction(status);
10.  
    } catch (RuntimeException var5) {
11.  
    this.rollbackOnException(status, var5);
12.  
    throw var5;
13.  
    } catch (Error var6) {
14.  
    this.rollbackOnException(status, var6);
15.  
    throw var6;
16.  
    } catch (Throwable var7) {
17.  
    this.rollbackOnException(status, var7);
18.  
    throw new UndeclaredThrowableException(var7, "TransactionCallback threw undeclared checked exception");
19.  
    }
20.  
     
21.  
    this.transactionManager.commit(status);
22.  
    return result;
23.  
    }
24.  
    }

使用前需要private TransactionTemplate trsTemplate;注入TransactionTemplate事务模板

进而实现TransactionCallback<T>接口的T doInTransaction(TransactionStatus status);方法，通过匿名内部类的方式在doInTransaction里重写需要进行事务控制的业务代码即可。

补充：其实借助TransactionTemplate .execute(...)执行事务管理的时候，传入的参数有两种选择：

1.TransactionCallback

2.TransactionCallbackWithoutResult

前者有返回值，后者无返回值。两者一般是功能上对读写进行区分。当时项目统一了使用TransactionCallback。

1.  
   this.trsTemplate.execute(new TransactionCallback() {
2.  
    
3.  
   @Override
4.  
   public Object doInTransaction(TransactionStatus status) {
5.  
   // 需要事务控制的业务代码
6.  
   }
7.  
   return null;
8.  
   }
9.  
   });

b) 事务异常回滚方法：

        程序未出现异常时由this.transactionManager.commit(status);进行事务提交，出现异常并能够被程序捕获且处理时由this.rollbackOnException(status, var);进行回滚

1.  
   private void rollbackOnException(TransactionStatus status, Throwable ex) throws TransactionException {
2.  
   this.logger.debug("Initiating transaction rollback on application exception", ex);
3.  
    
4.  
   try {
5.  
   this.transactionManager.rollback(status);
6.  
   } catch (TransactionSystemException var4) {
7.  
   this.logger.error("Application exception overridden by rollback exception", ex);
8.  
   var4.initApplicationException(ex);
9.  
   throw var4;
10.  
    } catch (RuntimeException var5) {
11.  
    this.logger.error("Application exception overridden by rollback exception", ex);
12.  
    throw var5;
13.  
    } catch (Error var6) {
14.  
    this.logger.error("Application exception overridden by rollback error", ex);
15.  
    throw var6;
16.  
    }
17.  
    }

二、事务 

补充：Spring事务控制主要有下面三个部分

        1.PlatformTransactionManager 事务控制器，spring事务管理的顶层接口（也是TransactionTemplate里使用的）

        2.TransactionDefinition 事务基础信息 超时时间、隔离级别、传播属性等

        3.TransactionStatus 事务运行状态信息 是否是新事务、是否已被标记为回滚等

1）PlatformTransactionManager事务控制器接口

1.  
   public interface PlatformTransactionManager {
2.  
    
3.  
   //根据事务定义TransactionDefinition，获取事务
4.  
   TransactionStatus getTransaction(TransactionDefinition definition);
5.  
    
6.  
   //提交事务
7.  
   void commit(TransactionStatus status);
8.  
    
9.  
   //回滚事务
10.  
    void rollback(TransactionStatus status);
11.  
    }

PlatformTransactionManager接口由AbstractPlatformTransactionManager抽象类实现，因为项目用的是mybatis和ibatis，所以实际使用的是对应子类DataSourceTransactionManage，相关代码挺多的，大致意思是如果没有传入事务定义就用默认定义DefaultTransactionDefinition；如果存在事务，那么进行事务传播属性处理，如果不存在事务就创建新事务并启用。

2）TransactionDefinition事务基础信息接口

之前1）中说的默认事务属性定义方法是DefaultTransactionDefinition实现的

1.  
   public DefaultTransactionDefinition(TransactionDefinition other) {
2.  
   this.propagationBehavior = other.getPropagationBehavior();
3.  
   this.isolationLevel = other.getIsolationLevel();
4.  
   this.timeout = other.getTimeout();
5.  
   this.readOnly = other.isReadOnly();
6.  
   this.name = other.getName();
7.  
   }
8.  
    
9.  
    
10.  
    // 事务的传播属性 如果没有当前事务就新建，如果有就使用当前事务
11.  
    private int propagationBehavior = PROPAGATION_REQUIRED;
12.  
     
13.  
    // 事务的隔离级别 数据库默认的隔离级别
14.  
    private int isolationLevel = ISOLATION_DEFAULT;
15.  
     
16.  
    // 超时时间采用底层数据库默认的超时时间
17.  
    private int timeout = TIMEOUT_DEFAULT;
18.  
     
19.  
    // 是否只读为false
20.  
    private boolean readOnly = false;
21.  
     
22.  
    private String name;

补充

a).事务的隔离级别是数据库本身的事务功能，然而事务的传播属性则是Spring自己为我们提供的功能，数据库事务没有事务的传播属性这一说法

b).propagationBehavior常见枚举值

c)事务隔离级别待补充，不同数据库不一样，常见是下面几类

隔离级别是指若干个并发的事务之间的隔离程度。TransactionDefinition 接口中定义了五个表示隔离级别的常量： T

TransactionDefinition.ISOLATION_DEFAULT：表示使用底层数据库的默认隔离级别。 TransactionDefinition.ISOLATION_READ_UNCOMMITTED：该隔离级别表示一个事务可以读取另一个事务修改但还没有提交的数据。该级别不能防止脏读和不可重复读，因此很少使用该隔离级别。 TransactionDefinition.ISOLATION_READ_COMMITTED：该隔离级别表示一个事务只能读取另一个事务已经提交的数据。该级别可以防止脏读，这也是大多数情况下的推荐值。 TransactionDefinition.ISOLATION_REPEATABLE_READ：该隔离级别表示一个事务在整个过程中可以多次重复执行某个查询，并且每次返回的记录都相同。即使在多次查询之间有新增的数据满足该查询，这些新增的记录也会被忽略。该级别可以防止脏读和不可重复读。 TransactionDefinition.ISOLATION_SERIALIZABLE：所有的事务依次逐个执行，这样事务之间就完全不可能产生干扰，也就是说，该级别可以防止脏读、不可重复读以及幻读。但是这将严重影响程序的性能。通常情况下也不会用到该级别。

 3.TransactionStatus事务运行状态信息接口

TransactionTemplate类里execute方法获取任务状态就调用AbstractPlatformTransactionManager的对应方法。

TransactionStatus status = this.transactionManager.getTransaction(this);

1.  
   @Override
2.  
   public final TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException {
3.  
   Object transaction = doGetTransaction();
4.  
    
5.  
   // Cache debug flag to avoid repeated checks.
6.  
   boolean debugEnabled = logger.isDebugEnabled();
7.  
    
8.  
   if (definition == null) {
9.  
   // Use defaults if no transaction definition given.
10.  
    definition = new DefaultTransactionDefinition();
11.  
    }
12.  
     
13.  
    if (isExistingTransaction(transaction)) {
14.  
    // Existing transaction found -> check propagation behavior to find out how to behave.
15.  
    return handleExistingTransaction(definition, transaction, debugEnabled);
16.  
    }
17.  
     
18.  
    // Check definition settings for new transaction.
19.  
    if (definition.getTimeout() < TransactionDefinition.TIMEOUT_DEFAULT) {
20.  
    throw new InvalidTimeoutException("Invalid transaction timeout", definition.getTimeout());
21.  
    }
22.  
     
23.  
    // No existing transaction found -> check propagation behavior to find out how to proceed.
24.  
    if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_MANDATORY) {
25.  
    throw new IllegalTransactionStateException(
26.  
    "No existing transaction found for transaction marked with propagation 'mandatory'");
27.  
    }
28.  
    else if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRED ||
29.  
    definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRES_NEW ||
30.  
    definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_NESTED) {
31.  
    SuspendedResourcesHolder suspendedResources = suspend(null);
32.  
    if (debugEnabled) {
33.  
    logger.debug("Creating new transaction with name [" definition.getName() "]: " definition);
34.  
    }
35.  
    try {
36.  
    boolean newSynchronization = (getTransactionSynchronization() != SYNCHRONIZATION_NEVER);
37.  
    DefaultTransactionStatus status = newTransactionStatus(
38.  
    definition, transaction, true, newSynchronization, debugEnabled, suspendedResources);
39.  
    doBegin(transaction, definition);
40.  
    prepareSynchronization(status, definition);
41.  
    return status;
42.  
    }
43.  
    catch (RuntimeException ex) {
44.  
    resume(null, suspendedResources);
45.  
    throw ex;
46.  
    }
47.  
    catch (Error err) {
48.  
    resume(null, suspendedResources);
49.  
    throw err;
50.  
    }
51.  
    }
52.  
    else {
53.  
    // Create "empty" transaction: no actual transaction, but potentially synchronization.
54.  
    if (definition.getIsolationLevel() != TransactionDefinition.ISOLATION_DEFAULT && logger.isWarnEnabled()) {
55.  
    logger.warn("Custom isolation level specified but no actual transaction initiated; "
56.  
    "isolation level will effectively be ignored: " definition);
57.  
    }
58.  
    boolean newSynchronization = (getTransactionSynchronization() == SYNCHRONIZATION_ALWAYS);
59.  
    return prepareTransactionStatus(definition, null, true, newSynchronization, debugEnabled, null);
60.  
    }
61.  
    }

一般使用DefaultTransactionStatus实现TransactionStatus接口

这篇好文章是转载于：学新通技术网