什么是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会将消息推送给所有的客户端。

推荐内容