1. 安裝包下載。
Apache官網(wǎng)下載 RocketMQ官網(wǎng)
下載文件解壓后,可以看到conf文件夾里有2m-noslave、2m-2s-async、2m-2s-sync文件夾:
- 2m-noslave 兩主,無從的配置
- 2m-2s-async 兩主,兩從,同步復制數(shù)據(jù)的配置
-
2m-2s-sync 兩主,兩從,異步復制數(shù)據(jù)的配置
image.png
上述配置是需要配置集群模式配置的內(nèi)容,如果配置單機模式,可以不用理會。
上述配置文件的詳細配置可參考官網(wǎng)。
環(huán)境變量配置
- linux
環(huán)境變量配置(JAVA_HOME和ROCKETMQ_HOME)
vim /etc/profile
修改如下配置
export JAVA_HOME=/usr/java/jdk1.8.0_102
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$PATH:$JAVA_HOME/bin:$ROCKETMQ_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib
- window
計算機-高級配置-環(huán)境變量

image.png
2. 修改nameServer和broker中內(nèi)存大小。(如果linux或者windows內(nèi)存不夠的話)
由于本地內(nèi)存不足4G,因此修改如下
-
runServer.cmd:
image.png -
runBroker.cmd:
image.png
linux環(huán)境對應修改上述sh文件即可
3. 管理平臺下載
請參考文章 windows下Apache.RocketMQ安裝部署 第三節(jié)插件部署模塊,這里不做詳述。
【注意要修改下console項目的applicate屬性文件中namesrvAddr,默認為空】
打包編譯命令
mvn clean package -Dmaven.test.skip=true
4. 啟動命令
-
啟動mqnamesrv
windows:
如果需要指定日志路徑,先去指定目錄創(chuàng)建logs文件夾,這樣啟動命令后面就可以指定日志路徑了。
cd F:\soft-install\rocketmq-4.4.0\bin
start mqnamesrv.cmd >F:\soft-install\rocketmq-4.4.0\logs\mqnamesrv.log
linux:
nohup sh mqnamesrv >/usr/local/rocketmq/logs/mqnamesrv.log 2>&1 &
-
啟動mqbroker
windows:
cd F:\soft-install\rocketmq-4.4.0\bin
start mqbroker.cmd -n "127.0.0.1:9876" autoCreateTopicEnable=true >F:\soft-install\rocketmq-4.4.0\logs\mqbroker.log
linux:
nohup sh mqbroker -n "127.0.0.1:9876" autoCreateTopicEnable=true> /usr/local/rocketmq/logs/mqbroker.log 2>&1 &
要設置自動創(chuàng)建Topic,需要加上
autoCreateTopicEnable=true
關閉Broker服務
sh mqshutdown broker
(還可以加上-c broker文件,指定使用哪個broker文件-c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties )
-
啟動管理平臺
windows:進入編譯好的target目錄,執(zhí)行java -jar命令(可以通過參數(shù)動態(tài)修改服務端口號,以及nameServer的地址和端口,如果編譯時沒指定的話可以在啟動的時候通過參數(shù)指定)。
java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=127.0.0.1:9876
linux 同windows。
5. 管理平臺使用
- 部署成功,打開http://服務器IP:8080

image.png
-
查看和創(chuàng)建topic
image.png
-
查看服務消費者(消費者組)
image.png -
查看指定Topic的消息
image.png
參考文章
1、 官方指南
2、 RocketMQ入門手冊
3、 RocketMQ運維指令





