这篇文章主要介绍了rocketMq中分布式事务的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。先回顾一下事务，例如银行转账，A给B转100元，这个动作包括2个步骤：A账户减100元B账户加100元把这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根据本地事务执行结果给予反馈，是成功了还是失败了。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中分布式事务的示例分析”这篇文章对大家有帮助，同时也希望大家多多支持开发云，关注开发云行业资讯频道，更多相关知识等着你来学习!
flink中如何使用set实时计算当天网站uv，针 香港云主机对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。背景对于web网站，我们一般会有这样的需求，实时的计算出来当天网站的uv，尽可能快的展示…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
