RocketMQ 架构图
2021-07-12 10:20:51 2 举报
对RocketMQ的整体架构做了一个汇总
作者其他创作
大纲/内容
Offset
Slave Broker
近实时的将CommitLog的数据偏移写入到ConsumerQueue和IndexFile
消息
Pull消息
NameServer集群
发送失败，重试其他Broker
commited消息
地址引用
Topic
根据元数据信息均匀写入MessageQueue
异步生成
NameServer
Pull
Master Broker
生产者
每10秒检测Broker的最后一次心跳，超过120秒认为失效
uncommitted消息
发送消息
Broker集群
CommitLog
Message Queue
Pull消息可能从Master，也可能从Slave，根据节点情况选择
注册
拉取路由信息
IndexFile
一个Broker只有一个CommitLogCommitLog对应了多个ConsumerQueue
OS Page Cache
长连接30秒心跳连接
ConsumerQueue
同步刷盘/异步刷盘
消费者
ack
长连接拉取元数据信息
ReputMessageService
0 条评论
回复 删除
下一页
