1 初步理解

理解事务之前&＃xff0c;先讲一个你日常生活中最常干的事&＃xff1a;取钱。 
比如你去ATM机取1000块钱&＃xff0c;大体有两个步骤&＃xff1a;首先输入密码金额&＃xff0c;银行卡扣掉1000元钱&＃xff1b;然后ATM出1000元钱。这两个步骤必须是要么都执行要么都不执行。如果银行卡扣除了1000块但是ATM出钱失败的话&＃xff0c;你将会损失1000元&＃xff1b;如果银行卡扣钱失败但是ATM却出了1000块&＃xff0c;那么银行将损失1000元。所以&＃xff0c;如果一个步骤成功另一个步骤失败对双方都不是好事&＃xff0c;如果不管哪一个步骤失败了以后&＃xff0c;整个取钱过程都能回滚&＃xff0c;也就是完全取消所有操作的话&＃xff0c;这对双方都是极好的。 
事务就是用来解决类似问题的。事务是一系列的动作&＃xff0c;它们综合在一起才是一个完整的工作单元&＃xff0c;这些动作必须全部完成&＃xff0c;如果有一个失败的话&＃xff0c;那么事务就会回滚到最开始的状态&＃xff0c;仿佛什么都没发生过一样。 
在企业级应用程序开发中&＃xff0c;事务管理必不可少的技术&＃xff0c;用来确保数据的完整性和一致性。 
事务有四个特性&＃xff1a;ACID

• 原子性&＃xff08;Atomicity&＃xff09;&＃xff1a;事务是一个原子操作&＃xff0c;由一系列动作组成。事务的原子性确保动作要么全部完成&＃xff0c;要么完全不起作用。
• 一致性&＃xff08;Consistency&＃xff09;&＃xff1a;一旦事务完成&＃xff08;不管成功还是失败&＃xff09;&＃xff0c;系统必须确保它所建模的业务处于一致的状态&＃xff0c;而不会是部分完成部分失败。在现实中的数据不应该被破坏。
• 隔离性&＃xff08;Isolation&＃xff09;&＃xff1a;可能有许多事务会同时处理相同的数据&＃xff0c;因此每个事务都应该与其他事务隔离开来&＃xff0c;防止数据损坏。
• 持久性&＃xff08;Durability&＃xff09;&＃xff1a;一旦事务完成&＃xff0c;无论发生什么系统错误&＃xff0c;它的结果都不应该受到影响&＃xff0c;这样就能从任何系统崩溃中恢复过来。通常情况下&＃xff0c;事务的结果被写到持久化存储器中。

2 核心接口

Spring事务管理的实现有许多细节&＃xff0c;如果对整个接口框架有个大体了解会非常有利于我们理解事务&＃xff0c;下面通过讲解Spring的事务接口来了解Spring实现事务的具体策略。 
Spring事务管理涉及的接口的联系如下&＃xff1a;

2.1 事务管理器

Spring并不直接管理事务&＃xff0c;而是提供了多种事务管理器&＃xff0c;他们将事务管理的职责委托给Hibernate或者JTA等持久化机制所提供的相关平台框架的事务来实现。 
Spring事务管理器的接口是org.springframework.transaction.PlatformTransactionManager&＃xff0c;通过这个接口&＃xff0c;Spring为各个平台如JDBC、Hibernate等都提供了对应的事务管理器&＃xff0c;但是具体的实现就是各个平台自己的事情了。此接口的内容如下&＃xff1a;

