前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >MQ事务方案(可靠消息事务)

MQ事务方案(可靠消息事务)

原创
作者头像
Get
发布2024-03-25 22:32:20
1130
发布2024-03-25 22:32:20
代码语言:java
复制
基于 MQ 的分布式事务方案其实是对本地消息表的封装,"将本地消息表基于 MQ 内部",其他方面的协议基本与本地消息表一致。
优点:相比本地消息表方案,MQ 事务方案优点是:
1、消息数据独立存储 ,降低业务系统与消息系统之间的耦合。
2、吞吐量大于使用本地消息表方案。
缺点
1、一次消息发送需要两次网络请求(half 消息 + commit/rollback 消息) 。
2、业务处理服务需要实现消息状态回查接口。
MQ事务方案整体流程和本地消息表的流程很相似,如下图:
可以看出和本地消息表方案唯一不同就是将本地消息表存在了MQ内部,而不是业务数据库中。

clipboard.png
clipboard.png
代码语言:java
复制
在本地消息表方案中,保证事务主动方发写业务表数据和写消息表数据的一致性是基于数据库事务
RocketMQ 的事务消息相对于普通 MQ提供了 2PC 的提交接口,方案如下:

正常情况:事务主动方发消息

clipboard.png
clipboard.png
代码语言:java
复制
这种情况下,事务主动方服务正常,没有发生故障,发消息流程如下:
步骤1:发送方向 MQ 服务端(MQ Server)发送 half 消息。
步骤2:MQ Server 将消息持久化成功之后,向发送方 ack 确认消息已经发送成功。
步骤3:发送方开始执行本地事务逻辑。
步骤4:发送方根据本地事务执行结果向 MQ Server 提交二次确认(commit 或是 rollback)。
步骤5:MQ Server 收到 commit 状态则将半消息标记为可投递,订阅方最终将收到该消息;
      MQ Server 收到 rollback 状态则删除半消息,订阅方将不会接受该消息。

异常情况:事务主动方消息恢复

clipboard.png
clipboard.png
代码语言:java
复制
在断网或者应用重启等异常情况下,图中 4 提交的二次确认超时未到达 MQ Server,此时处理逻辑如下:
步骤5:MQ Server 对该消息发起消息回查。
步骤6:发送方收到消息回查后,需要检查对应消息的本地事务执行的最终结果。
步骤7:发送方根据检查得到的本地事务的最终状态再次提交二次确认。
步骤8:MQ Server基于 commit/rollback 对消息进行投递或者删除

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
分布式事务 DTF
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档