首页 | 新闻 | 新品 | 文库 | 方案 | 视频 | 下载 | 商城 | 开发板 | 数据中心 | 座谈新版 | 培训 | 工具 | 博客 | 论坛 | 百科 | GEC | 活动 | 主题月 | 电子展
返回列表 回复 发帖

RocketMQ原理解析-Broker(1)

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