spring5 源码深度解析----- Spring事务 是怎么通过AOP实现的？（100%理解Spring事务）

此篇文章需要有springaop基础，知道aop底层原理可以更好的理解spring的事务处理。

自定义标签

对于spring中事务功能的代码分析，我们首先从配置文件开始人手，在配置文件中有这样一个配置：<tx:annotation-driven/>。可以说此处配置是事务的开关，如果没有此处配置，那么spring中将不存在事务的功能。那么我们就从这个配置开始分析。

根据之前的分析，我们因此可以判断，在自定义标签中的解析过程中一定是做了一些辅助操作，于是我们先从自定义标签入手进行分析。使用idea搜索全局代码，关键字annotation-driven，最终锁定类txnamespacehandler，在txnamespacehandler中的 init 方法中：

@override
public void init() {
    registerbeandefinitionparser("advice", new txadvicebeandefinitionparser());
    registerbeandefinitionparser("annotation-driven", new annotationdrivenbeandefinitionparser());
    registerbeandefinitionparser("jta-transaction-manager", new jtatransactionmanagerbeandefinitionparser());
}

在遇到诸如tx:annotation-driven为开头的配置后，spring都会使用annotationdrivenbeandefinitionparser类的parse方法进行解析。

@override
@nullable
public beandefinition parse(element element, parsercontext parsercontext) {
    registertransactionaleventlistenerfactory(parsercontext);
    string mode = element.getattribute("mode");
    if ("aspectj".equals(mode)) {
        // mode="aspectj"
        registertransactionaspect(element, parsercontext);
        if (classutils.ispresent("javax.transaction.transactional", getclass().getclassloader())) {
            registerjtatransactionaspect(element, parsercontext);
        }
    }
    else {
        // mode="proxy"
        aopautoproxyconfigurer.configureautoproxycreator(element, parsercontext);
    }
    return null;
}

在解析中存在对于mode属性的判断，根据代码，如果我们需要使用aspectj的方式进行事务切入（spring中的事务是以aop为基础的），那么可以使用这样的配置：

<tx:annotation-driven transaction-manager="transactionmanager" mode="aspectj"/>

注册 infrastructureadvisorautoproxycreator

我们以默认配置为例进行分析，进人aopautoproxyconfigurer类的configureautoproxycreator：

public static void configureautoproxycreator(element element, parsercontext parsercontext) {
    //向ioc注册infrastructureadvisorautoproxycreator这个类型的bean
    aopnamespaceutils.registerautoproxycreatorifnecessary(parsercontext, element);

    string txadvisorbeanname = transactionmanagementconfigutils.transaction_advisor_bean_name;
    if (!parsercontext.getregistry().containsbeandefinition(txadvisorbeanname)) {
        object elesource = parsercontext.extractsource(element);

        // create the transactionattributesource definition.
        // 创建annotationtransactionattributesource类型的bean
        rootbeandefinition sourcedef = new rootbeandefinition("org.springframework.transaction.annotation.annotationtransactionattributesource");
        sourcedef.setsource(elesource);
        sourcedef.setrole(beandefinition.role_infrastructure);
        string sourcename = parsercontext.getreadercontext().registerwithgeneratedname(sourcedef);

        // create the transactioninterceptor definition.
        // 创建transactioninterceptor类型的bean
        rootbeandefinition interceptordef = new rootbeandefinition(transactioninterceptor.class);
        interceptordef.setsource(elesource);
        interceptordef.setrole(beandefinition.role_infrastructure);
        registertransactionmanager(element, interceptordef);
        interceptordef.getpropertyvalues().add("transactionattributesource", new runtimebeanreference(sourcename));
        string interceptorname = parsercontext.getreadercontext().registerwithgeneratedname(interceptordef);

        // create the transactionattributesourceadvisor definition.
        // 创建beanfactorytransactionattributesourceadvisor类型的bean
        rootbeandefinition advisordef = new rootbeandefinition(beanfactorytransactionattributesourceadvisor.class);
        advisordef.setsource(elesource);
        advisordef.setrole(beandefinition.role_infrastructure);
        // 将上面annotationtransactionattributesource类型bean注入进上面的advisor
        advisordef.getpropertyvalues().add("transactionattributesource", new runtimebeanreference(sourcename));
        // 将上面transactioninterceptor类型bean注入进上面的advisor
        advisordef.getpropertyvalues().add("advicebeanname", interceptorname);
        if (element.hasattribute("order")) {
            advisordef.getpropertyvalues().add("order", element.getattribute("order"));
        }
        parsercontext.getregistry().registerbeandefinition(txadvisorbeanname, advisordef);
        // 将上面三个bean注册进ioc中
        compositecomponentdefinition compositedef = new compositecomponentdefinition(element.gettagname(), elesource);
        compositedef.addnestedcomponent(new beancomponentdefinition(sourcedef, sourcename));
        compositedef.addnestedcomponent(new beancomponentdefinition(interceptordef, interceptorname));
        compositedef.addnestedcomponent(new beancomponentdefinition(advisordef, txadvisorbeanname));
        parsercontext.registercomponent(compositedef);
    }
}

