RocketMQ事务消息机制
2024-08-30 19:58:01
1.half消息对消费者不可见，用于确定MQ服务正常。
2.MQ响应half消息。
3.生产者执行本地事务。
4.生产者发送具体消息+本地事务状态，MQ根据本地事务状态执行Commit或者Rollback（Commit操作生成消息索引，消息对消费者可见）。
5.对没有Commit/Rollback的事务消息（Unknow），从MQ发起一次回查。
6.生产者检查本地事务状态。
7.生产者将本地事务状态给MQ。
5、6、7、为补偿流程，达到超时（检查次数默认15次），MQ认定本地事务失败（Rollback）。
最新文章
- 00Linux学习及角色定义
- 关于firewalld防火墙的使用
- 关于 ant 不同渠道自动打包的笔记
- Objective-C学习笔记－第一天(3)
- demo04calc
- Windows CPU占用率过高
- 慕课网-安卓工程师初养成-1-6 MyEclipse的使用简介
- android studio安装插件
- 轻量级的中文分词工具包 - IK Analyzer
- 终于说再见了！Google Reader
- 关于css的伪类和伪元素
- HDU1848-Fibonacci again and again
- display: run-in
- SQLSERVER 远程登录18456错误
- AndroidStudio 集成litepal 报错
- idea 模板注释设置
- SQL SERVER 打开脚本报“未能完成操作，存储空间不足”
- http中post和get方法区别
- Android深入四大组件（九）Content Provider的启动过程
- @EnableDiscoveryClient与@EnableEurekaClient 区别