image.png
1 发送半消息
2 mq server 发送半消息成功给发送方
3 发送方收到后，执行本地事务
4 发送方主动提交事务状态，成功or 失败
5 如果成功，mq server 投递到下游，执行下游事务。
6 如果失败，mq server 删除消息
7 如果迟迟没有收到发送方提交事务状态，mq server 会主动去发送方查询，该逻辑需要发送方实现。
8 检查本地事务。根据成功or失败，选择走第5步还是第6步。
补充：
1 如果下游事务失败，需要重试，并有报警人工介入的机制。
2 第7步mq server 会不断的回查直到超时或者次数上限。
3 回查的时候，本地事务有3种状态，commit rollback unkown
4 回查的逻辑就是看本地事务提交的数据在不在，如果不在不能认为是失败了
要返回unkown
优点：稳定可靠，毕竟是经历过双11的
缺点：有侵入性，需要业务实现者多写一个确认事务状态的方法
1、RocketMQ事务消息概念 RocketMQ事务消息：RocketMQ 提供分布事务功能，通过 Rocket...
rocketMq: 事务消息发送步骤如下： 发送方将半事务消息发送至消息队列 RocketMQ 版服务端。 消息队...
参考：rocketmq实现事务消息
一、RocketMQ 介绍 1、消息顺序2、消息重复消费3、事务消息 二、RocketMQ 安装 Windows:...
抽空扒一下RocketMQ的事务消息，看看具体的实现，版本4.6.0。 基本原理 RocketMQ的事务消息实现是...
1：什么是分布式事务： 2：RocketMQ4.X分布式事务消息架构讲解 3：RocketMQ4.X分布式事务消息...
分布式事务 微服务倡导将复杂的系统拆分为若干个简单、职责单一、松耦合的服务，可以降低开发难度，便于敏捷开发。而对大...
系列 RocketMq 消息Tag过滤 RocketMq 广播模式 RocketMQ 同步调用的新特性 Rocke...
概述 事务消息解决的问题是：Provider本地事务 + 消息投递 一起执行。解决应用端 和 MQ端两个独立的应用...
在微服务架构中，随着服务的逐步拆分，数据库私有已经成为共识，这也导致所面临的分布式事务问题成为微服务落地过程中一个...
本文标题：rocketmq的事务消息
本文链接：https://www.haomeiwen.com/subject/wdstzctx.html
网友评论