认识RocketMQ
RocketMQ的底层架构
NameServer: Broker的注册与发现
Broker:
Broker与NameServer保持长链接及心跳。Broker会在启动时将自己注册至NameServer并后续每30S发送心跳,并发送其下所有的topic至NameServer。
Broker的master与slave。通过brokerName确定是否为同一个组,通过BrokerID确定那个为主,那些为从。brokerID为0,为主节点。
Producter:
Consumer:
RocketMq的存储实现
- commitLog 存放具体的消息及内容;
- ConsumerQueue 存放Queue及相关的偏移量offset,消息大小,hash值;
- indexLog 以key进行索引消息;