RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
RocketMq的事务消息是什么

本篇内容介绍了“RocketMq的事务消息是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

创新互联建站专注骨干网络服务器租用10多年,服务更有保障!服务器租用,中国电信成都枢纽中心 成都服务器租用,成都服务器托管,骨干网络带宽,享受低延迟,高速访问。灵活、实现低成本的共享或公网数据中心高速带宽的专属高性能服务器。

事务消息概念介绍

   Half(Prepare)Message

消息不能传递,当消息成功发送到Broker之后,Broker没有收到Producer的二次确认事件,消息被broker标记为暂时不能派发,这种状态下的消息就是Half(Prepare)Message。

   消息状态校验

网络闪断和Productor应用服务重启,都会导致事务消息二次确认事件的丢失,当broker发现消息一直处于Half(Prepare)Message状态,就会向Productor应用发送请求,确认消息的最终状态(派送还是回滚)。

   事务消息执行流程:

RocketMq的事务消息是什么

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提供了一个带有自己的存储系统的默认实现,我们使用事务桥来实现我们的事务存储逻辑,而不是直接修改RocketMQ的存储层。

      发送事务消息

RocketMq的事务消息是什么

     发送事务消息时序图,以及事务消息是如何两阶段提交的。

     事务消息校验

RocketMq的事务消息是什么

    事务消息检验逻辑时序图,如果事务消息一直处于Half(Prepare)Message status,Broker就会向producer发送确认消息,验证事务消息的最终状态。

“RocketMq的事务消息是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!


当前名称:RocketMq的事务消息是什么
当前地址:http://scyingshan.cn/article/gicsop.html