RocketMQ的基本功能是消息转发,除此之外还支持事务消息延迟消息以及分布式消息存储。任何消息在发送到Broker的master节点都要先落到commitlog中持久化事务消息、延迟消息、主从日志同步模块从commitlog中读取数据进行处理。消息流转顺序如下:
1、生产者产生消息发送到broker
2、broker先将数据持久化到commitlog日志中,如果是事务消息或延迟消息会对消息主题不显示消息和queueID做特殊处理
3、主从同步模块将commitlog日志不断同步给slave节点
4、队列分发模块获取commitlog日志内容,根据topic和queueID将消息摘要信息推送到消费队列中transaction queue和delay queue是专门存放事务消息和延迟消息摘要的队列
5、事务消息模块读取transaction queue中数据,通过事务回查机制获取判断事务是否提交如果已经提交,将原始数据信息重新写入commoitlog中步骤4会將回写的消息推送到实际queue
6、延迟消息模块会不断读取delay queue中数据,判断是否到触发时间如果到了触发时间,与事务消息处理逻辑一致将原始数据重新写入commitlog中,步骤4会将回写的消息推送到实际queue
7、消费者根据自己订阅topic根据负载均衡策略,拉去queue中数据进行消费