RocketMQ的事务投递
2019-07-20 21:38
1111 查看
RocketMQ的事务投递
这是阿里的分布式事务图:
- 1、A服务先发送个Half Message给Brock端,消息中携带 B服务 即将要+100元的信息。
- 2、当A服务知道Half Message发送成功后,那么开始第3步执行本地事务。
- 3、执行本地事务(会有三种情况1、执行成功。2、执行失败。3、网络等原因导致没有响应)
- 4.1)、如果本地事务成功,那么Product像Brock服务器发送Commit,这样B服务就可以消费该message。
- 4.2)、如果本地事务失败,那么Product像Brock服务器发送Rollback,那么就会直接删除上面这条半消息。
- 4.3)、如果因为网络等原因迟迟没有返回失败还是成功,那么会执行RocketMQ的回调接口,来进行事务的回查。
如果回查,那么一定要先查看当前事务的执行情况,再看是否需要重新执行本地事务。 本地事务执行成功后,返回Commit进行消息二次确认的时候的服务挂了,在重启服务那么这个时候在brock端,它还是个Half Message(半消息),这也会回查。如果不先查看当前事务的执行情况,而是直接执行事务,那么就相当于成功执行了两个本地事务。
基于MQ的事务处理特点
最终一致性
RocketMQ是一种最终一致性的分布式事务,就是说它保证的是消息最终一致性,而不是像2PC、3PC、TCC那样强一致分布式事务,至于为什么说它是最终一致性事务下面会详细说明。
Half Message(半消息)
是指暂不能被Consumer消费的消息。Producer 已经把消息成功发送到了 Broker 端,但此消息被标记为暂不能投递状态,处于该种状态下的消息称为半消息。需要 Producer
对消息的二次确认后,Consumer才能去消费它。
消息回查
由于网络闪段,生产者应用重启等原因。导致 Producer 端一直没有对 Half Message(半消息) 进行 二次确认。这是Brock服务器会定时扫描长期处于半消息的消息,会
主动询问 Producer端 该消息的最终状态(Commit或者Rollback),该消息即为 消息回查。
一个例子
以下单流程为例:
相关文章推荐
- 消息顺序和消息事务 - RocketMQ及分布式消息系统的原理以及重要问题解读
- Rocketmq事务消息
- 消息中间件 RocketMQ源码解析:事务消息
- rocketmq事务消息的理解
- RocketMQ实战(三):分布式事务
- RocketMQ事务消费和顺序消费详解
- 消息中间件 RocketMQ源码解析:事务消息
- RocketMQ实战(三):分布式事务 - 简书RocketMQ实战(三):分布式事务 - 简书
- rocketmq事务消息入门介绍
- rocketmq事务消息入门介绍
- 分布式开放消息系统RocketMQ的原理与实践(消息的顺序问题、重复问题、可靠消息/事务消息)
- RocketMQ事务消息实现分析
- RocketMq学习一:RocketMq的安装
- 消息队列选型[首选Kafka](备选:RabbitMQ/NSQ/RocketMQ/disque/Kafka)
- SpringBoot与RocketMQ客户端集成原理解读与示例
- 阿里云搭建rocketmq踩坑
- RocketMQ Golang /Node.js Client发布预告
- RocketMQ源码分析----Broker处理发送请求
- rocketmq broker 第三章注册过程2
- RocketMQ broker jvm 监控