当前位置 : 首页 » 文章分类 :  开发  »  Apache-RocketMQ

Apache-RocketMQ

RocketMQ 使用笔记

https://rocketmq.apache.org/

RocketMQ 事务消息

Apache RocketMQ 4.3.0版本开始支持事务消息。

  • 事务消息:MQ 提供类似 X/Open XA 的分布事务功能,通过 MQ 事务消息能达到分布式事务的最终一致。
  • 半消息:Half(Prepare) Message,暂不能投递的消息,发送方已经将消息成功发送到了 MQ 服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半消息。
  • 消息回查:由于网络闪断、生产者应用重启等原因,导致某条事务消息的二次确认丢失,MQ 服务端通过扫描发现某条消息长期处于“半消息”时,需要主动向消息生产者询问该消息的最终状态(Commit 或是 Rollback),该过程即消息回查。

RocketMQ 事务消息原理如图:


RocketMQ事务消息原理

其中:

  1. 发送方向 MQ 服务端发送消息。
  2. MQ Server 将消息持久化成功之后,向发送方 ACK 确认消息已经发送成功,此时消息为 半消息
  3. 发送方开始执行本地事务逻辑。
  4. 发送方根据本地事务执行结果向 MQ Server 提交二次确认(Commit 或是 Rollback),MQ Server 收到 Commit 状态则将半消息标记为可投递,订阅方最终将收到该消息;MQ Server 收到 Rollback 状态则删除半消息,订阅方将不会接受该消息。
  5. 在断网或者是应用重启的特殊情况下,上述步骤 4 提交的二次确认最终未到达 MQ Server,经过固定时间后 MQ Server 将对该消息发起消息回查
  6. 发送方收到消息回查后,需要检查对应消息的本地事务执行的最终结果。
  7. 发送方根据检查得到的本地事务的最终状态再次提交二次确认,MQ Server 仍按照步骤4对半消息进行操作。

事务消息发送对应步骤1、2、3、4,事务消息回查对应步骤5、6、7。

事务消息是为了为了解决Producer端发送消息与本地事务执行的原子性问题。
与本地事务表的思路一致,都是将消息先找一个地方暂存起来,只不过暂存的地方不一样,RocketMQ将消息暂存到了内部的主题中。
为了支持事务消息,RocketMQ引入了Half Topic 以及Operation Topic 两个内部队列来存储事务消息推进状态。其中:
Half Topic对应队列中存放着prepare消息,也就是预发送的消息,消息会不直接发到目标Topic,因此消费者不可见,实现暂存
Operation Topic对应的队列则存放了prepare message对应的commit/rollback消息,消息体中则是prepare message对应的offset。

Rocket MQ 4.3.0分布式事务消息初析
https://blog.csdn.net/feeltouch/article/details/81610560

可靠消息一致性的奇淫技巧
https://mp.weixin.qq.com/s/yxYCybFPMrFp465FVg15TQ

上一篇 OAuth2

下一篇 Hexo博客(25)自建博客评论系统

阅读
评论
789
阅读预计3分钟
创建日期 2019-05-13
修改日期 2019-05-13
类别

页面信息

location:
protocol:
host:
hostname:
origin:
pathname:
href:
document:
referrer:
navigator:
platform:
userAgent:

评论