这里分别是注册了三个bean，和一个infrastructureadvisorautoproxycreator，其中三个bean支撑了整个事务的功能。

我们首先需要回顾一下aop的原理，aop中有一个 advisor 存放在代理类中，而advisor中有advise与pointcut信息，每次执行被代理类的方法时都会执行代理类的invoke（如果是jdk代理）方法，而invoke方法会根据advisor中的pointcut动态匹配这个方法需要执行的advise链，遍历执行advise链，从而达到aop切面编程的目的。

• beanfactorytransactionattributesourceadvisor：首先看这个类的继承结构，可以看到这个类其实是一个advisor，其实由名字也能看出来，类中有几个关键地方注意一下，在之前的注册过程中，将两个属性注入进这个bean中：

// 将上面annotationtransactionattributesource类型bean注入进上面的advisor
advisordef.getpropertyvalues().add("transactionattributesource", new runtimebeanreference(sourcename));
// 将上面transactioninterceptor类型bean注入进上面的advisor
advisordef.getpropertyvalues().add("advicebeanname", interceptorname);

那么它们被注入成什么了呢？进入beanfactorytransactionattributesourceadvisor一看便知。

@nullable
private transactionattributesource transactionattributesource;

在其父类中有属性：

@nullable
private string advicebeanname;

也就是说，这里先将上面的transactioninterceptor的beanname传入到advisor中，然后将annotationtransactionattributesource这个bean注入到advisor中，那么这个source bean有什么用呢？可以继续看看beanfactorytransactionattributesourceadvisor的源码。

private final transactionattributesourcepointcut pointcut = new     transactionattributesourcepointcut() {
    @override
    @nullable
    protected transactionattributesource gettransactionattributesource() {
        return transactionattributesource;
    }
};

看到这里应该明白了，这里的source是提供了pointcut信息，作为存放事务属性的一个类注入进advisor中，到这里应该知道注册这三个bean的作用了吧？首先注册pointcut、advice、advisor，然后将pointcut和advice注入进advisor中，在之后动态代理的时候会使用这个advisor去寻找每个bean是否需要动态代理（取决于是否有开启事务），因为advisor有pointcut信息。

• infrastructureadvisorautoproxycreator：在方法开头，首先就调用了aopnamespeceutils去注册了这个bean，那么这个bean是干什么用的呢？还是先看看这个类的结构。这个类继承了abstractautoproxycreator，看到这个名字，熟悉aop的话应该已经知道它是怎么做的了吧？其次这个类还实现了beanpostprocessor接口，凡事实现了这个beanpost接口的类，我们首先关注的就是它的postprocessafterinitialization方法，这里在其父类也就是刚刚提到的abstractautoproxycreator这里去实现。（这里需要知道spring容器初始化bean的过程，关于beanpostprocessor的使用我会另开一篇讲解。如果不知道只需了解如果一个bean实现了beanpostprocessor接口，当所有bean实例化且依赖注入之后初始化方法之后会执行这个实现bean的postprocessafterinitialization方法）

