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

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/143224.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • python控制mt4自动交易软件排名_股票自动交易软件排名

    python控制mt4自动交易软件排名_股票自动交易软件排名原标题:股票自动交易软件排名提起股票自动交易软件,大家都很不陌生了,很多用户也使用过很多不同品牌的产品,那么谁比较好呢?接下来我们就为大家来总体排名一下:第一名:智能A股管家股票自动交易系统把它排在第一名是因为它的性价比高,功能上虽然比不上第二名,但它的价格确实普罗大众用户可以接受的功能:可以实现多种条件任务自动执行买卖,内置9种智能交易任务策略,止盈止损,拐点交易,自动T+0,闪电交易,双向卖…

    2022年5月30日
    51
  • 软件测试用例常用七大方法

    软件测试用例常用七大方法第一:测试用例格式包括十大特点用例编号测试项测试标题用例属性重要级别:高中低预置条件测试输入操作步骤预期结果实际结果第二:等价类1,等价类定义2,等价类划分3,等价类划分规则4,进行等价类用例设计5,案例加以说明第三:边界值1,边界值的三点2,边界值应用场景3,边界值方法应用步骤第四:判定…

    2022年6月30日
    20
  • 分布式系统下的纠删码技术(一) — Erasure Code (EC)

    分布式系统下的纠删码技术(一) — Erasure Code (EC) 近几个月主要参与一个分布式存储系统的纠删码部分(用于数据容错),纠删码在学术界出现比较早,现在ceph,微软的存储系统,Hadoop3.0等都用了EC。文章会分为多篇,主要将ErasureCode,LRC, 以及相关的数学基础,作为学习总结。 一、纠删码简介      分布式系统需要在硬件失效等故障发生后仍然能继续提供服务。就数据而言,HDFS采用每份数据3副本的方式,保…

    2025年7月2日
    1
  • 磁盘管理器能看到u盘,但电脑里没有_bt3安装到u盘启动不了

    磁盘管理器能看到u盘,但电脑里没有_bt3安装到u盘启动不了最近在弄bt3U盘版的时候,依照网上的方法弄了半天都有问题,一直都进不去xwindow,由于spoonwep工具是有界面的,故只在命令行下如果没有界面的支持,是不能办事的,后来在网上看到很多兄弟们说显卡的问题,结果在无线网论坛里找到了ATI卡的驱动,具体下载的地址是:http://www.wlanbbs.com/thread-5439-1-1.html  非常感谢这位提供驱动的兄弟,ATI在哪

    2022年10月1日
    0
  • C++如何做字符串分割(5种方法)

    C++如何做字符串分割(5种方法)1、用strtok函数进行字符串分割原型:char*strtok(char*str,constchar*delim);功能:分解字符串为一组字符串。参数说明:str为要分解的字符串,delim为分隔符字符串。返回值:从str开头开始的一个个被分割的串。当没有被分割的串时则返回NULL。其它:strtok函数线程不安全,可以使用strtok_r替代。示例://借助strtok实现split#include<string.h>#include<stdio.h&

    2022年4月29日
    640
  • 程序员如何学习量化交易,一文总结

    程序员如何学习量化交易,一文总结最近有位金融行业的朋友想把一个盈利能力很强的策略做成量化程序遇到问题,问题是这样的线程A在while(true)的循环里做条件判断,循环耗时1分钟。循环结束判断条件满足的时候调用交易接口下单建仓。想实现条件成立马上建仓,而不需要等待1分钟的循环。想通过多进程或者多线程方式,但两个线程不知道如何交互。对有经验的开发来说这样的逻辑很简单,只要通过线程通信的方式就可以实现。A线程判断到满足条件就发个消息给B线程,B线程while(true)等待消息就行。技术本身不复杂,只是没接触过编程的不知道还可以这么干

    2022年6月26日
    29

发表回复

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

关注全栈程序员社区公众号