如果想搞清楚spring如何的对事务的管理,那么我们就需要先了解下它对于事务的抽象。这里可以参考它的事务管理文档中
1.2. Understanding the Spring Framework Transaction Abstraction
众所周知,事务一般有A(原子性).C(一致性).I(隔离性).D(持久性)四个特征。在sprig里对于事务定义了七个传播特性PROPAGATION和五个隔离级别。
于是spring对于事务的管理抽象(TransactionManager)就建立在事务定义抽象(TransactionDefinition )上了。它被定义在如下接口里
public interface PlatformTransactionManager extends TransactionManager {
TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;
}
从Spring Framework 5.2开始,对于反应式编程也有对应的org.springframework.transaction.ReactiveTransactionManager接口可以进行扩展。
public interface ReactiveTransactionManager extends TransactionManager {
Mono<ReactiveTransaction> getReactiveTransaction(TransactionDefinition definition) throws TransactionException;
Mono<Void> commit(ReactiveTransaction status) throws TransactionException;
Mono<Void> rollback(ReactiveTransaction status) throws TransactionException;
}
这里就体现了spring的一直以来的优势了。因为TransactionManager 是接口,所以它可以很容易的被扩展,如果你的应用有这样的需求的话。并且扩展后的类可以作为bean被spring的ioc容器进行管理。这样就很方便的进行使用或者测试了。另外为了延续spring一直以来的风格,它的异常抽象TransactionException,是非受检的异常。
@SuppressWarnings("serial")
public abstract class TransactionException extends NestedRuntimeException {
/**
* Constructor for TransactionException.
* @param msg the detail message
*/
public TransactionException(String msg) {
super(msg);
}
/**
* Constructor for TransactionException.
* @param msg the detail message
* @param cause the root cause from the transaction API in use
*/
public TransactionException(String msg, Throwable cause) {
super(msg, cause);
}
}
这里稍微提醒下,异常是可以序列化的。spring其实已经不去做受检异常了,所以它的代码里基本上用的都是非受检运行期异常。当然如果在很少出现的需要对于事务错误进行恢复处理的情况下,作为应用开发者也是可以catch并处理该TransactionException。最重要的是,开发者不被强制要求这么做。
我们继续往下看,这个getTransaction方法返回一个TransactionStatus,依赖一个TransactionDefinition的传参。这个返回的TransactionStatus也许代表一个新事务或者一个已经出现的可以在当前栈中匹配上的事务。而后一个例子往往默认如果结合Java EE的事务上下文的话,TransactionStatus是线程的执行相关联的。
事务的定义主要有下面四点。
- 传播性:通常,在一个事务域里的代码是被这个事务进行管理执行的。你也可以指定已经在上下文里存在的事务执行你这个事务性的方法。一般来说,你的代码可以继续在一个已经存在的事务下运行,或者这个事务被挂起,并创建一个新事务。
- 隔离级别:顾名思义,事务和其他事务的相互影响程度。
- 超时时间:一个事务最多执行多久,超时要自动rollback。
- 只读状态:只读不写数据。
这些配置反映了事务的基本概念。理解这些概念是很有助于你使用spring framework或者其他的事务管理解决方案。
我们再看下TransactionStatus这个接口。它提供了一个方便的方法对于你去控制事务执行或者查询事务状态。如下
public interface TransactionStatus extends TransactionExecution, SavepointManager, Flushable {
@Override
boolean isNewTransaction();
boolean hasSavepoint();
@Override
void setRollbackOnly();
@Override
boolean isRollbackOnly();
void flush();
@Override
boolean isCompleted();
}
无论你是编程式的事务管理(TransactionTemplate)还是声明式的事务管理(@Transactional),定义一个正确的TransactionManager实现都是很重要的。最好使用依赖注入的方式。而TransactionManager实现的实现往往需要知道当前数据源的创建方式,例如JDBC,JTA等。样例配置如下
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="${jdbc.driverClassName}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</bean>
<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
在你改变spring的事务设置时,应用代码是不需要改变的。这的确体现了spring的强大。