RocketMq的事务消息是什么
本篇内容介绍了“RocketMq的事务消息是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
创新互联建站专注骨干网络服务器租用10多年,服务更有保障!服务器租用,中国电信成都枢纽中心 成都服务器租用,成都服务器托管,骨干网络带宽,享受低延迟,高速访问。灵活、实现低成本的共享或公网数据中心高速带宽的专属高性能服务器。
事务消息概念介绍
Half(Prepare)Message
消息不能传递,当消息成功发送到Broker之后,Broker没有收到Producer的二次确认事件,消息被broker标记为暂时不能派发,这种状态下的消息就是Half(Prepare)Message。
消息状态校验
网络闪断和Productor应用服务重启,都会导致事务消息二次确认事件的丢失,当broker发现消息一直处于Half(Prepare)Message状态,就会向Productor应用发送请求,确认消息的最终状态(派送还是回滚)。
事务消息执行流程:
1.Producer向Broker发送Half(Prepare)Message
2.发送Half(Prepare)Message success,执行本地事务
3.根据本地事务执行结果,想Broker发送提交或者回滚消息
4.如果提交或者回滚消息丢失或者Producer执行本地事务期间挂起,Broker会给同一组类的所有producer发送check消息,确认事务最终状态
5.Producer会根据本地事务状态回复提交/回滚消息
6.已提交的消息将传递给订阅的Consumer,但Broker服务器将丢弃已回滚的消息
详细设计
Rocketmq为了抽象存储的底层实现,所有事务性消息操作都集中在事务服务接口上。 RocketMQ提供了一个带有自己的存储系统的默认实现,我们使用事务桥来实现我们的事务存储逻辑,而不是直接修改RocketMQ的存储层。
发送事务消息
发送事务消息时序图,以及事务消息是如何两阶段提交的。
事务消息校验
事务消息检验逻辑时序图,如果事务消息一直处于Half(Prepare)Message status,Broker就会向producer发送确认消息,验证事务消息的最终状态。
“RocketMq的事务消息是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!
本文标题:RocketMq的事务消息是什么
分享地址:http://ybzwz.com/article/gicsop.html