hmily源码解读

大家好，又见面了，我是你们的朋友全栈君。

一阶段TRYING

入口点orderService.orderPay

orderService.orderPay
    -> CglibAopProxy$DynamicAdvisedInterceptor.intercept 
        -> methodProxy.invoke 
            -> OrderServiceImpl.orderPay业务方法

本地Hmily注解方法

paymentService.makePayment 
    -> CglibAopProxy$DynamicAdvisedInterceptor.intercept 
        -> (new CglibAopProxy.CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy)).proceed() 
            -> DubboHmilyTransactionAspect.interceptTccMethod 
                -> DubboHmilyTransactionInterceptor.interceptor 
                    -> hmilyTransactionAspectService.invoke
                        -> txTransactionHandler.handler
                                -> point.proceed()(PaymentServiceImpl.makePayment业务try方法)
                                    -> 更新事务状态为TRYING

上述txTransactionHandler是StarterHmilyTransactionHandler，handler方法主要逻辑，构建根事务，绑定参与者，关联当前线程放入ThreadLocal，持久化事务日志，创建事务上下文，关联当前线程放入ThreadLocal。

下面是rpc远程调用，这里分析以dubbo为例

accountService.payment -
    > proxy0.payment 
        -> InvokerInvocationHandler.invoke 
            -> dubbo filter调用链 
                -> 框架自定义调用链DubboHmilyTransactionFilter.invoke
                    -> invoker.invoke(Remote服务的AccountServiceImpl.payment) 
                        -> DubboHmilyTransactionAspect.interceptTccMethod 
                            -> DubboHmilyTransactionInterceptor.interceptor
                                 -> hmilyTransactionAspectService.invoke
                                    -> txTransactionHandler.handler() 
                                        -> point.proceed()(AccountServiceImpl.payment业务方法)
                                            -> 更新事务状态为TRYING

上述txTransactionHandler是ParticipantHmilyTransactionHandler，此时事务上下文的的action为try阶段1，role为start发起者，获取到的handler为ParticipantHmilyTransactionHandler，handler方法主要逻辑，构建分支事务，绑定参与者，缓存分支事务并持久化，改变事务上下文role为LOCAL，关联当前线程放入ThreadLocal。

InventoryService.decrease类似accountService.payment。

二阶段CONFIRMING

根事务参与者

hmilyTransactionExecutor.confirm，循环根事务参与者，分支事务的参与者的提交在根事务发起远程服务commit过程（根据阶段CONFIRMING状态）

    -> HmilyReflector.executor 
        -> MethodUtils.invokeMethod
            -> CglibAopProxy.intercept
                -> (new CglibAopProxy.CglibMethodInvocation(proxy, target, method, args, targetClass, chain, methodProxy)).proceed()
                -> PaymentServiceImpl.confirmOrderStatus业务方法

AccountService.payment参与者

MethodUtils.invokeMethod 
    -> method.invoke(proxy0.payment)
            -> InvokerInvocationHandler.invoke  // rpc开始
                -> DubboHmilyTransactionFilter.invoke
                    -> DubboHmilyTransactionAspect.interceptTccMethod(Remote)
                        -> DubboHmilyTransactionInterceptor.interceptor 
                            -> HmilyTransactionAspectServiceImpl.invoke
                                -> ParticipantHmilyTransactionHandler.handler 
                                    -> hmilyTransactionExecutor.confirm
                                        -> MethodUtils.invokeMethod(AccountServiceImpl.confirm业务方法)

InventoryService.decrease参与者类似AccountService.payment。
这一章主要讲述了try confirm执行流程，比较粗糙，嵌套事务分析见下章。