hmily源码解读

hmily源码解读一阶段TRYING入口点orderService.orderPayorderService.orderPay->CglibAopProxy$DynamicAdvisedInterceptor.intercept->methodProxy.invoke->OrderServiceImpl.orderPay业务…

一阶段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执行流程,比较粗糙,嵌套事务分析见下章。

今天的文章hmily源码解读分享到此就结束了,感谢您的阅读。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/5749.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注