RocketMq的事务消息是什么

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

事务消息概念介绍

   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的事务消息是什么”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！