Public interface PlatformTransactionManager()...{ // 由TransactionDefinition得到TransactionStatus对象TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; // 提交Void commit(TransactionStatus status) throws TransactionException; // 回滚Void rollback(TransactionStatus status) throws TransactionException; }

从这里可知具体的具体的事务管理机制对Spring来说是透明的&＃xff0c;它并不关心那些&＃xff0c;那些是对应各个平台需要关心的&＃xff0c;所以Spring事务管理的一个优点就是为不同的事务API提供一致的编程模型&＃xff0c;如JTA、JDBC、Hibernate、JPA。下面分别介绍各个平台框架实现事务管理的机制。

2.1.1 JDBC事务

如果应用程序中直接使用JDBC来进行持久化&＃xff0c;DataSourceTransactionManager会为你处理事务边界。为了使用DataSourceTransactionManager&＃xff0c;你需要使用如下的XML将其装配到应用程序的上下文定义中&＃xff1a;

id&＃61;"transactionManager" class&＃61;"org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name&＃61;"dataSource" ref&＃61;"dataSource" />

实际上&＃xff0c;DataSourceTransactionManager是通过调用java.sql.Connection来管理事务&＃xff0c;而后者是通过DataSource获取到的。通过调用连接的commit()方法来提交事务&＃xff0c;同样&＃xff0c;事务失败则通过调用rollback()方法进行回滚。

2.1.2 Hibernate事务

如果应用程序的持久化是通过Hibernate实习的&＃xff0c;那么你需要使用HibernateTransactionManager。对于Hibernate3&＃xff0c;需要在Spring上下文定义中添加如下的声明&＃xff1a;

id&＃61;"transactionManager" class&＃61;"org.springframework.orm.hibernate3.HibernateTransactionManager"><property name&＃61;"sessionFactory" ref&＃61;"sessionFactory" />

sessionFactory属性需要装配一个Hibernate的session工厂&＃xff0c;HibernateTransactionManager的实现细节是它将事务管理的职责委托给org.hibernate.Transaction对象&＃xff0c;而后者是从Hibernate Session中获取到的。当事务成功完成时&＃xff0c;HibernateTransactionManager将会调用Transaction对象的commit()方法&＃xff0c;反之&＃xff0c;将会调用rollback()方法。

2.1.3 Java持久化API事务&＃xff08;JPA&＃xff09;

Hibernate多年来一直是事实上的Java持久化标准&＃xff0c;但是现在Java持久化API作为真正的Java持久化标准进入大家的视野。如果你计划使用JPA的话&＃xff0c;那你需要使用Spring的JpaTransactionManager来处理事务。你需要在Spring中这样配置JpaTransactionManager&＃xff1a;

id&＃61;"transactionManager" class&＃61;"org.springframework.orm.jpa.JpaTransactionManager"><property name&＃61;"sessionFactory" ref&＃61;"sessionFactory" />

JpaTransactionManager只需要装配一个JPA实体管理工厂&＃xff08;javax.persistence.EntityManagerFactory接口的任意实现&＃xff09;。JpaTransactionManager将与由工厂所产生的JPA EntityManager合作来构建事务。

2.1.4 Java原生API事务

如果你没有使用以上所述的事务管理&＃xff0c;或者是跨越了多个事务管理源&＃xff08;比如两个或者是多个不同的数据源&＃xff09;&＃xff0c;你就需要使用JtaTransactionManager&＃xff1a;

id&＃61;"transactionManager" class&＃61;"org.springframework.transaction.jta.JtaTransactionManager"><property name&＃61;"transactionManagerName" value&＃61;"java:/TransactionManager" />

JtaTransactionManager将事务管理的责任委托给javax.transaction.UserTransaction和javax.transaction.TransactionManager对象&＃xff0c;其中事务成功完成通过UserTransaction.commit()方法提交&＃xff0c;事务失败通过UserTransaction.rollback()方法回滚。

2.2 基本事务属性的定义

上面讲到的事务管理器接口PlatformTransactionManager通过getTransaction(TransactionDefinition definition)方法来得到事务&＃xff0c;这个方法里面的参数是TransactionDefinition类&＃xff0c;这个类就定义了一些基本的事务属性。 
那么什么是事务属性呢&＃xff1f;事务属性可以理解成事务的一些基本配置&＃xff0c;描述了事务策略如何应用到方法上。事务属性包含了5个方面&＃xff0c;如图所示&＃xff1a;

而TransactionDefinition接口内容如下&＃xff1a;

public interface TransactionDefinition {int getPropagationBehavior(); // 返回事务的传播行为int getIsolationLevel(); // 返回事务的隔离级别&＃xff0c;事务管理器根据它来控制另外一个事务可以看到本事务内的哪些数据int getTimeout(); // 返回事务必须在多少秒内完成boolean isReadOnly(); // 事务是否只读&＃xff0c;事务管理器能够根据这个返回值进行优化&＃xff0c;确保事务是只读的
}

我们可以发现TransactionDefinition正好用来定义事务属性&＃xff0c;下面详细介绍一下各个事务属性。

2.2.1 传播行为

事务的第一个方面是传播行为&＃xff08;propagation behavior&＃xff09;。当事务方法被另一个事务方法调用时&＃xff0c;必须指定事务应该如何传播。例如&＃xff1a;方法可能继续在现有事务中运行&＃xff0c;也可能开启一个新事务&＃xff0c;并在自己的事务中运行。Spring定义了七种传播行为&＃xff1a;

注&＃xff1a;以下具体讲解传播行为的内容参考自Spring事务机制详解 
&＃xff08;1&＃xff09;PROPAGATION_REQUIRED 如果存在一个事务&＃xff0c;则支持当前事务。如果没有事务则开启一个新的事务。

//事务属性 PROPAGATION_REQUIRED
methodA{……methodB();……
}

//事务属性 PROPAGATION_REQUIRED
methodB{……
}

使用spring声明式事务&＃xff0c;spring使用AOP来支持声明式事务&＃xff0c;会根据事务属性&＃xff0c;自动在方法调用之前决定是否开启一个事务&＃xff0c;并在方法执行之后决定事务提交或回滚事务。

单独调用methodB方法&＃xff1a;

main{ metodB();
}

相当于

Main{ Connection con&＃61;null; try{ con &＃61; getConnection(); con.setAutoCommit(false); //方法调用methodB(); //提交事务con.commit(); } Catch(RuntimeException ex) { //回滚事务con.rollback(); } finally { //释放资源closeCon(); }
}

Spring保证在methodB方法中所有的调用都获得到一个相同的连接。在调用methodB时&＃xff0c;没有一个存在的事务&＃xff0c;所以获得一个新的连接&＃xff0c;开启了一个新的事务。 
单独调用MethodA时&＃xff0c;在MethodA内又会调用MethodB.

执行效果相当于&＃xff1a;

main{ Connection con &＃61; null; try{ con &＃61; getConnection(); methodA(); con.commit(); } catch(RuntimeException ex) { con.rollback(); } finally { closeCon(); }
}

调用MethodA时&＃xff0c;环境中没有事务&＃xff0c;所以开启一个新的事务.当在MethodA中调用MethodB时&＃xff0c;环境中已经有了一个事务&＃xff0c;所以methodB就加入当前事务。

&＃xff08;2&＃xff09;PROPAGATION_SUPPORTS 如果存在一个事务&＃xff0c;支持当前事务。如果没有事务&＃xff0c;则非事务的执行。但是对于事务同步的事务管理器&＃xff0c;PROPAGATION_SUPPORTS与不使用事务有少许不同。

//事务属性 PROPAGATION_REQUIRED
methodA(){methodB();
}//事务属性 PROPAGATION_SUPPORTS
methodB(){……
}

单纯的调用methodB时&＃xff0c;methodB方法是非事务的执行的。当调用methdA时,methodB则加入了methodA的事务中,事务地执行。

&＃xff08;3&＃xff09;PROPAGATION_MANDATORY 如果已经存在一个事务&＃xff0c;支持当前事务。如果没有一个活动的事务&＃xff0c;则抛出异常。

//事务属性 PROPAGATION_REQUIRED
methodA(){methodB();
}//事务属性 PROPAGATION_MANDATORYmethodB(){……
}

当单独调用methodB时&＃xff0c;因为当前没有一个活动的事务&＃xff0c;则会抛出异常throw new IllegalTransactionStateException(“Transaction propagation ‘mandatory’ but no existing transaction found”);当调用methodA时&＃xff0c;methodB则加入到methodA的事务中&＃xff0c;事务地执行。

&＃xff08;4&＃xff09;PROPAGATION_REQUIRES_NEW 总是开启一个新的事务。如果一个事务已经存在&＃xff0c;则将这个存在的事务挂起。

//事务属性 PROPAGATION_REQUIRED
methodA(){doSomeThingA();methodB();doSomeThingB();
}//事务属性 PROPAGATION_REQUIRES_NEW
methodB(){……
}

调用A方法&＃xff1a;

main(){methodA();
}

相当于

main(){TransactionManager tm &＃61; null;try{//获得一个JTA事务管理器tm &＃61; getTransactionManager();tm.begin();//开启一个新的事务Transaction ts1 &＃61; tm.getTransaction();doSomeThing();tm.suspend();//挂起当前事务try{tm.begin();//重新开启第二个事务Transaction ts2 &＃61; tm.getTransaction();methodB();ts2.commit();//提交第二个事务} Catch(RunTimeException ex) {ts2.rollback();//回滚第二个事务} finally {//释放资源}//methodB执行完后&＃xff0c;恢复第一个事务tm.resume(ts1);doSomeThingB();ts1.commit();//提交第一个事务} catch(RunTimeException ex) {ts1.rollback();//回滚第一个事务} finally {//释放资源}
}

在这里&＃xff0c;我把ts1称为外层事务&＃xff0c;ts2称为内层事务。从上面的代码可以看出&＃xff0c;ts2与ts1是两个独立的事务&＃xff0c;互不相干。Ts2是否成功并不依赖于 ts1。如果methodA方法在调用methodB方法后的doSomeThingB方法失败了&＃xff0c;而methodB方法所做的结果依然被提交。而除了 methodB之外的其它代码导致的结果却被回滚了。使用PROPAGATION_REQUIRES_NEW,需要使用 JtaTransactionManager作为事务管理器。

&＃xff08;5&＃xff09;PROPAGATION_NOT_SUPPORTED 总是非事务地执行&＃xff0c;并挂起任何存在的事务。使用PROPAGATION_NOT_SUPPORTED,也需要使用JtaTransactionManager作为事务管理器。&＃xff08;代码示例同上&＃xff0c;可同理推出&＃xff09;

&＃xff08;6&＃xff09;PROPAGATION_NEVER 总是非事务地执行&＃xff0c;如果存在一个活动事务&＃xff0c;则抛出异常。

&＃xff08;7&＃xff09;PROPAGATION_NESTED如果一个活动的事务存在&＃xff0c;则运行在一个嵌套的事务中. 如果没有活动事务, 则按TransactionDefinition.PROPAGATION_REQUIRED 属性执行。这是一个嵌套事务,使用JDBC 3.0驱动时,仅仅支持DataSourceTransactionManager作为事务管理器。需要JDBC 驱动的java.sql.Savepoint类。有一些JTA的事务管理器实现可能也提供了同样的功能。使用PROPAGATION_NESTED&＃xff0c;还需要把PlatformTransactionManager的nestedTransactionAllowed属性设为true;而 nestedTransactionAllowed属性值默认为false。

//事务属性 PROPAGATION_REQUIRED
methodA(){doSomeThingA();methodB();doSomeThingB();
}//事务属性 PROPAGATION_NESTED
methodB(){……
}

如果单独调用methodB方法&＃xff0c;则按REQUIRED属性执行。如果调用methodA方法&＃xff0c;相当于下面的效果&＃xff1a;

main(){Connection con &＃61; null;Savepoint savepoint &＃61; null;try{con &＃61; getConnection();con.setAutoCommit(false);doSomeThingA();savepoint &＃61; con2.setSavepoint();try{methodB();} catch(RuntimeException ex) {con.rollback(savepoint);} finally {//释放资源}doSomeThingB();con.commit();} catch(RuntimeException ex) {con.rollback();} finally {//释放资源}
}

当methodB方法调用之前&＃xff0c;调用setSavepoint方法&＃xff0c;保存当前的状态到savepoint。如果methodB方法调用失败&＃xff0c;则恢复到之前保存的状态。但是需要注意的是&＃xff0c;这时的事务并没有进行提交&＃xff0c;如果后续的代码(doSomeThingB()方法)调用失败&＃xff0c;则回滚包括methodB方法的所有操作。

嵌套事务一个非常重要的概念就是内层事务依赖于外层事务。外层事务失败时&＃xff0c;会回滚内层事务所做的动作。而内层事务操作失败并不会引起外层事务的回滚。

PROPAGATION_NESTED 与PROPAGATION_REQUIRES_NEW的区别:它们非常类似,都像一个嵌套事务&＃xff0c;如果不存在一个活动的事务&＃xff0c;都会开启一个新的事务。使用 PROPAGATION_REQUIRES_NEW时&＃xff0c;内层事务与外层事务就像两个独立的事务一样&＃xff0c;一旦内层事务进行了提交后&＃xff0c;外层事务不能对其进行回滚。两个事务互不影响。两个事务不是一个真正的嵌套事务。同时它需要JTA事务管理器的支持。

使用PROPAGATION_NESTED时&＃xff0c;外层事务的回滚可以引起内层事务的回滚。而内层事务的异常并不会导致外层事务的回滚&＃xff0c;它是一个真正的嵌套事务。DataSourceTransactionManager使用savepoint支持PROPAGATION_NESTED时&＃xff0c;需要JDBC 3.0以上驱动及1.4以上的JDK版本支持。其它的JTA TrasactionManager实现可能有不同的支持方式。

PROPAGATION_REQUIRES_NEW 启动一个新的, 不依赖于环境的 “内部” 事务. 这个事务将被完全 commited 或 rolled back 而不依赖于外部事务, 它拥有自己的隔离范围, 自己的锁, 等等. 当内部事务开始执行时, 外部事务将被挂起, 内务事务结束时, 外部事务将继续执行。

另一方面, PROPAGATION_NESTED 开始一个 “嵌套的” 事务, 它是已经存在事务的一个真正的子事务. 潜套事务开始执行时, 它将取得一个 savepoint. 如果这个嵌套事务失败, 我们将回滚到此 savepoint. 潜套事务是外部事务的一部分, 只有外部事务结束后它才会被提交。

由此可见, PROPAGATION_REQUIRES_NEW 和 PROPAGATION_NESTED 的最大区别在于, PROPAGATION_REQUIRES_NEW 完全是一个新的事务, 而 PROPAGATION_NESTED 则是外部事务的子事务, 如果外部事务 commit, 嵌套事务也会被 commit, 这个规则同样适用于 roll back.

PROPAGATION_REQUIRED应该是我们首先的事务传播行为。它能够满足我们大多数的事务需求。

2.2.2 隔离级别

事务的第二个维度就是隔离级别&＃xff08;isolation level&＃xff09;。隔离级别定义了一个事务可能受其他并发事务影响的程度。 
&＃xff08;1&＃xff09;并发事务引起的问题 
在典型的应用程序中&＃xff0c;多个事务并发运行&＃xff0c;经常会操作相同的数据来完成各自的任务。并发虽然是必须的&＃xff0c;但可能会导致一下的问题。

• 脏读&＃xff08;Dirty reads&＃xff09;——脏读发生在一个事务读取了另一个事务改写但尚未提交的数据时。如果改写在稍后被回滚了&＃xff0c;那么第一个事务获取的数据就是无效的。
• 不可重复读&＃xff08;Nonrepeatable read&＃xff09;——不可重复读发生在一个事务执行相同的查询两次或两次以上&＃xff0c;但是每次都得到不同的数据时。这通常是因为另一个并发事务在两次查询期间进行了更新。
• 幻读&＃xff08;Phantom read&＃xff09;——幻读与不可重复读类似。它发生在一个事务&＃xff08;T1&＃xff09;读取了几行数据&＃xff0c;接着另一个并发事务&＃xff08;T2&＃xff09;插入了一些数据时。在随后的查询中&＃xff0c;第一个事务&＃xff08;T1&＃xff09;就会发现多了一些原本不存在的记录。

不可重复读与幻读的区别

不可重复读的重点是修改: 
同样的条件, 你读取过的数据, 再次读取出来发现值不一样了 
例如&＃xff1a;在事务1中&＃xff0c;Mary 读取了自己的工资为1000,操作并没有完成

con1 &＃61; getConnection(); select salary from employee empId &＃61;"Mary";

在事务2中&＃xff0c;这时财务人员修改了Mary的工资为2000,并提交了事务.

con2 &＃61; getConnection(); update employee set salary &＃61; 2000; con2.commit();

在事务1中&＃xff0c;Mary 再次读取自己的工资时&＃xff0c;工资变为了2000

//con1 select salary from employee empId &＃61;"Mary";

在一个事务中前后两次读取的结果并不一致&＃xff0c;导致了不可重复读。

幻读的重点在于新增或者删除&＃xff1a; 
同样的条件, 第1次和第2次读出来的记录数不一样 
例如&＃xff1a;目前工资为1000的员工有10人。事务1,读取所有工资为1000的员工。

con1 &＃61; getConnection(); Select * from employee where salary &＃61;1000;

共读取10条记录

这时另一个事务向employee表插入了一条员工记录&＃xff0c;工资也为1000

con2 &＃61; getConnection(); Insert into employee(empId,salary) values("Lili",1000); con2.commit();

事务1再次读取所有工资为1000的员工

//con1 select * from employee where salary &＃61;1000;

共读取到了11条记录&＃xff0c;这就产生了幻像读。

从总的结果来看, 似乎不可重复读和幻读都表现为两次读取的结果不一致。但如果你从控制的角度来看, 两者的区别就比较大。 
对于前者, 只需要锁住满足条件的记录。 
对于后者, 要锁住满足条件及其相近的记录。

&＃xff08;2&＃xff09;隔离级别

2.2.3 只读

事务的第三个特性是它是否为只读事务。如果事务只对后端的数据库进行该操作&＃xff0c;数据库可以利用事务的只读特性来进行一些特定的优化。通过将事务设置为只读&＃xff0c;你就可以给数据库一个机会&＃xff0c;让它应用它认为合适的优化措施。

2.2.4 事务超时

为了使应用程序很好地运行&＃xff0c;事务不能运行太长的时间。因为事务可能涉及对后端数据库的锁定&＃xff0c;所以长时间的事务会不必要的占用数据库资源。事务超时就是事务的一个定时器&＃xff0c;在特定时间内事务如果没有执行完毕&＃xff0c;那么就会自动回滚&＃xff0c;而不是一直等待其结束。

2.2.5 回滚规则

事务五边形的最后一个方面是一组规则&＃xff0c;这些规则定义了哪些异常会导致事务回滚而哪些不会。默认情况下&＃xff0c;事务只有遇到运行期异常时才会回滚&＃xff0c;而在遇到检查型异常时不会回滚&＃xff08;这一行为与EJB的回滚行为是一致的&＃xff09; 
但是你可以声明事务在遇到特定的检查型异常时像遇到运行期异常那样回滚。同样&＃xff0c;你还可以声明事务遇到特定的异常不回滚&＃xff0c;即使这些异常是运行期异常。

2.3 事务状态

上面讲到的调用PlatformTransactionManager接口的getTransaction()的方法得到的是TransactionStatus接口的一个实现&＃xff0c;这个接口的内容如下&＃xff1a;

public interface TransactionStatus{boolean isNewTransaction(); // 是否是新的事物boolean hasSavepoint(); // 是否有恢复点void setRollbackOnly(); // 设置为只回滚boolean isRollbackOnly(); // 是否为只回滚boolean isCompleted; // 是否已完成
}

可以发现这个接口描述的是一些处理事务提供简单的控制事务执行和查询事务状态的方法&＃xff0c;在回滚或提交的时候需要应用对应的事务状态。

3.事务管理的分类

   3.1 编程式事务管理
        # 手动编写代码进行事务管理.(很少使用)
   3.2 声明式事务管理
        # 基于TransactionProxyFactoryBean的方式.(很少使用)
            * 需要为每个进行事务管理的类,配置一个TransactionProxyFactoryBean进行增强.
        # 基于AspectJ的XML方式.(经常使用)
            * 一旦配置好之后,类上不需要添加任何东西
        # 基于注解方式.(经常使用)
            * 配置简单,需要在业务层上添加一个&＃64;Transactional的注解.