接第2节事务流程，这是第5点解析

回滚逻辑如下:

  1. 判断是否存在事务，只有存在事务才执行回滚
  2. 依据异样类型判断是否回滚。如果异样类型不合乎，依然会提交事务
  3. 回滚解决

具体解析

  1. 判断是否存在事务，只有存在事务才执行回滚，即是否有@Transactional事务注解或相干事务切面
  2. 依据异样类型判断是否回滚。如果异样类型不合乎，依然会提交事务

依据@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值，找到最合乎ex的异样类型，如果合乎的异样类型不是NoRollbackRuleAttribute，则能够执行回滚。
如果@Transactional没有配置，则默认应用RuntimeException和Error异样。
代码如下：

@Overridepublic boolean rollbackOn(Throwable ex) {    if (logger.isTraceEnabled()) {        logger.trace("Applying rules to determine whether transaction should rollback on " + ex);    }    RollbackRuleAttribute winner = null;    int deepest = Integer.MAX_VALUE;    //rollbackRules保留@Transactional注解中rollbackFor、rollbackForClassName、noRollbackForClassName配置的值    if (this.rollbackRules != null) {        for (RollbackRuleAttribute rule : this.rollbackRules) {            int depth = rule.getDepth(ex);            if (depth >= 0 && depth < deepest) {                deepest = depth;                winner = rule;            }        }    }    if (logger.isTraceEnabled()) {        logger.trace("Winning rollback rule is: " + winner);    }    // User superclass behavior (rollback on unchecked) if no rule matches.    //若@Transactional没有配置，默认调用父类的    if (winner == null) {        logger.trace("No relevant rollback rule found: applying default rules");        return super.rollbackOn(ex);    }    return !(winner instanceof NoRollbackRuleAttribute);}//super@Overridepublic boolean rollbackOn(Throwable ex) {    return (ex instanceof RuntimeException || ex instanceof Error);}
  1. 回滚解决
  • 如果存在平安点，则回滚事务至平安点，这个次要是解决嵌套事务，回滚平安点的操作还是交给了数据库解决.
  • 以后事务是一个新事务时，那么间接回滚，应用的是DataSourceTransactionManager事务管理器，所以调用DataSourceTransactionManager#doRollback,间接调用数据库连贯的回滚办法。
  • 以后存在事务，但又不是一个新的事务，只把事务的状态标记为read-only，等到事务链执行结束后，对立回滚,调用DataSourceTransactionManager#doSetRollbackOnly
  • 清空记录的资源并将挂起的资源复原

代码如下：

private void processRollback(DefaultTransactionStatus status) {    try {        try {            triggerBeforeCompletion(status);            //如果有平安点，回滚至平安点            if (status.hasSavepoint()) {                if (status.isDebug()) {                    logger.debug("Rolling back transaction to savepoint");                }                status.rollbackToHeldSavepoint();            }            //如果是新事务，回滚事务            else if (status.isNewTransaction()) {                if (status.isDebug()) {                    logger.debug("Initiating transaction rollback");                }                doRollback(status);            }            //如果有事务但不是新事务，则把标记事务状态，等事务链执行结束后对立回滚            else if (status.hasTransaction()) {                if (status.isLocalRollbackOnly() || isGlobalRollbackOnParticipationFailure()) {                    if (status.isDebug()) {                        logger.debug("Participating transaction failed - marking existing transaction as rollback-only");                    }                    doSetRollbackOnly(status);                }                else {                    if (status.isDebug()) {                        logger.debug("Participating transaction failed - letting transaction originator decide on rollback");                    }                }            }            else {                logger.debug("Should roll back transaction but cannot - no transaction available");            }        }        catch (RuntimeException ex) {            triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);            throw ex;        }        catch (Error err) {            triggerAfterCompletion(status, TransactionSynchronization.STATUS_UNKNOWN);            throw err;        }        triggerAfterCompletion(status, TransactionSynchronization.STATUS_ROLLED_BACK);    }    finally {        //清空记录的资源并将挂起的资源复原        cleanupAfterCompletion(status);    }}