资讯

精准传达 • 有效沟通

从品牌网站建设到网络营销策划,从策略到执行的一站式服务

rocketMq中分布式事务的示例分析

这篇文章主要介绍了rocketMq中分布式事务的示例分析,具有一定借鉴价值,感兴趣的朋友可以参考下,希望大家阅读完这篇文章之后大有收获,下面让小编带着大家一起了解一下。

专注于为中小企业提供成都网站设计、成都做网站服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业云州免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了数千家企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。

分布式事务

先回顾一下事务,例如银行转账,A给B转100元,这个动作包括2个步骤:

  1. A账户减100元

  2. B账户加100元

把这2个步骤放在一个事务中,来保证完全成功或者完全失败。

在单体服务中,比较好解决,一个数据库事务就完成了,但在分布式系统中,这2个步骤可能是由不同的子服务分别处理,这就涉及到了分布式事务的概念。

RocketMQ 提供了对事务的支持,可以帮助我们完成分布式事务的处理。

RocketMQ 解决思路

比如事务T,包括T1和T2两个逻辑步骤,系统 A 和 B 分别执行 T1 和 T2。

A 向 RocketMQ 发送一个待确认的消息 M(这个消息不会被发送给B,RocketMQ 先保留这个消息),然后执行T1,A 根据执行结果向 RocketMQ 提交二次确认。

如果T1执行成功了,那么消息M就标记为可投递状态,B将能够接收到,B收到M后,就知道A肯定完成了T1部分的工作,B只需要保证自己完成T2即可;如果T1执行失败了,那么消息M就会被RocketMQ删除掉,B不会收到。

这样,这个分布式事务就完成了。

这个待确认的消息叫做 “half message (半消息)”。

有一个问题,如果A由于某种原因没能向RocketMQ发送二次确认怎么办?

RocketMQ有一个回查机制,就是过一段时间后,发现待确认消息还没有被确认,就会主动向producer询问,producer根据本地事务执行结果给予反馈,是成功了还是失败了。

详细步骤说明

rocketMq中分布式事务的示例分析

  1. Producer 向 MQ 发送事务类型的 message。

  2. MQ 接收成功后,向 Producer 返回确认信息,这时,half message 就形成了。

  3. Producer 执行本地事务逻辑。

  4. Producer 根据本地执行结果向 MQ 进行二次确认(commit提交 或 rollback回滚),如果是 commit 那么 MQ 就让之前的 half message 变为可以被 Consumer 消费的消息,Consumer 接收消息;如果是 rollback,那么 MQ 就把之前的 half message 废弃掉。

  5. 当步骤4缺失时,MQ 找 Producer 进行回查。

  6. Producer 查看本地事务执行结果。

  7. Producer 根据步骤6的反馈,向 MQ 发送确认信息

感谢你能够认真阅读完这篇文章,希望小编分享的“rocketMq中分布式事务的示例分析”这篇文章对大家有帮助,同时也希望大家多多支持创新互联,关注创新互联行业资讯频道,更多相关知识等着你来学习!


分享题目:rocketMq中分布式事务的示例分析
标题链接:http://cdkjz.cn/article/ppcoji.html
多年建站经验

多一份参考,总有益处

联系快上网,免费获得专属《策划方案》及报价

咨询相关问题或预约面谈,可以通过以下方式与我们联系

大客户专线   成都:13518219792   座机:028-86922220