RocketMQ由四部分組成
Name Server 可集群部署，節(jié)點(diǎn)之間無任何信息同步。提供輕量級(jí)的服務(wù)發(fā)現(xiàn)和路由
Broker(消息中轉(zhuǎn)角色，負(fù)責(zé)存儲(chǔ)消息，轉(zhuǎn)發(fā)消息) 部署相對(duì)復(fù)雜，Broker 分為Master 與Slave，一個(gè)Master 可以對(duì)應(yīng)多個(gè)Slave，但是一個(gè)Slave 只能對(duì)應(yīng)一個(gè)Master，Master 與Slave 的對(duì)應(yīng)關(guān)系通過指定相同的BrokerName，不同的BrokerId來定 義，BrokerId為0 表示Master，非0 表示Slave。Master 也可以部署多個(gè)。
Producer，生產(chǎn)者，擁有相同 Producer Group 的 Producer 組成一個(gè)集群， 與Name Server 集群中的其中一個(gè)節(jié)點(diǎn)（隨機(jī)選擇）建立長(zhǎng)連接，定期從Name Server 取Topic 路由信息，并向提供Topic服務(wù)的Master 建立長(zhǎng)連接，且定時(shí)向Master 發(fā)送心跳。Producer 完全無狀態(tài)，可集群部署。
Consumer，消費(fèi)者，接收消息進(jìn)行消費(fèi)的實(shí)例，擁有相同 Consumer Group 的 Consumer 組成一個(gè)集群，與Name Server 集群中的其中一個(gè)節(jié)點(diǎn)（隨機(jī)選擇）建立長(zhǎng)連接，定期從Name Server 取Topic 路由信息，并向提供Topic 服務(wù)的Master、Slave 建立長(zhǎng)連接，且定時(shí)向Master、Slave 發(fā)送心跳。Consumer既可以從Master 訂閱消息，也可以從Slave 訂閱消息，訂閱規(guī)則由Broker 配置決定。
要使用rocketmq，至少需要啟動(dòng)兩個(gè)進(jìn)程，nameserver、broker，前者是各種topic注冊(cè)中心，后者是真正的broker。
單機(jī)環(huán)境RocketMQ的安裝（單master）
下載?rocketmq的安裝文件:?http://rocketmq.apache.org
解壓 至本地文件夾??D:\rocketmq
配置mq環(huán)境變量?
啟動(dòng) mqname? server
進(jìn)入rocketMQ解壓目錄下的bin文件夾,啟動(dòng)namesrv服務(wù)：start mqnamesrv.cmd
成功啟動(dòng)后如下圖
停止服務(wù)的時(shí)候需要注意，要先停止broker，其次停止nameserver。
默認(rèn)情況下，nameserver監(jiān)聽的是?9876?端口。
啟動(dòng)broker
啟動(dòng)之前需要先打開bin文件夾下的runbroker.cmd，配置%CLASSPATH%加上雙引號(hào)，如下圖
然后在bin目錄下輸入啟動(dòng)命令? ??
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true
成功如下圖
rocketmq插件部署
原插件路徑：https://gitee.com/mirrors/RocketMQ-Externals.git
打開Idea編輯器，打開Get From Version Control,從git上輸入以上網(wǎng)址下載rocketmq外部項(xiàng)目
下載完成之后，進(jìn)入‘rocketmq-externals\rocketmq-console\src\main\resources’文件夾，打開‘a(chǎn)pplication.properties’進(jìn)行配置。
進(jìn)入‘\rocketmq-externals\rocketmq-console’文件夾，
執(zhí)行‘mvn clean package -Dmaven.test.skip=true’，編譯生成。
（若沒有配置mvn環(huán)境，需要自行下載安裝配置maven）
編譯成功之后，Cmd進(jìn)入‘target’文件夾，
執(zhí)行‘java -jar rocketmq-console-ng-2.0.0.jar’，
啟動(dòng)‘rocketmq-console-ng-2.0.0.jar’。
瀏覽器中輸入‘127.0.0.1：配置端口’，成功后即可查看。
