CentOS7中如何安裝RocketMQ 4.7.1

本篇內(nèi)容介紹了“CentOS7中如何安裝RocketMQ 4.7.1”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

安裝過(guò)程

服務(wù)器上已經(jīng)安裝了OpenJDK 8，并設(shè)置了JAVA_HOME 。

下載和解壓RocketMQ

在RocketMQ官網(wǎng)上找到下載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

調(diào)低RocketMQ的JVM大小

RocketMQ的默認(rèn)JVM太大，不適合在開發(fā)測(cè)試環(huán)境中使用，需要調(diào)低JVM大小。

在RocketMQ的安裝目錄（本例為/usr/local/rocketmq)，查找sh腳本中的JVM參數(shù)設(shè)置：

find . -name '*.sh' | xargs egrep 'Xms'

需要修改以下sh腳本的JVM參數(shù)：

bin/runserver.sh  bin/runbroker.sh  bin/tools.sh

修改前記得先備份相應(yīng)腳本，具體JVM大小根據(jù)實(shí)際情況設(shè)定。

- 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"

啟動(dòng)Name Server

# 后臺(tái)啟動(dòng)  nohup sh bin/mqnamesrv >/dev/null 2>&1 &

Name Server的默認(rèn)端口為9876，運(yùn)行sh bin/mqnamesrv -p可查看Name Server的配置項(xiàng)，并可通過(guò)-c namesrv.conf方式指定配置文件啟動(dòng)；

RocketMQ的默認(rèn)日志路徑為`~/logs/rocketmqlogs/``；

可以將啟動(dòng)Name Server命令保存為腳本，以方便下次啟動(dòng)。

啟動(dòng)Broker

啟動(dòng)Broker時(shí)需要指定要連接的Name Server：

# 后臺(tái)啟動(dòng)  nohup sh bin/mqbroker -n localhost:9876 >/dev/null 2>&1 &

可以將啟動(dòng)Broker命令保存為腳本，以方便下次啟動(dòng)。

查看RocketMQ進(jìn)程

ps -ef | grep -v grep | grep rocketmq

測(cè)試RocketMQ

測(cè)試發(fā)送消息和接收消息

使用RocketMQ自帶的消息生產(chǎn)者和消費(fèi)者示例來(lái)測(cè)試發(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

關(guān)閉RocketMQ

關(guān)閉Broker

sh bin/mqshutdown broker

可以將關(guān)閉Broker命令保存為腳本，以方便下次關(guān)閉。

關(guān)閉Name Server

sh bin/mqshutdown namesrv

關(guān)閉Name Server前需要先關(guān)閉Broker；

可以將關(guān)閉Name Server命令保存為腳本，以方便下次關(guān)閉。

修改Name Server的端口

RocketMQ Name Server的默認(rèn)端口為9876，可以通過(guò)以下方法修改Name Server的端口：

1. 鴻蒙官方戰(zhàn)略合作共建——HarmonyOS技術(shù)社區(qū)

2.  新增一個(gè)Name Server配置文件namesrv.conf，保存內(nèi)容為： 

listenPort=10076

    2.  啟動(dòng)Name Server時(shí)指定配置文件：

nohup sh bin/mqnamesrv -c namesrv.conf >/dev/null 2>&1 &

    3.  查看RocketMQ進(jìn)程：

ps -ef | grep rocketmq

    4.  查看RocketMQ Name Server的端口號(hào)：

netstat -tnlp | grep <nameserver_pid>

    5.  修改后Broker需要指定新的Name Server地址（端口）。

安裝RocketMQ控制臺(tái)

克隆rocketmq-externals 項(xiàng)目，并編譯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安裝目錄下新建一個(gè)啟動(dòng)RocketMQ控制臺(tái)的腳本來(lái)啟動(dòng)RocketMQ控制臺(tái)：

nohup java -jar rocketmq-console-ng*.jar --server.port=8080 --rocketmq.config.namesrvAddr=localhost:9876 > /dev/null 2>&1 &

默認(rèn)RocketMQ控制臺(tái)不需要密碼登錄，請(qǐng)參考RocketMQ使用文檔 進(jìn)行配置。

Troubleshooting

問(wèn)題1: 啟動(dòng)Name Server和Broker，或測(cè)試時(shí)報(bào)錯(cuò)Please set the JAVA_HOME variable in your environment, We need java(x64)!但是系統(tǒng)已經(jīng)安裝了OpenJDK8，并且已經(jīng)設(shè)置了JAVA_HOME。

解決方法: 運(yùn)行which java來(lái)查看java的路徑，比如為/usr/bin/java。

修改bin/runserver.sh和bin/runbroker.sh和bin/tools.sh，注釋掉校驗(yàn)JAVA_HOME語(yǔ)句，并明確指定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"

“CentOS7中如何安裝RocketMQ 4.7.1”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！