进入这个函数：

public static void registerautoproxycreatorifnecessary(
        parsercontext parsercontext, element sourceelement) {

    beandefinition beandefinition = aopconfigutils.registerautoproxycreatorifnecessary(
            parsercontext.getregistry(), parsercontext.extractsource(sourceelement));
    useclassproxyingifnecessary(parsercontext.getregistry(), sourceelement);
    registercomponentifnecessary(beandefinition, parsercontext);
}

@nullable
public static beandefinition registerautoproxycreatorifnecessary(beandefinitionregistry registry,
        @nullable object source) {

    return registerorescalateapcasrequired(infrastructureadvisorautoproxycreator.class, registry, source);
}

对于解析来的代码流程aop中已经有所分析，上面的两个函数主要目的是注册了infrastructureadvisorautoproxycreator类型的bean，那么注册这个类的目的是什么呢？查看这个类的层次，如下图所示：

 

从上面的层次结构中可以看到，infrastructureadvisorautoproxycreator间接实现了smartinstantiationawarebeanpostprocessor，而smartinstantiationawarebeanpostprocessor又继承自instantiationawarebeanpostprocessor，也就是说在spring中，所有bean实例化时spring都会保证调用其postprocessafterinstantiation方法，其实现是在父类abstractautoproxycreator类中实现。

以之前的示例为例，当实例化accountserviceimpl的bean时便会调用此方法，方法如下：

@override
public object postprocessafterinitialization(@nullable object bean, string beanname) {
    if (bean != null) {
        // 根据给定的bean的class和name构建出key，格式：beanclassname_beanname
        object cachekey = getcachekey(bean.getclass(), beanname);
        if (!this.earlyproxyreferences.contains(cachekey)) {
            // 如果它适合被代理，则需要封装指定bean
            return wrapifnecessary(bean, beanname, cachekey);
        }
    }
    return bean;
}

 这里实现的主要目的是对指定bean进行封装，当然首先要确定是否需要封装，检测与封装的工作都委托给了wrapifnecessary函数进行。

protected object wrapifnecessary(object bean, string beanname, object cachekey) {
    // 如果处理过这个bean的话直接返回
    if (stringutils.haslength(beanname) && this.targetsourcedbeans.contains(beanname)) {
        return bean;
    }
    // 之后如果bean匹配不成功，会将bean的cachekey放入advisedbeans中
    // value为false，所以这里可以用cachekey判断此bean是否之前已经代理不成功了
    if (boolean.false.equals(this.advisedbeans.get(cachekey))) {
        return bean;
    }
    // 这里会将advise、pointcut、advisor类型的类过滤，直接不进行代理，return
    if (isinfrastructureclass(bean.getclass()) || shouldskip(bean.getclass(), beanname)) {
           // 这里即为不成功的情况，将false放入map中
        this.advisedbeans.put(cachekey, boolean.false);
        return bean;
    }

    // create proxy if we have advice.
    // 这里是主要验证的地方，传入bean的class与beanname去判断此bean有哪些advisor
    object[] specificinterceptors = getadvicesandadvisorsforbean(bean.getclass(), beanname, null);
    // 如果有相应的advisor被找到，则用advisor与此bean做一个动态代理，将这两个的信息
    // 放入代理类中进行代理
    if (specificinterceptors != do_not_proxy) {
        this.advisedbeans.put(cachekey, boolean.true);
        // 创建代理的地方
        object proxy = createproxy(
                bean.getclass(), beanname, specificinterceptors, new singletontargetsource(bean));
        this.proxytypes.put(cachekey, proxy.getclass());
        // 返回代理对象
        return proxy;
    }
    // 如果此bean没有一个advisor匹配，将返回null也就是do_not_proxy
    // 也就是会走到这一步，将其cachekey，false存入map中
    this.advisedbeans.put(cachekey, boolean.false);
    // 不代理直接返回原bean
    return bean;
}

