RocketMQ实现逻辑
2024-06-28 16:20:03 0 举报
登录查看完整内容
RocketMQ实现逻辑简版,逐步会丰富此版图
作者其他创作
大纲/内容
写索引
ConsumeQueue3
4、发送确认消息，broker确认后 更新索引状态
1、Segment包含一系列的索引项2、每个索引项包括消息在CommitLog中的起始物理offset、消息的逻辑offset（即在ConsumeQueue中的索引位置）
CommitLog文件
s6
1、维护所有的broker地址和状态2、维护Topic的路由信息3、提供负载均衡的功能4、管理broker集群的元数据5、在主从模式下，如若出现故障，实现自动故障转移
写数据
s1
2、收到消息的索引
磁盘
TopicA
1、定时拉取或长轮询
定期刷盘
Broker - C
ConsumeQueue1
Server1
Broker - D
Broker - B
拉取过程中 会根据消费者订阅的Tag进行过滤
消费者
写入消息
3、根据索引读取消息内容
Broker - A（master）
NameServer集群
主从复制
ConsumeQueue2
TopicB
生产者
0 条评论
回复 删除
下一页
