broker在整个rocketMq系统中是一个很重要的消息存储模块,保存了以下所有信息。
1、所有的消息都保存在broker当中
2、所有consumer的消费偏移量保存在broker当中
3、所有consumer的订阅关系保存在broker当中
4、所有的Topic信息保存在broker当中
5、延迟队列的消费进度保存在broker当中
broker在整个rocketMq中又担当着消息中枢的功能,转发以下消息
1、Topic的创建和更新消息通过broker转发到namesrv
broker核心需要理解清楚的是消息存储格式,这个会单独的一篇文章来分析consumer的消息存储格式
消息存储是broker的核心,消息存储是broker的核心,消息存储是broker的核心!
broker需要牢记依稀这个图