wrapifnecessary函数功能实现起来很复杂，但是逻辑上理解起来还是相对简单的，在wrapifnecessary函数中主要的工作如下：

（1）找出指定bean对应的增强器。

（2）根据找出的增强器创建代理。

听起来似乎简单的逻辑，spring中又做了哪些复杂的工作呢？对于创建代理的部分，通过之前的分析相信大家已经很熟悉了，但是对于增强器的获取，spring又是怎么做的呢？

获取对应class/method的增强器

获取指定bean对应的增强器，其中包含两个关键字：增强器与对应。也就是说在 getadvicesandadvisorsforbean函数中，不但要找出增强器，而且还需要判断增强器是否满足要求。

@override
@nullable
protected object[] getadvicesandadvisorsforbean(
        class<?> beanclass, string beanname, @nullable targetsource targetsource) {

    list<advisor> advisors = findeligibleadvisors(beanclass, beanname);
    if (advisors.isempty()) {
        return do_not_proxy;
    }
    return advisors.toarray();
}

protected list<advisor> findeligibleadvisors(class<?> beanclass, string beanname) {
    list<advisor> candidateadvisors = findcandidateadvisors();
    list<advisor> eligibleadvisors = findadvisorsthatcanapply(candidateadvisors, beanclass, beanname);
    extendadvisors(eligibleadvisors);
    if (!eligibleadvisors.isempty()) {
        eligibleadvisors = sortadvisors(eligibleadvisors);
    }
    return eligibleadvisors;
}

寻找候选增强器

protected list<advisor> findcandidateadvisors() {
    assert.state(this.advisorretrievalhelper != null, "no beanfactoryadvisorretrievalhelper available");
    return this.advisorretrievalhelper.findadvisorbeans();
}

public list<advisor> findadvisorbeans() {
    // determine list of advisor bean names, if not cached already.
    string[] advisornames = this.cachedadvisorbeannames;
    if (advisornames == null) {
        // 获取beanfactory中所有对应advisor.class的类名
        // 这里和aspectj的方式有点不同，aspectj是获取所有的object.class，然后通过反射过滤有注解aspectj的类
        advisornames = beanfactoryutils.beannamesfortypeincludingancestors(
                this.beanfactory, advisor.class, true, false);
        this.cachedadvisorbeannames = advisornames;
    }
    if (advisornames.length == 0) {
        return new arraylist<>();
    }

    list<advisor> advisors = new arraylist<>();
    for (string name : advisornames) {
        if (iseligiblebean(name)) {
            if (this.beanfactory.iscurrentlyincreation(name)) {
                if (logger.isdebugenabled()) {
                    logger.debug("skipping currently created advisor '" + name + "'");
                }
            }
            else {
                try {
                    //直接获取advisornames的实例，封装进advisors数组
                    advisors.add(this.beanfactory.getbean(name, advisor.class));
                }
                catch (beancreationexception ex) {
                    throwable rootcause = ex.getmostspecificcause();
                    if (rootcause instanceof beancurrentlyincreationexception) {
                        beancreationexception bce = (beancreationexception) rootcause;
                        string bcebeanname = bce.getbeanname();
                        if (bcebeanname != null && this.beanfactory.iscurrentlyincreation(bcebeanname)) {
                            if (logger.isdebugenabled()) {
                                logger.debug("skipping advisor '" + name +
                                        "' with dependency on currently created bean: " + ex.getmessage());
                            }
                            continue;
                        }
                    }
                    throw ex;
                }
            }
        }
    }
    return advisors;
}

首先是通过beanfactoryutils类提供的工具方法获取所有对应advisor.class的类，获取办法无非是使用listablebeanfactory中提供的方法：

string[] getbeannamesfortype(@nullable class<?> type, boolean includenonsingletons, boolean alloweagerinit);

