事务是逻辑上的一组操作,要么都执行,要么都不执行。事务能否生效数据库引擎是否支持事务是关键。比如常用的MySQL数据库默认使用支持事务的innodb引擎。但是如果把数据库引擎变为myisam,那么程序就不再支持事务了。
MySQL中保证事务原子性是对已经执行的操作进行回滚。
通过回滚日志实现的。
所有事务进行的修改都会先记录到这个回滚日志中。然后再执行相应的操作。如果执行过程中发生异常,我们利用回滚日志中的信息将数据回滚到修改之前的样子。
回滚日志会先于数据持久化到磁盘上,这样就保证了数据库突然宕机,当用户再次启动数据库的时候,还能通过查询回滚日志来回滚之前未完成的事务。
编程式事务管理
其实我们可以理解成手动提交事务和回滚事务。虽然很少使用但是我们可以了解一下。有两种调用方式:TransactionTemplate或者TransactionManager手动管理事务。使用demo如下:
@Autowired
private TransactionTemplate transactionTemplate;
public void testTransaction() {
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
@Override
protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
try {
// .... 业务代码
} catch (Exception e){
//回滚
transactionStatus.setRollbackOnly();
}
}
});
}
TransactionManager使用方式如下:
@Autowired
private PlatformTransactionManager transactionManager;
public void testTransaction() {
TransactionStatus status = transactionManager.getTransaction(new DefaultTransactionDefinition());
try {
// .... 业务代码
transactionManager.commit(status);
} catch (Exception e) {
transactionManager.rollback(status);
}
}
其实我个人感觉这么些虽然很麻烦,但是灵活多了。而另一种常用的方式是声明式事务管理。虽然使用更加简单,但是其实除了问题挺不容易排查的。
声明式事务管理
这种方式代码入侵性最小。实际上是通过AOP实现的。下面是使用demo:
@Transactional(propagation = Propagation.REQUIRED)
public void aMethod {
//do something
B b = new B();
C c = new C();
b.bMethod();
c.cMethod();
}
Spring框架中,事务管理相关最重要的接口有三个:
TransactionDefinition:事务属性
事务管理器接口通过getTransaction方法来得到一个事务。这个方法里的参数是
TransactionDefinition类。这个类就是定义了一些基本的事务属性。
事务属性包含五个方面:
TransactionStatus:事务状态
TransactionStatus接口用来记录事务的状态,该接口定义了一组方法,用来获取或者判断事务相应的状态信息。内容如下:
public interface TransactionStatus{
boolean isNewTransaction(); // 是否是新的事务
boolean hasSavepoint(); // 是否有恢复点
void setRollbackOnly(); // 设置为只回滚
boolean isRollbackOnly(); // 是否为只回滚
boolean isCompleted; // 是否已完成
}
实际开发中大家一般都使用@Transactional注解来开启事务。这个注解里有一些参数,下面是介绍。
事务传播行为是为了解决业务层方法之间互相调用的事务问题。
当事务方法被另一个事务方法调用时,必须指定事务应该如何传播。例如可以继续在现有事务中运行,也可以开启一个新事务,在自己的事务中运行。
举个例子:我们在A类的a方法中调用了B类的b方法,这个时候如果b方法异常,我们要a也回滚么?如何让a回滚?这就是事务传播行为的知识了。
在TransactionDefinition中定义了以下几个常量:
public interface TransactionDefinition {
int PROPAGATION_REQUIRED = 0;
int PROPAGATION_SUPPORTS = 1;
int PROPAGATION_MANDATORY = 2;
int PROPAGATION_REQUIRES_NEW = 3;
int PROPAGATION_NOT_SUPPORTED = 4;
int PROPAGATION_NEVER = 5;
int PROPAGATION_NESTED = 6;
......
}
当然了spring也定义了枚举类:
package org.springframework.transaction.annotation;
import org.springframework.transaction.TransactionDefinition;
public enum Propagation {
REQUIRED(TransactionDefinition.PROPAGATION_REQUIRED),
SUPPORTS(TransactionDefinition.PROPAGATION_SUPPORTS),
MANDATORY(TransactionDefinition.PROPAGATION_MANDATORY),
REQUIRES_NEW(TransactionDefinition.PROPAGATION_REQUIRES_NEW),
NOT_SUPPORTED(TransactionDefinition.PROPAGATION_NOT_SUPPORTED),
NEVER(TransactionDefinition.PROPAGATION_NEVER),
NESTED(TransactionDefinition.PROPAGATION_NESTED);
private final int value;
Propagation(int value) {
this.value = value;
}
public int value() {
return this.value;
}
}
下面一个一个说:
TransactionDefinition.PROPAGATION_REQUIRED
这个是使用最多的事务传播行为。@Transactional注解默认使用的就是这个事务传播行为。如果当前存在事务,则加入该事务,如果当前没有事务,则创建一个新事务。也就是说:
TransactionDefinition.PROPAGATION_REQUIRES_NEW
创建一个新事务,如果当前存在事务,则把当前事务挂起。也就是说不管外部方法是否开启事务,PROPAGATION_REQUIRES_NEW修饰的内部方法都会开启自己的事务。且开启的事务相互独立,互不干扰。举个例子,如图的两个方法。如果a发生异常回滚,b不会回滚。但是如果b发生异常回滚并且把异常抛出来了,a检测到异常也会回滚。
@Service
Class A {
@Autowired
B b;
@Transactional(propagation = Propagation.REQUIRED)
public void aMethod {
//do something
b.bMethod();
}
}
@Service
Class B {
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void bMethod {
//do something
}
}
TransactionDefinition.PROPAGATION_NESTED
如果当前存在事务,就在嵌套事务内执行。如果当前没有事务,就开启一个事务。也就是说:
TransactionDefinition.PROPAGATION_MANDATORY
这个是当前存在事务则加入。不存在事务则抛异常。这个使用的很少。
TransactionDefinition.PROPAGATION_SUPPORTS
当前存在事务则加入该事务,当前不存在事务就以非事务的方式运行
TransactionDefinition.PROPAGATION_NOT_SUPPORTED
以非事务方式运行,如果当前存在事务则挂起
TransactionDefinition.PROPAGATION_NEVER
以非事务方式运行,如果当前存在事务则报错
TransactionDefinition接口定义了五个隔离级别的常量,当然也有对应的枚举。
public interface TransactionDefinition {
......
int ISOLATION_DEFAULT = -1;
int ISOLATION_READ_UNCOMMITTED = 1;
int ISOLATION_READ_COMMITTED = 2;
int ISOLATION_REPEATABLE_READ = 4;
int ISOLATION_SERIALIZABLE = 8;
......
}
public enum Isolation {
DEFAULT(TransactionDefinition.ISOLATION_DEFAULT),
READ_UNCOMMITTED(TransactionDefinition.ISOLATION_READ_UNCOMMITTED),
READ_COMMITTED(TransactionDefinition.ISOLATION_READ_COMMITTED),
REPEATABLE_READ(TransactionDefinition.ISOLATION_REPEATABLE_READ),
SERIALIZABLE(TransactionDefinition.ISOLATION_SERIALIZABLE);
private final int value;
Isolation(int value) {
this.value = value;
}
public int value() {
return this.value;
}
}
指一个事务允许执行的最长时间。如果超过该时间限制事务还没完成,则自动回滚。在TransactionDefinition 中int值表示时间,单位是秒。默认是-1.表示该事务没有超时时间。
对于只有查询功能的事务,可以指定类型为readonly。即只读事务。只读事务不涉及到数据的修改,数据库会有一些优化手段。适合用在有多条数据库查询操作的方法中。只读为什么还要事务呢?
打个比方,现在一个查询功能是同时查询汇总和每条详细数据的。如果我们先查询了汇总,总金额是100.然后查询详细数据,在汇总之后,查询详细之前多了一笔金额20.可能查出来的详细数据就变成120.这样汇总和详细数据是不一致的。
而当我们启动了只读事务。起码可以保证我们读的汇总和详情是一致的。
默认情况下事务只有遇到运行期一场或者Error才会导致事务回滚。但是在遇到检查型异常时不会回滚。如果想要回滚特定的异常类型的话,可以指定rollbackFor属性。
上面简单说过这个注解的实现是基于AOP。而AOP又是使用动态代理实现的。如果目标对象实现了接口,默认情况下会采用JDK的动态代理,如果目标对象没有实现接口,会使用CGLIB动态代理。
如果一个类或者一个类中的public方法被标注@Transactional注解的话,spring容器就会在启动的时候为其创建一个代理类。在调用被@Transactional注解的public方法时,实际上调用的是TransactionInterceptor类中的Invoke方法。这个方法是作用就是在目标方法之前开启事务,方法执行过程中如果遇到异常的时候回滚事务,方法调用完成之后提交事务。
若同一类中的其它没有@Transactional注解的方法内部调用有@Transactional注解的方法,有@Transactional注解的方法的事务会失效。这是由于Spring AOP代理的原因造成的。因为只有当@Transactional注解的方法在类以外被调用的时候,Spring事务管理才生效。
本篇笔记就整理到这里,如果稍微帮到你了记得点个喜欢点个关注,也祝大家工作顺顺利利~!