[TOC] ## 1. 下載安裝 ### 1.1 下載 > 創建用戶 ~~~ adduser rocket ~~~ http://rocketmq.apache.org/release_notes/release-notes-4.2.0/ ~~~ unzip rocketmq-all-4.2.0-bin-release.zip ~~~ ### 1.2 修改broker啟動參數（內存） ~~~ vim runbroker.sh # 根據服務器調整，如果實際內存小于設置的內存，啟動失敗，做以下修改 JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4m" # 因為我的服務器內存才1G，所以修改小一點，否則無法啟動 JAVA_OPT="${JAVA_OPT} -server -Xms200m -Xmx200m -Xmn100m" ~~~ ### 1.3 修改環境變量 1. 修改配置文件 `vim /etc/profile` ~~~ export ROCKETMQ_HOME=/home/rocket/rocketmq export PATH=$PATH:$ROCKETMQ_HOME/bin ~~~ 2. 刷新配置文件 ~~~ source /etc/profile ~~~ ### 1.4 修改brokerIP地址 > 修改rockeMQ安裝目錄/conf/broker.conf，注意這里一定要修改！ > 如果用的是虛擬機，就要改成虛擬機的ip地址 > 同理如果是阿里云或者其他的服務器就要指明對應的外網ip地址 `vim broker.conf` > 添加IP地址綁定，在需要外網訪問的情況下，綁定外網ip ~~~ brokerIP1=192.168.56.130 # 指定nameserver，有多個用分號隔開 namesrvAddr=192.168.56.131:9876;localhost:9876 brokerName=broker-a brokerClusterName=Dev-Cluster brokerId=0 # broker名稱相同時，0表示master，大于零表示slave brokerRole=ASYNC_MASTER # master同步，slave時不用同步，及設置為SLAVE ~~~ ## 2.啟動服務 ### 2.1 Start Name Server ~~~ nohup mqnamesrv & tail -f ~/logs/rocketmqlogs/namesrv.log # 提示成功 2018-04-24 15:26:08 INFO main - The Name Server boot success. serializeType=JSON ~~~ ### 2.2 Start Broker ~~~ nohup mqbroker -c $HOME/conf/broker.conf > /dev/null 2>&1 & tail -f ~/logs/rocketmqlogs/broker.log # 提示成功 2018-04-24 15:27:16 INFO BrokerControllerScheduledThread1 - register broker to name server localhost:9876 OK ~~~ > -n localhost:9876 ： 指定nameserver > -c $HOME/conf/broker.conf ：指定broker配置文件 ## 3. 停止服務 ### 3.1 停止broker ~~~ mqshutdown broker The mqbroker(36695) is running... Send shutdown request to mqbroker(36695) OK ~~~ ### 3.1 停止server ~~~ mqshutdown namesrv The mqnamesrv(36664) is running... Send shutdown request to mqnamesrv(36664) OK ~~~ ## 4. 頁面監控安裝rocketmq-console > 頁面監控功能是GitHub上對rocketMQ使用上的擴展 ### 4.1 下載 https://github.com/apache/rocketmq-externals ### 4.2 編譯jar > 命令行進入：rocketmq-externals-master\rocketmq-console目錄下，執行打包命令 ~~~ mvn clean package -Dmaven.test.skip=true ~~~ > 此時，target目錄下生成rocketmq-console-ng-1.0.0.jar文件 ### 4.3 運行界面程序 ~~~ nohup java -jar rocketmq-console-ng-1.0.0.jar > ./rocketconsole.log 2>&1 & ~~~ ### 4.4 配置nameserver 輸入nameserver  **輸入后，按回車才能保存 ！！！！**，***關掉IsUseVIPChannel***  在按更新 ### 4.5 使用說明 #### 4.5.1 更換語言 右上角可以更換頁面顯示語言  #### 4.5.2 數據概覽（駕駛艙）  #### 4.5.3 nameserver配置 > 需要獲取整個RocketMQ的信息，就要配置信息獲取的源頭（nameservers） > 這里的UseVIPChannel要關閉  #### 4.5.4 集群管理  #### 4.5.5 主題（topic）管理 會對所有rocketmq的topic進行管理  **1. topic信息管理** 點擊某一topic的“狀態”，如下圖，可以看到topic有四個隊列，其中隊列0、2、3有數據，offset分別是75、1、86（offset可以理解為消息存儲位置的偏移量）  **2. 消費管理** 點擊某一topic的“CONSUMER管理”，如下圖所示，其中有兩個消費組對該topic進行了消費，其中order_Consumer組仍有未消費完的數據，數據偏移量差了5  此時啟動一個consumer去消費這個topic，如下圖，消費的偏移量和數據的偏移量相同，說明這個topic被這個消費組完全消費了。  ## 5. 服務腳本 沒有檢查環境變量，因為前邊配置環境變量，直接把腳本放在RocketMQ的安裝目錄的bin下即可 ~~~ #!/bin/bash set -x HOME="/home/rocket/rocketmq" start_broker(){ $(nohup mqbroker -n localhost:9876 -c $HOME/conf/broker.conf > /dev/null 2>&1 &) if [ $? -eq 0 ];then echo "broker started!" else echo "broker start faild!" fi } stop_broker(){ $(mqshutdown broker) > /dev/null 2>&1 echo "broker stopped!" } start_nameserver(){ $(nohup mqnamesrv > /dev/null 2>&1 &) if [ $? -eq 0 ];then echo "nameserver started!" else echo "nameserver start faild!" fi } stop_nameserver(){ $(mqshutdown namesrv) > /dev/null 2>&1 echo "nameserver stop!" } case $1 in broker) case $2 in start) start_broker ;; stop) stop_broker ;; restart) stop_broker start_broker ;; esac;; nameserver) case $2 in start) start_nameserver ;; stop) stop_nameserver ;; restart) stop_broker start_broker ;; esac ;; *) echo "Useage:$0 nameserver|broker start|stop|restart" ;; esac ~~~