在我们讲解自定义标签时曾经注册了一个类型为 beanfactorytransactionattributesourceadvisor 的 bean，而在此 bean 中我们又注入了另外两个bean，那么此时这个 bean 就会被开始使用了。因为 beanfactorytransactionattributesourceadvisor同样也实现了 advisor接口，那么在获取所有增强器时自然也会将此bean提取出来， 并随着其他增强器一起在后续的步骤中被织入代理。

候选增强器中寻找到匹配项

当找出对应的增强器后，接下来的任务就是看这些增强器是否与对应的class匹配了，当然不只是class，class内部的方法如果匹配也可以通过验证。

public static list<advisor> findadvisorsthatcanapply(list<advisor> candidateadvisors, class<?> clazz) {
    if (candidateadvisors.isempty()) {
        return candidateadvisors;
    }
    list<advisor> eligibleadvisors = new arraylist<>();
    // 首先处理引介增强
    for (advisor candidate : candidateadvisors) {
        if (candidate instanceof introductionadvisor && canapply(candidate, clazz)) {
            eligibleadvisors.add(candidate);
        }
    }
    boolean hasintroductions = !eligibleadvisors.isempty();
    for (advisor candidate : candidateadvisors) {
        // 引介增强已经处理
        if (candidate instanceof introductionadvisor) {
            // already processed
            continue;
        }
        // 对于普通bean的处理
        if (canapply(candidate, clazz, hasintroductions)) {
            eligibleadvisors.add(candidate);
        }
    }
    return eligibleadvisors;
}

public static boolean canapply(advisor advisor, class<?> targetclass, boolean hasintroductions) {
    if (advisor instanceof introductionadvisor) {
        return ((introductionadvisor) advisor).getclassfilter().matches(targetclass);
    }
    else if (advisor instanceof pointcutadvisor) {
        pointcutadvisor pca = (pointcutadvisor) advisor;
        return canapply(pca.getpointcut(), targetclass, hasintroductions);
    }
    else {
        // it doesn't have a pointcut so we assume it applies.
        return true;
    }
}

beanfactorytransactionattributesourceadvisor 间接实现了pointcutadvisor。 因此，在canapply函数中的第二个if判断时就会通过判断，会将beanfactorytransactionattributesourceadvisor中的getpointcut()方法返回值作为参数继续调用canapply方法，而 getpoint()方法返回的是transactionattributesourcepointcut类型的实例。对于 transactionattributesource这个属性大家还有印象吗？这是在解析自定义标签时注入进去的。

private final transactionattributesourcepointcut pointcut = new transactionattributesourcepointcut() {
    @override
    @nullable
    protected transactionattributesource gettransactionattributesource() {
        return transactionattributesource;
    }
};

那么，使用transactionattributesourcepointcut类型的实例作为函数参数继续跟踪canapply。

public static boolean canapply(pointcut pc, class<?> targetclass, boolean hasintroductions) {
    assert.notnull(pc, "pointcut must not be null");
    if (!pc.getclassfilter().matches(targetclass)) {
        return false;
    }

    // 此时的pc表示transactionattributesourcepointcut
    // pc.getmethodmatcher()返回的正是自身(this)
    methodmatcher methodmatcher = pc.getmethodmatcher();
    if (methodmatcher == methodmatcher.true) {
        // no need to iterate the methods if we're matching any method anyway...
        return true;
    }

    introductionawaremethodmatcher introductionawaremethodmatcher = null;
    if (methodmatcher instanceof introductionawaremethodmatcher) {
        introductionawaremethodmatcher = (introductionawaremethodmatcher) methodmatcher;
    }

    set<class<?>> classes = new linkedhashset<>();
    if (!proxy.isproxyclass(targetclass)) {
        classes.add(classutils.getuserclass(targetclass));
    }
    //获取对应类的所有接口
    classes.addall(classutils.getallinterfacesforclassasset(targetclass));
    //对类进行遍历
    for (class<?> clazz : classes) {
        //反射获取类中所有的方法
        method[] methods = reflectionutils.getalldeclaredmethods(clazz);
        for (method method : methods) {
            //对类和方法进行增强器匹配
            if (introductionawaremethodmatcher != null ?
                    introductionawaremethodmatcher.matches(method, targetclass, hasintroductions) :
                    methodmatcher.matches(method, targetclass)) {
                return true;
            }
        }
    }

    return false;
}

