一、準備

     下載MQ所需tar包

wget https://github.com/apache/rocketmq/archive/rocketmq-all-4.2.0.tar.gz

  二、安裝MQ步驟

     ①建立目錄/usr/local/rocketmq 將下載好的tar包 解壓在該目錄中 tar –zxvf rocketmq-all-4.2.0.tar.gz

     ②在目錄/usr/loacl/rocketmq/usr/local/rocketmq-all-4.2.0 目錄中執行命令

         mvn -Prelease-all -DskipTests clean install –U   如下圖表示編譯成功

     ③配置系統環境變數 vi /etc/profile  並且執行source /etc/profile

#RocketMq
ROCKETMQ=/usr/local/rocketmq/rocketmq-rocketmq-all-4.2.0

PATH=$PATH:$ROCKETMQ/bin

export JAVA_HOME JRE_HOME CLASS_PATH PATH MAVEN_HOME

     ④建立mq日誌資料夾 /usr/local/logs/rocketmqlogs

     ⑤進入/usr/local/rocketmq/rocketmq-rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin目錄

        啟動namesrv   參考命令模組

        啟動broker   參考命令模組

      ⑥檢查是否啟動成功

        ps –ef | grep rocketmq

        檢視日誌  /usr/local/logs/rocketmqlogs/namesrv.log

        檢視日誌  /usr/local/logs/rocketmqlogs/broker.log

      ⑦訊息收發驗證

        export NAMESRV_ADDR = localhost:9876

        在/usr/local/rocketmq/rocketmq-rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin目錄中執行

        sh tools.sh org.apache.rocketmq.example.quickstart.Producer

        sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

  三、命令

#啟動namesrv
nohup sh mqnamesrv > /usr/local/logs/rocketmqlogs/namesrv.log 2>&1 &
#啟動broker
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > /usr/local/logs/rocketmqlogs/broker.log 2>&1 &
#停止 nameserver
sh bin/mqshutdown namesrv
#停止broker
sh bin/mqshutdown broker
#檢視叢集情況
./mqadmin clusterList -n 127.0.0.1:9876
#檢視 broker 狀態
./mqadmin brokerStatus -n 127.0.0.1:9876 -b 172.20.1.138:10911 (注意換成你的 broker 地址)
#檢視 topic 列表
./mqadmin topicList -n 127.0.0.1:9876
#檢視 topic 狀態
./mqadmin topicStatus -n 127.0.0.1:9876 -t MyTopic (換成你想查詢的 topic)
#檢視 topic 路由
./mqadmin topicRoute -n 127.0.0.1:9876 -t MyTopic

四、安裝MQAdmin 視覺化工具

     ①首先確定有maven和git環境 如果沒有參考其他部署文章

        mvn –version

        git –-version

     ②建立目錄/usr/local/rocketmq/rocketmq-project

     ③在rocketmq-project目錄執行

        git init

        git clone https://github.com/apache/rocketmq-externals.git 

        下載完畢目錄會有rocketmq-externals工程

     ④進入/usr/local/rocketmq/rocketmq-project/rocketmq-externals/rocketmq-console目錄執行

        mvn clean package -Dmaven.test.skip=true

        打包完成後會在target目錄生成rocketmq-console-ng-1.0.0.jar

     ⑤進入target目錄執行jar包

 nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=12581 --rocketmq.config.namesrvAddr=10.89.0.64:9876;10.89.0.65:9876  >/usr/local/logs/rocketmqlogs/rocket_console.log >&1 &

     ⑥檢視日誌 /usr/local/logs/rocketmqlogs/rocket_console.log

五、問題

    1.mq目錄中mvn編譯錯誤問題

       因第一次mvn編譯要下載好多外掛，有可能會下載超時，多試幾次就好了

     2.啟動namesrv和broker時記憶體問題

     進入資料夾/usr/local/rocketmq/rocketmq-rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin

     修改檔案runserver.sh和runbroker.sh,重新啟動

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:PermSize=128m -XX:MaxPermSize=128m"