关于java:二Spring事务执行流程

接上节内容，Spring 事务执行原理通过创立一个 BeanFactoryTransactionAttributeSourceAdvisor，并把 TransactionInterceptor 注入进去，而 TransactionInterceptor 实现了 Advice 接口。而 Spring Aop 在 Spring 中会把 Advisor 中的 Advice 转换成拦截器链，而后调用。

执行流程

1. 获取对应事务属性，也就是获取 @Transactional 注解上的属性
2. 获取 TransactionManager，罕用的如 DataSourceTransactionManager 事务管理
3. 在指标办法执行前获取事务信息并创立事务
4. 回调执行下一个调用链
5. 一旦出现异常，尝试异样解决，回滚事务
6. 提交事务前的事务信息清理
7. 提交事务

具体分析

1. 获取对应事务属性，具体代码执行流程如下：

final TransactionAttribute txAttr = getTransactionAttributeSource().getTransactionAttribute(method, targetClass);

protected TransactionAttribute computeTransactionAttribute(Method method, Class<?> targetClass) {
    // Don't allow no-public methods as required.
    //1. allowPublicMethodsOnly() 返回 true，只能是公共办法
    if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {return null;}

    // Ignore CGLIB subclasses - introspect the actual user class.
    Class<?> userClass = ClassUtils.getUserClass(targetClass);
    // The method may be on an interface, but we need attributes from the target class.
    // If the target class is null, the method will be unchanged.
    //method 代表接口中的办法、specificMethod 代表实现类的办法
    Method specificMethod = ClassUtils.getMostSpecificMethod(method, userClass);
    // If we are dealing with method with generic parameters, find the original method.
    // 解决泛型
    specificMethod = BridgeMethodResolver.findBridgedMethod(specificMethod);

    // First try is the method in the target class.
    // 查看办法中是否存在事务
    TransactionAttribute txAttr = findTransactionAttribute(specificMethod);
    if (txAttr != null) {return txAttr;}

    // Second try is the transaction attribute on the target class.
    // 查看办法所在类是否存在事务申明
    txAttr = findTransactionAttribute(specificMethod.getDeclaringClass());
    if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {return txAttr;}

    // 如果存在接口，则在接口中查找
    if (specificMethod != method) {
        // Fallback is to look at the original method.
        // 查找接口办法
        txAttr = findTransactionAttribute(method);
        if (txAttr != null) {return txAttr;}
        // Last fallback is the class of the original method.
        // 到接口类中寻找
        txAttr = findTransactionAttribute(method.getDeclaringClass());
        if (txAttr != null && ClassUtils.isUserLevelMethod(method)) {return txAttr;}
    }

    return null;
}

getTransactionAttributeSource() 取得的对象是在 ProxyTransactionManagementConfiguration 创立 bean 时注入的 AnnotationTransactionAttributeSource 对象。AnnotationTransactionAttributeSource 中 getTransactionAttributeSource 办法次要逻辑交给了 computeTransactionAttribute 办法，所以咱们间接看 computeTransactionAttribute 代码实现。

computeTransactionAttribute 办法执行的逻辑是：

• 判断是不是只运行公共办法，在 AnnotationTransactionAttributeSource 构造方法中传入 true。若办法不是公共办法，则返回 null。
• 失去具体的办法，method 办法可能是接口办法或者泛型办法。
• 查看办法上是否存在事务
• 查看办法所在类上是否存在事务
• 查看接口的办法是否存在事务，查看接口上是否存在事务。

所以如果一个办法上用了 @Transactional，类上和接口上也用了，以办法上的为主，其次才是类，最初才到接口。

1. 获取 TransactionManager，具体代码执行流程如下：

protected PlatformTransactionManager determineTransactionManager(TransactionAttribute txAttr) {
    // Do not attempt to lookup tx manager if no tx attributes are set
    if (txAttr == null || this.beanFactory == null) {return getTransactionManager();
    }
    String qualifier = txAttr.getQualifier();
    if (StringUtils.hasText(qualifier)) {return determineQualifiedTransactionManager(qualifier);
    }
    else if (StringUtils.hasText(this.transactionManagerBeanName)) {return determineQualifiedTransactionManager(this.transactionManagerBeanName);
    }
    else {
        // 罕用的会走到这里
        PlatformTransactionManager defaultTransactionManager = getTransactionManager();
        if (defaultTransactionManager == null) {defaultTransactionManager = this.transactionManagerCache.get(DEFAULT_TRANSACTION_MANAGER_KEY);
            if (defaultTransactionManager == null) {
                // 从 beanFactory 获取 PlatformTransactionManager 类型的 bean
                defaultTransactionManager = this.beanFactory.getBean(PlatformTransactionManager.class);
                this.transactionManagerCache.putIfAbsent(DEFAULT_TRANSACTION_MANAGER_KEY, defaultTransactionManager);
            }
        }
        return defaultTransactionManager;
    }
}

@Bean
public PlatformTransactionManager txManager() {return new DataSourceTransactionManager(dataSource());
}