通过上面函数大致可以理清大体脉络，首先获取对应类的所有接口并连同类本身一起遍历，遍历过程中又对类中的方法再次遍历，一旦匹配成功便认为这个类适用于当前增强器。

到这里我们不禁会有疑问，对于事物的配置不仅仅局限于在函数上配置，我们都知道，在类或接口上的配置可以延续到类中的每个函数，那么，如果针对每个函数迸行检测，在类本身上配罝的事务属性岂不是检测不到了吗？带着这个疑问，我们继续探求matcher方法。

做匹配的时候 methodmatcher.matches(method, targetclass)会使用 transactionattributesourcepointcut 类的 matches 方法。

@override
public boolean matches(method method, class<?> targetclass) {
    if (transactionalproxy.class.isassignablefrom(targetclass)) {
        return false;
    }
    // 自定义标签解析时注入
    transactionattributesource tas = gettransactionattributesource();
    return (tas == null || tas.gettransactionattribute(method, targetclass) != null);
}

此时的 tas 表示 annotationtransactionattributesource 类型，这里会判断tas.gettransactionattribute(method, targetclass) != null，而 annotationtransactionattributesource 类型的 gettransactionattribute 方法如下：

@override
@nullable
public transactionattribute gettransactionattribute(method method, @nullable class<?> targetclass) {
    if (method.getdeclaringclass() == object.class) {
        return null;
    }

    object cachekey = getcachekey(method, targetclass);
    object cached = this.attributecache.get(cachekey);
    //先从缓存中获取transactionattribute
    if (cached != null) {
        if (cached == null_transaction_attribute) {
            return null;
        }
        else {
            return (transactionattribute) cached;
        }
    }
    else {
        // 如果缓存中没有，工作又委托给了computetransactionattribute函数
        transactionattribute txattr = computetransactionattribute(method, targetclass);
        // put it in the cache.
        if (txattr == null) {
            // 设置为空
            this.attributecache.put(cachekey, null_transaction_attribute);
        }
        else {
            string methodidentification = classutils.getqualifiedmethodname(method, targetclass);
            if (txattr instanceof defaulttransactionattribute) {
                ((defaulttransactionattribute) txattr).setdescriptor(methodidentification);
            }
            if (logger.isdebugenabled()) {
                logger.debug("adding transactional method '" + methodidentification + "' with attribute: " + txattr);
            }
            //加入缓存中
            this.attributecache.put(cachekey, txattr);
        }
        return txattr;
    }
}

尝试从缓存加载，如果对应信息没有被缓存的话，工作又委托给了computetransactionattribute函数，在computetransactionattribute函数中我们终于看到了事务标签的提取过程。

提取事务标签

@nullable
protected transactionattribute computetransactionattribute(method method, @nullable class<?> targetclass) {
    // don't allow no-public methods as required.
    if (allowpublicmethodsonly() && !modifier.ispublic(method.getmodifiers())) {
        return null;
    }

    // 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 = aoputils.getmostspecificmethod(method, targetclass);

    // 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;
}

对于事务属性的获取规则相信大家都已经很清楚，如果方法中存在事务属性，则使用方法上的属性，否则使用方法所在的类上的属性，如果方法所在类的属性上还是没有搜寻到对应的事务属性，那么在搜寻接口中的方法，再没有的话，最后尝试搜寻接口的类上面的声明。对于函数computetransactionattribute中的逻辑与我们所认识的规则并无差別，但是上面函数中并没有真正的去做搜寻事务属性的逻辑，而是搭建了个执行框架，将搜寻事务属性的任务委托给了 findtransactionattribute 方法去执行。

@override
@nullable
protected transactionattribute findtransactionattribute(class<?> clazz) {
    return determinetransactionattribute(clazz);
}

