一.直接去官網(wǎng)下載編譯好的zip包,安裝+配置;

官網(wǎng)包地址：https://archive.apache.org/dist/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-release.zip

1.在/usr/local/創(chuàng)建rocketmq文件夾，直接下載到/home/download目錄下，

mkdir /usr/local/rocketmq &&
mkdir /home/download  &&
cd /home/download/  &&
wget https://archive.apache.org/dist/rocketmq/4.6.0/rocketmq-all-4.6.0-bin-release.zip

2.并將下載的文件復制到rocketmq文件夾,并切換到/usr/local/rocketmq目錄

cp /home/download/rocketmq-all-4.6.0-bin-release.zip /usr/local/rocketmq &&
cd /usr/local/rocketmq

3.解壓zip文件

yum install -y unzip zip &&
unzip rocketmq-all-4.6.0-bin-release.zip 

4.cd到解壓后的文件夾rocketmq-all-4.6.0-bin-release/

cd rocketmq-all-4.6.0-bin-release/bin

5.設(shè)置環(huán)境變量NAMESRV_ADDR值 127.0.0.1:9876

#編輯/etc/profile文件，在文末添加
vim /etc/profile 

#添加如下內(nèi)容：
export NAMESRV_ADDR=127.0.0.1:9876

#source刷新環(huán)境變量
source  /etc/profile

6.修改nameSrv的啟動配置，(默認配置太高)

#修改啟動腳本
vim bin/runserver.sh 

#修改下行參數(shù)
JAVA_OPT="${JAVA_OPT} -server -Xms3g -Xmx3g -Xmn2g"

7.修改brokerSrv的啟動配置，(默認配置太高)

#修改啟動腳本
vim bin/runbroker.sh

#修改下行參數(shù)
JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

8.修改conf/broker.conf，讓brocker支持sql動態(tài)過濾

vim conf/broker.conf
#末尾追加
enablePropertyFilter=true

二.啟動broker,nameSrv;

1.在bin目錄下后臺啟動nameSrv和broker

nohup sh mqnamesrv > ../nameSrv-console.log &

2.在bin目錄下后臺啟動broker

nohup sh mqbroker -n localhost:9876 > ../broker-console.log &

三.在/bin目錄下使用測試腳本測試;

1.測試生產(chǎn)者發(fā)送消息

export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Producer

2.測試消費者接收消息

export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Consumer

成功如圖所示

Producer測試發(fā)送成功

Consumer測試消費成功

四.關(guān)閉nameSrv,關(guān)閉broker服務(wù)

#關(guān)閉server
sh mqshutdown namesrv
#關(guān)閉broker
sh mqshutdown broker

五.設(shè)置rocketmq-console，web控制臺

1.從git獲取console源碼，編譯成jar包
地址：https://github.com/apache/rocketmq-dashboard （新版本的控制臺叫dashboard，原名console）
clone代碼,

2.修改springboot配置文件
修改 resources/application.properties 文件 添加

#default localhost:9876
rocketmq.config.namesrvAddr=127.0.0.1:9876
#if you use rocketmq version < 3.5.8, rocketmq.config.isVIPChannel should be false.default true
rocketmq.config.isVIPChannel=false

# 開啟登錄功能
rocketmq.config.loginRequired=true

resources/users.properties 文件添加用戶名密碼（沒有就自己添加該文件）

# 該文件支持熱修改，即添加和修改用戶時，不需要重新啟動console
# 格式， 每行定義一個用戶， username=password[,N]  #N是可選項，可以為0 (普通用戶)； 1 （管理員）  
 
#定義管理員 
admin=1234,1
root=1234,1
 
#定義普通用戶
#user1=user1
#user2=user2

guest=guest,0

3.users.properties登錄用戶配置文件，支持熱更新，默認地址
默認位置在物理機的：/tmp/rocketmq-console/data目錄，
如果沒有users.properties文件則讀取resource下的默認配置，有的話讀取外部配置

users.properties

4.重新打jar包，上傳服務(wù)器，java -jar，運行

 mvn clean package -Dmaven.test.skip=true

得到j(luò)ar包

rocketmq-dashboard-2.00.jar

5.在和RocketMQ同一臺服務(wù)器上 java -jar，運行

nohup java -jar rocketmq-dashboard-2.0.0.jar  > ../dashboard-2.0.0.log &

6.jps查看當前運行的進程信息
如圖Brocker，NameServer，dashboard.jar都在運行。

Jps查看當前進程

打開頁面如下

web控制臺