标题:
RocketMQ原理解析-Broker(1)
[打印本页]
作者:
look_w
时间:
2018-12-18 20:34
标题:
RocketMQ原理解析-Broker(1)
broker 1. broker的启动brker的启动
Broker向namesrv注册
1. 获取namesrv的地址列表(是乱序的)2. 遍历向每个namesrv注册topic的配置信息topicconfig
Topic在broker文件上的存储json格式
[url=]
[/url]
"
TopicTest
"
:{
"
perm
"
:6
,
"
readQueueNums
"
:8
,
"
topicFilterType
"
:
"
SINGLE_TAG
"
,
"
topicName
"
:
"
TopicTest
"
,
"
writeQueueNums
"
:8
}
Namesrv接收Broker注册的topic信息, namesrv只存内存,但是broker有任务定时推送
1. 接收数据向RouteInfoManager注册。
Broker初始化加载本地配置,配置信息是以json格式存储在本地, rocketmq强依赖fastjson作转换, RocketMq通过ConfigMananger来管理配置加载以及持久化
欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/)
Powered by Discuz! 7.0.0