RocketMQ-最终一致性
2024-05-23 19:30:39 3 举报
RockerMQ最终一致性
作者其他创作
大纲/内容
DB
6、投递消息给消费者
判断消费逻辑是否成功
4、根据本地事务结果进行Commit或Rollback
3、执行本地业务逻辑、提交事务
7、执行消费业务逻辑，提交本地事务，注意幂等操作。幂等可以通过全局分布式ID配合Redis的setnx命令
5.1、从内部队列中删除消息
定时器，补偿机制
7.1、提交本次消息的 offset，偏移量
生产者
1、发送半事务消息，half，该事务用户不可见
Rollback
2.2、弱网等原因导致生产者没有进行事务2次确认
进行消息回查，根据回查结果，进行Commit或RollBack
Broker-Master
5.2、从缓存页PageCache同步或异步写入磁盘
Commit
消费者
5、根据事务2次确认状态进行Commit或Rollback
7.2、本地事务异常，消费者服务正常后，Broker会继续投递消息进行消费
收藏
0 条评论
回复 删除
下一页
