RocketMQ零碎知识点

• 1.事务消息如何保证
• 2.事务消息执行流程
• 3.消息的存储
• 4.过期文件删除机制
• 5.消息存储最终一致性保证

1.事务消息如何保证

• 基于两阶段提交和定时任务回查

2.事务消息执行流程

• 1.应用程序完成本地事务后，同步调用MQ消息发送接口，发送状态为prepare的消息，发送成功后等待本地事务的执行情况。为两阶段提交的第一阶段
• 2.同时MQ会将prepare消息备份其主题和消息队列，将消息存储在RMQ_SYS_TRANS_HALF_TOPIC的消息消费队列中，然后会开启一个定时任务，消费该消息队列的消息，并向应用程序发起消息事务状态回查，根据反馈的状态之下，同时设有回查次数，超过次数未获取到状态，默认回滚。此为定时任务回查
• 3.根据本地事务的返回状态执行提交，回滚，然后结束事务。此为两阶段提交的第二阶段

3.消息的存储

• Commitlog 存储所有主题的消息，顺序写入，通过文件名表示的偏移量来定位第一条消息
• ConsumeQueue 相当于主题跟队列的索引，一个消费队列对应一个文件，异步将消息转发到该队列
• IndexFile 加速消息的检索，主要存储消息Key和Offset的对应关系

4.过期文件删除机制

• 非当前写文件在一定时间间隔内没有被再次更新，则认为是过期文件，可以直接删除。时间间隔默认72小时

5.消息存储最终一致性保证

• 当Broker由于某个原因宕机，会导致存储的三个文件不一致
• 若Broker上一次是异常退出，会在store目录下留下一个abort文件，这个abort文件是通过启动创建，正常退出时通过JVM钩子函数删除该文件，因此下一次启动时存在该文件，说明为异常退出，需要进行数据修复

标签：知识点,存储,文件,队列,事务,零碎,消息,回查,RocketMQ
来源： https://blog.csdn.net/lamperouge_conan/article/details/120159662