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来管理配置加载以及持久化
|