在CentOS7上安裝RocketMQ 4.7.1
前言
阿里的fastjson的低版本（<=1.2.68）被爆出有安全漏洞，而RocketMQ 4.7.0使用了fastjson 1.2.62，因此需要將RocketMQ升級到 RocketMQ 4.7.1(fastjson 1.2.69)。
本文描述了在CentOS7上安裝RocketMQ 4.7.1的過程，僅作為開發(fā)測試環(huán)境使用：
- 單機部署，Name Server和Broker都裝在一臺服務器上；
- 調低了RocketMQ默認的JVM大小；
- 沒有設置開機自啟動和守護進程。
安裝過程
服務器上已經安裝了OpenJDK 8，并設置了JAVA_HOME 。
下載和解壓RocketMQ
在RocketMQ官網上找到下載RocketMQ 4.7.1的鏈接，下載和解壓RocketMQ：
- # 下載
- wget http://ftp.cuhk.edu.hk/pub/packages/apache.org/rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip
- # 解壓
- unzip rocketmq-all-4.7.1-bin-release.zip
- # 安裝到/usr/local/rocketmq
- mv rocketmq-all-4.7.1-bin-release /usr/local
- ln -s /usr/local/rocketmq-all-4.7.1-bin-release /usr/local/rocketmq
調低RocketMQ的JVM大小
RocketMQ的默認JVM太大，不適合在開發(fā)測試環(huán)境中使用，需要調低JVM大小。
在RocketMQ的安裝目錄（本例為/usr/local/rocketmq)，查找sh腳本中的JVM參數設置：
- find . -name '*.sh' | xargs egrep 'Xms'
需要修改以下sh腳本的JVM參數：
- bin/runserver.sh
- bin/runbroker.sh
- bin/tools.sh
修改前記得先備份相應腳本，具體JVM大小根據實際情況設定。
- bin/runserver.sh
修改前：
- JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改后：
- JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
- bin/runserver.sh
修改前：
- JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改后：
- JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
- bin/tools.sh修改前：
- JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m"
修改后：
- JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=128m"
啟動Name Server
- # 后臺啟動
- nohup sh bin/mqnamesrv >/dev/null 2>&1 &
Name Server的默認端口為9876，運行sh bin/mqnamesrv -p可查看Name Server的配置項，并可通過-c namesrv.conf方式指定配置文件啟動；
RocketMQ的默認日志路徑為`~/logs/rocketmqlogs/``；
可以將啟動Name Server命令保存為腳本，以方便下次啟動。
啟動Broker
啟動Broker時需要指定要連接的Name Server：
- # 后臺啟動
- nohup sh bin/mqbroker -n localhost:9876 >/dev/null 2>&1 &
可以將啟動Broker命令保存為腳本，以方便下次啟動。
查看RocketMQ進程
- ps -ef | grep -v grep | grep rocketmq
測試RocketMQ
測試發(fā)送消息和接收消息
使用RocketMQ自帶的消息生產者和消費者示例來測試發(fā)送消息和接收消息：
- export NAMESRV_ADDR=localhost:9876
- sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
- sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
關閉RocketMQ
關閉Broker
- sh bin/mqshutdown broker
可以將關閉Broker命令保存為腳本，以方便下次關閉。
關閉Name Server
- sh bin/mqshutdown namesrv
關閉Name Server前需要先關閉Broker；
可以將關閉Name Server命令保存為腳本，以方便下次關閉。
修改Name Server的端口
RocketMQ Name Server的默認端口為9876，可以通過以下方法修改Name Server的端口：
- 新增一個Name Server配置文件namesrv.conf，保存內容為：
- listenPort=10076
2. 啟動Name Server時指定配置文件：
- nohup sh bin/mqnamesrv -c namesrv.conf >/dev/null 2>&1 &
3. 查看RocketMQ進程：
- ps -ef | grep rocketmq
4. 查看RocketMQ Name Server的端口號：
- netstat -tnlp | grep <nameserver_pid>
5. 修改后Broker需要指定新的Name Server地址（端口）。
安裝RocketMQ控制臺
克隆rocketmq-externals 項目，并編譯rocketmq-console。
命令示例：
- git clone https://github.com/apache/rocketmq-externals.git
- cd rocketmq-externals/rocketmq-console
- mvn clean package -Dmaven.test.skip=true
將target/rocketmq-console-ng*.jar放到和RocketMQ安裝目錄（本例為/usr/local/rocketmq)下。
在RocketMQ安裝目錄下新建一個啟動RocketMQ控制臺的腳本來啟動RocketMQ控制臺：
- nohup java -jar rocketmq-console-ng*.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 > /dev/null 2>&1 &
默認RocketMQ控制臺不需要密碼登錄，請參考RocketMQ使用文檔 進行配置。
參見：
- https://github.com/apache/rocketmq-externals
- https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console
Troubleshooting
問題1: 啟動Name Server和Broker，或測試時報錯Please set the JAVA_HOME variable in your environment, We need java(x64)!但是系統已經安裝了OpenJDK8，并且已經設置了JAVA_HOME。
解決方法: 運行which java來查看java的路徑，比如為/usr/bin/java。
修改bin/runserver.sh和bin/runbroker.sh和bin/tools.sh，注釋掉校驗JAVA_HOME語句，并明確指定JAVA路徑：
- #[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=$HOME/jdk/java
- #[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
- #[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your environment, We need java(x64)!"
- #export JAVA_HOME
- export JAVA="/usr/bin/java"
