江苏龙网

  1. 首页 > 人文 > >

面试官：问你一个，Spring事务是如何传播的？( 二 )


  1. 支持当前事务（在同一个事务中）：
PROPAGATION_REQUIRED：支持当前事务 ， 如果不存在 ， 就新建一个事务 。 PROPAGATION_MANDATORY：支持当前事务 ， 如果不存在 ， 就抛出异常 。 PROPAGATION_SUPPORTS：支持当前事务 ， 如果不存在 ， 就不使用事务 。
  1. 不支持当前事务（不在同一个事务中）：
PROPAGATION_NEVER：以非事务的方式运行 ， 如果有事务 ， 则抛出异常 。 PROPAGATION_NOT_SUPPORTED：以非事务的方式运行 ， 如果有事务 ， 则挂起当前事务 。 PROPAGATION_REQUIRES_NEW：新建事务 ， 如果有事务 ， 挂起当前事务（两个事务相互独立 ， 父事务回滚不影响子事务） 。 PROPAGATION_NESTED：如果当前事务存在 ， 则嵌套事务执行（指必须依存父事务 ， 子事务不能单独提交且父事务回滚则子事务也必须回滚 ， 而子事务若回滚 ， 父事务可以回滚也可以捕获异常） 。 如果当前没有事务 ， 则进行与PROPAGATION_REQUIRED类似的操作 。
别看属性这么多 ， 实际上我们主要用的是PROPAGATION_REQUIRED默认属性 ， 一些特殊业务下可能会用到PROPAGATION_REQUIRES_NEW以及PROPAGATION_NESTED 。 下面我会假设一个场景 ， 并主要分析这三个属性 。
public class A {@Autowired private B b; @Transactional public void addA() {b.addB(); }}public class B { @Transactional public void addB() {// doSomething... }}上面我创建了A、B两个类 ， 每个类中有一个事务方法 ， 使用了声明式事务并采用的默认传播属性 ， 在A中调用了B的方法 。 当请求来了调用addA时 ， 首先调用的是代理对象的方法 ， 因此会进入createTransactionIfNecessary方法开启事务：
protected TransactionInfo createTransactionIfNecessary(@Nullable PlatformTransactionManager tm,@Nullable TransactionAttribute txAttr, final String joinpointIdentification) {// If no name specified, apply method identification as transaction name.if (txAttr != null}};}TransactionStatus status = null;if (txAttr != null) {if (tm != null) {//开启事务 ， 这里重点看status = tm.getTransaction(txAttr);}else {}}//创建事务信息对象 ， 记录新老事务信息对象return prepareTransactionInfo(tm, txAttr, joinpointIdentification, status); }实际上开启事务是通过AbstractPlatformTransactionManager做的 ， 而这个类是一个抽象类 ， 具体实例化的对象就是我们在项目里常配置的DataSourceTransactionManager对象 。
public final TransactionStatus getTransaction(@Nullable TransactionDefinition definition) throws TransactionException {//这里重点看 ， .DataSourceTransactionObject拿到对象Object transaction = doGetTransaction();// Cache debug flag to avoid repeated checks.boolean debugEnabled = logger.isDebugEnabled();if (definition == null) {// Use defaults if no transaction definition given.definition = new DefaultTransactionDefinition();}//第一次进来connectionHolder为空的 ， 所以不存在事务if (isExistingTransaction(transaction)) {// Existing transaction found -> check propagation behavior to find out how to behave.return handleExistingTransaction(definition, transaction, debugEnabled);}// Check definition settings for new transaction.if (definition.getTimeout() < TransactionDefinition.TIMEOUT_DEFAULT) {throw new InvalidTimeoutException("Invalid transaction timeout", definition.getTimeout());}// No existing transaction found -> check propagation behavior to find out how to proceed.if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_MANDATORY) {throw new IllegalTransactionStateException("No existing transaction found for transaction marked with propagation 'mandatory'");}//第一次进来大部分会走这里else if (definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRED ||definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_REQUIRES_NEW ||definition.getPropagationBehavior() == TransactionDefinition.PROPAGATION_NESTED) {//先挂起SuspendedResourcesHolder suspendedResources = suspend(null);if (debugEnabled) {logger.debug("Creating new transaction with name [" + definition.getName() + "]: " + definition);}try {boolean newSynchronization = (getTransactionSynchronization() != SYNCHRONIZATION_NEVER);//创建事务状态对象 ， 其实就是封装了事务对象的一些信息 ， 记录事务状态的DefaultTransactionStatus status = newTransactionStatus(definition, transaction, true, newSynchronization, debugEnabled, suspendedResources);//开启事务,重点看看 DataSourceTransactionObjectdoBegin(transaction, definition);//开启事务后 ， 改变事务状态prepareSynchronization(status, definition);return status;}catch (RuntimeException | Error ex) {resume(null, suspendedResources);throw ex;}}else {boolean newSynchronization = (getTransactionSynchronization() == SYNCHRONIZATION_ALWAYS);return prepareTransactionStatus(definition, null, true, newSynchronization, debugEnabled, null);} }


推荐阅读


上一篇：次世代Xbox扩展存储卡拆解：群联主控配合海力士存储芯片

下一篇：低价4G套餐集体消失，高价5G套餐你开始用了吗？