什么是RocketMQ
一款由阿里巴巴集团开发,对付双11削峰填谷的消息中间件。
RocketMQ的构成
1.NameServer
一个注册中心,需要比Broker先启动,具有以下作用:
Broker定时向它打报告,注册自己
(资料图片)
生产者会从它这打听Broker的地址
消费者会从它这打听Broker的地址
2.Broker
负责消息的存储与转发工作
3.生产者
负责生产消息
4.消费者
负责消费消息
RocketMQ的运转流程
1.NameServer启动
2.Broker启动,并向NamerServer注册自己
3.生产者从NameServer打听Broker的地址,生产者根据地址向Broker发送某个主题(Topic)的消息
4.消费者从NameServer打听Broker的地址,找到Broker,根据自己感兴趣的主题(Topic)那里拿取到消息,进行消费
消息的发送方式
1.我只管发,你收不到关我鸟事
2.这是个傻傻等着消息发完的老实人
3.这是个一心多用的小机灵鬼
RocketMQ的消费模式
集群消费:
使用同一个Group Id的消息订阅者属于同一个集群,一条消费只会被集群中的一个消费者消费。
广播消费
RocketMQ会将消息推送给所有的客户端。