@nullable
protected transactionattribute determinetransactionattribute(annotatedelement ae) {
    for (transactionannotationparser annotationparser : this.annotationparsers) {
        transactionattribute attr = annotationparser.parsetransactionannotation(ae);
        if (attr != null) {
            return attr;
        }
    }
    return null;
}

this.annotationparsers 是在当前类 annotationtransactionattributesource 初始化的时候初始化的，其中的值被加入了 springtransactionannotationparser，也就是当进行属性获取的时候其实是使用 springtransactionannotationparser 类的 parsetransactionannotation 方法进行解析的。

@override
@nullable
public transactionattribute parsetransactionannotation(annotatedelement ae) {
    annotationattributes attributes = annotatedelementutils.findmergedannotationattributes(
            ae, transactional.class, false, false);
    if (attributes != null) {
        return parsetransactionannotation(attributes);
    }
    else {
        return null;
    }
}

至此，我们终于看到了想看到的获取注解标记的代码。首先会判断当前的类是否含有 transactional注解，这是事务属性的基础，当然如果有的话会继续调用parsetransactionannotation 方法解析详细的属性。

protected transactionattribute parsetransactionannotation(annotationattributes attributes) {
    rulebasedtransactionattribute rbta = new rulebasedtransactionattribute();
    propagation propagation = attributes.getenum("propagation");
    // 解析propagation
    rbta.setpropagationbehavior(propagation.value());
    isolation isolation = attributes.getenum("isolation");
    // 解析isolation
    rbta.setisolationlevel(isolation.value());
    // 解析timeout
    rbta.settimeout(attributes.getnumber("timeout").intvalue());
    // 解析readonly
    rbta.setreadonly(attributes.getboolean("readonly"));
    // 解析value
    rbta.setqualifier(attributes.getstring("value"));
    arraylist<rollbackruleattribute> rollbackrules = new arraylist<>();
    // 解析rollbackfor
    class<?>[] rbf = attributes.getclassarray("rollbackfor");
    for (class<?> rbrule : rbf) {
        rollbackruleattribute rule = new rollbackruleattribute(rbrule);
        rollbackrules.add(rule);
    }
    // 解析rollbackforclassname
    string[] rbfc = attributes.getstringarray("rollbackforclassname");
    for (string rbrule : rbfc) {
        rollbackruleattribute rule = new rollbackruleattribute(rbrule);
        rollbackrules.add(rule);
    }
    // 解析norollbackfor
    class<?>[] nrbf = attributes.getclassarray("norollbackfor");
    for (class<?> rbrule : nrbf) {
        norollbackruleattribute rule = new norollbackruleattribute(rbrule);
        rollbackrules.add(rule);
    }
    // 解析norollbackforclassname
    string[] nrbfc = attributes.getstringarray("norollbackforclassname");
    for (string rbrule : nrbfc) {
        norollbackruleattribute rule = new norollbackruleattribute(rbrule);
        rollbackrules.add(rule);
    }
    rbta.getrollbackrules().addall(rollbackrules);
    return rbta;
}

至此，我们终于完成了事务标签的解析。回顾一下，我们现在的任务是找出某个增强器是否适合于对应的类，而是否匹配的关键则在于是否从指定的类或类中的方法中找到对应的事务属性，现在，我们以accountserviceimpl为例，已经在它的接口accountserviceimp中找到了事务属性，所以，它是与事务增强器匹配的，也就是它会被事务功能修饰。

至此，事务功能的初始化工作便结束了，当判断某个bean适用于事务增强时，也就是适用于增强器beanfactorytransactionattributesourceadvisor

beanfactorytransactionattributesourceadvisor 作为 advisor 的实现类，自然要遵从 advisor 的处理方式，当代理被调用时会调用这个类的增强方法，也就是此bean的advice，又因为在解析事务定义标签时我们把transactionlnterceptor类的bean注人到了 beanfactorytransactionattributesourceadvisor中，所以，在调用事务增强器增强的代理类时会首先执行transactionlnterceptor进行增强，同时，也就是在transactionlnterceptor类中的invoke方法中完成了整个事务的逻辑。