什么是RocketMQ

一款由阿里巴巴集團開發(fā)，對付雙11削峰填谷的消息中間件。

RocketMQ的構成

1.NameServer

一個注冊中心，需要比Broker先啟動，具有以下作用：

Broker定時向它打報告，注冊自己

生產(chǎn)者會從它這打聽Broker的地址

消費者會從它這打聽Broker的地址

2.Broker

負責消息的存儲與轉發(fā)工作

3.生產(chǎn)者

負責生產(chǎn)消息

4.消費者

負責消費消息

RocketMQ的運轉流程

1.NameServer啟動

2.Broker啟動，并向NamerServer注冊自己

3.生產(chǎn)者從NameServer打聽Broker的地址，生產(chǎn)者根據(jù)地址向Broker發(fā)送某個主題(Topic)的消息

4.消費者從NameServer打聽Broker的地址，找到Broker，根據(jù)自己感興趣的主題（Topic）那里拿取到消息，進行消費

消息的發(fā)送方式

1.我只管發(fā)，你收不到關我鳥事

2.這是個傻傻等著消息發(fā)完的老實人

3.這是個一心多用的小機靈鬼

RocketMQ的消費模式

集群消費：

使用同一個Group Id的消息訂閱者屬于同一個集群，一條消費只會被集群中的一個消費者消費。

廣播消費

RocketMQ會將消息推送給所有的客戶端。