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

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

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

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

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

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

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中分布式事务的示例分析

Producer 向 MQ 发送事务类型的 message。
MQ 接收成功后，向 Producer 返回确认信息，这时，half message 就形成了。
Producer 执行本地事务逻辑。
Producer 根据本地执行结果向 MQ 进行二次确认（commit提交或 rollback回滚），如果是 commit 那么 MQ 就让之前的 half message 变为可以被 Consumer 消费的消息，Consumer 接收消息；如果是 rollback，那么 MQ 就把之前的 half message 废弃掉。
当步骤4缺失时，MQ 找 Producer 进行回查。
Producer 查看本地事务执行结果。
Producer 根据步骤6的反馈，向 MQ 发送确认信息

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

分享名称：rocketMq中分布式事务的示例分析
本文网址：http://6mz.cn/article/ppcoji.html

网站建设知识