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

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

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

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 方法的参数传递

    方法的参数传递

  • jupyter notebook的安装与使用

    jupyter notebook的安装与使用最近由于项目需要,开始学习python,然后发现一个非常有用的python交互式编辑器,非常容易上手而且非常有用和实在,本博文是对学习jupyternotebook的一个汇总和记录,与大家一起分享!下面的内容是针对ubuntu系统的,当然,jupyternotebook在windows也是支持的。

  • SDRAM控制器设计(数字控制器的两种设计方法)

    FPGA之SDRAM控制器设计(二):刷新这次要来解决上次留下来的刷新问题,在100us后首先要经过两次刷新才进行模式寄存器设置。这颗SDRAM芯片需要每隔64ms对8192行(列地址10-位,行地址13位)的每一个存储电容进行一次刷新,因为不刷新电充会泄露电流导致存储信息丢失。那每一行的刷新时间为64/8192≈7810ns,注意刷新是以行为单位,器芯片内部有一个计数器,这个计数器不是时钟直接驱动的,而是AUTOPRECHARGE驱动,每发一次atuoprecharge命令这个计数器加1,我们是

  • 将menubar加入_java菜单栏工具栏

    将menubar加入_java菜单栏工具栏importjava.awt.*;importjava.awt.event.*;importjavax.swing.*;importjava.util.EventListener;publicclassTestMenuBarextendsFrame/*implementsActionListener*/{MenuBarmenubar=newMenuBar();Menufi…

    2022年10月25日
  • 04_solr7.3之solrJ7.3的使用

    04_solr7.3之solrJ7.3的使用

  • JMeter下载安装以及使用教程

    JMeter下载安装以及使用教程JMeter下载1、下载地址:https://jmeter.apache.org/download_jmeter.cgi2、下载后无需安装,解压后即可使用。解压后目录如下:3、打开JMeter中bin目录下面的jmeter.bat双击即可打开JMeter了,打开的时候会有两个窗口,Jmeter的命令窗口和Jmeter的图形操作界面,不要关闭命令窗口,打开界面如下:4、打开jmeter软件,发现显示的为英文,更改为中文步骤如下:点击菜单栏【Options】按钮然后依次单击【Cho

    2022年10月31日

发表回复

您的电子邮箱地址不会被公开。

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