一、什么是事务
事务是一系列操作组成的工作单元,该工作单元的操作是不可分割的,也就是说,要么都执行,要么都不执行。它具有ACID四个属性:
(1)原子性(atomicity):操作这些指令时,要么全部执行成功,要么全部不执行。只要其中一个指令执行失败,所有的指令都执行失败,数据进行回滚,回到执行指令前的数据状态。
(2)一致性(consistency):事务的执行使数据从一个状态转换为另一个状态,但是对于整个数据的完整性保持稳定。
(3)隔离性(isolation):在该事务执行的过程中,无论发生的任何数据的改变都应该只存在于该事务之中,对外界不存在任何影响。只有在事务确定正确提交之后,才会显示该事务对数据的改变。其他事务才能获取到这些改变后的数据。
(4)持久性(durability):当事务正确完成后,它对于数据的改变是永久性的。
二、Spring事务管理
Spring并不直接管理事务,而是提供了多种事务管理器,他们将事务管理的职责委托给Hibernate或者JTA等持久化机制所提供的相关平台框架的事务来实现。Spring事务管理器的接口是org.springframework.transaction.PlatformTransactionManager,通过这个接口,Spring为各个平台如JDBC、Hibernate等都提供了对应的事务管理器,但是具体的实现就是各个平台自己的事情了。
如mybatis的事务配置如下:
从原理上来看,Spring事务基于AOP实现,AOP实现基于JDK动态代理,如:
代理方法{
开始事务
业务方法
异常?回滚事务:不回滚
提交事务
}
spring 对应的源码:
TransactionInfo txInfo = createTransactionIfNecessary(tm,txAttr,....);
Object retVal = null ;
try{
retVal = invocation.proceedWithInvocation();
}catch(Throwable ex){
compelteTransactionAfterThrowing(txInfo , ex);
throw ex ;
}finally{
cleanupTransactionInfo(txInfo );
}
commitTransactionAfterReturning(txInfo);
return retVal;
三、Spring 事务的传播属性
所谓spring事务的传播属性,就是定义在多个事务同时存在的时候,spring应该如何处理这些事务的行为。这些属性在TransactionDefinition中定义。
(1)PROPAGATION_REQUIRED:如果当前存在事务,则使用当前事务,如果不存在则新建事务。
(2)PROPAGATION_REQUIRES_NEW:如果当前存在事务,则当前事务挂起,创建新的事务,会影响当前事务的回滚。
(3)PROPAGATION_SUPPORTS:如果当前存在事务,则使用当前事务,如果不存在,则不使用事务。
(4)PROPAGATION_MANDATORY:支持当前事务,如果当前没有事务,就抛出异常。
(5)PROPAGATION_NOT_SUPPORTED:如果当前存在事务,则当前事务挂起,使用非事务的方式执行。
(6)PROPAGATION_NEVER:以非事务的方式执行,如果当前存在事务,则抛出异常。
(7)PROPAGATION_NESTED:如果当前存在事务,创建一个带有保存点的嵌套事务,如果当前不存在事务,就创建一个新的事务。
Spring异常捕获方式:被拦截的方法需显式抛出异常,并不能经任何处理,这样aop代理才能捕获到方法的异常,才能进行回滚,默认情况下aop只捕获runtimeexception的异常,但可以通过 。所以,在service的方法中不使用try catch 或者在catch中最后加上throw new runtimeexcetpion(),这样程序异常时才能被aop捕获进而回滚。
四、模拟用例
介绍了这么多事务传播行为,我们在实际工作中如何应用呢?下面我来举一个示例:
假设我们有一个注册的方法,方法中调用添加积分的方法,如果我们希望添加积分不会影响注册流程(即添加积分执行失败回滚不能使注册方法也回滚),我们会这样写:
@Service
public class UserServiceImpl implements UserService{
@Transactional
public void register(User user){
try{
membershipPointService.addPoint(Point point);
}catch(Exception e) {//省略...}
//省略...
}
//省略...
}
我们还规定注册失败要影响addPoint()方法(注册方法回滚添加积分方法也需要回滚),那么addPoint()方法就需要这样实现:
@Service
public class MembershipPointServiceImpl implements MembershipPointService{
@Transactional(propagation = Propagation.NESTED)
public void addPoint(Point point){
try{
recordService.addRecord(Record record);
}catch(Exception e) {
//省略...
}
//省略...
}
//省略...
}
我们注意到了在addPoint()中还调用了addRecord()方法,这个方法用来记录日志。他的实现如下:
@Service
public class RecordServiceImpl implements RecordService{
@Transactional(propagation = Propagation.NOT_SUPPORTED)
public void addRecord(Record record){
//省略...
}
//省略...
}
我们注意到addRecord()方法中propagation = Propagation.NOT_SUPPORTED,因为对于日志无所谓精确,可以多一条也可以少一条,所以addRecord()方法本身和外围addPoint()方法抛出异常都不会使addRecord()方法回滚,并且addRecord()方法抛出异常也不会影响外围addPoint()方法的执行。
通过这个例子相信大家对事务传播行为的使用有了更加直观的认识,通过各种属性的组合确实能让我们的业务实现更加灵活多样。






网友评论