导航：首页 > 服务器 >

分布式消息队列RocketMQ如何部署与监控

发表于：2025-02-04 作者：千家信息网编辑

千家信息网最后更新 2025年02月04日，这篇文章主要为大家展示了"分布式消息队列RocketMQ如何部署与监控"，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下"分布式消息队列RocketMQ如何部署

千家信息网最后更新 2025年02月04日分布式消息队列RocketMQ如何部署与监控

这篇文章主要为大家展示了"分布式消息队列RocketMQ如何部署与监控"，内容简而易懂，条理清晰，希望能够帮助大家解决疑惑，下面让小编带领大家一起研究并学习一下"分布式消息队列RocketMQ如何部署与监控"这篇文章吧。

一、RocketMQ简介

RocketMQ是一款分布式、队列模型的消息中间件，具有以下特点：

1、支持严格的消息顺序；

2、支持Topic与Queue两种模式；

3、亿级消息堆积能力；

4、比较友好的分布式特性；

5、同时支持Push与Pull方式消费消息；

本文采用双Master的架构模式。

二、服务器分布

1、相关说明

2、hosts信息添加

# vim /etc/hosts10.217.121.123  mqnameserver110.217.122.31    mqnameserver210.217.121.123  rocketmq-master110.217.122.31    rocketmq-master2

3、系统环境

CentOS 6.30

4、总体架构

wKioL1PuQE3DcTjUAAE4E08WEfw644.jpg

三、RocketMQ安装与配置

1、JDK安装

http://download.oracle.com/otn-pub/java/jdk/7u65-b17/jdk-7u65-linux-x64.tar.gz# tar xvzf jdk-7u65-linux-x64.gz -C /usr/local# rm -f jdk-7u65-linux-x64.gz# cd /usr/local && ln -s jdk1.7.0_65 jdk# cd /usr/local/bin && ln -s /usr/local/jdk/bin/java

2、RocketMQ安装

https://github.com/alibaba/RocketMQ/releases# tar xvzf alibaba-rocketmq-3.1.7.tar.gz -C /usr/local# mv alibaba-rocketmq alibaba-rocketmq-3.1.7# ln -s alibaba-rocketmq-3.1.7 rocketmq# rm alibaba-rocketmq-3.1.7.tar.gz# ll /usr/local

3、环境变量设置

# vim /etc/profileexport PATH=$PATH:/usr/local/binexport JAVA_HOME=/usr/local/jdkexport CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jarexport PATH=$PATH:$JAVA_HOME/binexport ROCKETMQ_HOME=/usr/local/rocketmqexport PATH=$PATH::$ROCKETMQ_HOME/bin# source /etc/profile# cd /usr/local/rocketmq/bin && sh os.sh》

4、主机名设置

(1)、Master1服务器

# vim /etc/hosts10.217.121.123  mqnameserver110.217.122.31    mqnameserver210.217.121.123  rocketmq-master110.217.122.31    rocketmq-master2# sed -i  '/HOSTNAME/d' /etc/sysconfig/network# echo 'HOSTNAME=rocketmq-master1'  >> /etc/sysconfig/network# hostname rocketmq-master1

(2)、Master2服务器

# vim /etc/hosts10.217.121.123  mqnameserver110.217.122.31    mqnameserver210.217.121.123  rocketmq-master110.217.122.31    rocketmq-master2# sed -i  '/HOSTNAME/d' /etc/sysconfig/network# echo 'HOSTNAME=rocketmq-master2'  >> /etc/sysconfig/network# hostname rocketmq-master2

5、RocketMQ配置

(1)、Master1服务器

# vim /usr/local/rocketmq/conf/2m-noslave/broker-a.propertiesbrokerClusterName=AdpMqClusterbrokerName=broker-abrokerId=0namesrvAddr=mqnameserver1:9876;mqnameserver2:9876defaultTopicQueueNums=4autoCreateTopicEnable=trueautoCreateSubscriptionGroup=truelistenPort=10911deleteWhen=04fileReservedTime=120mapedFileSizeCommitLog=1073741824mapedFileSizeConsumeQueue=50000000destroyMapedFileIntervalForcibly=120000redeleteHangedFileInterval=120000diskMaxUsedSpaceRatio=88storePathRootDir=/data/rocketmq/storestorePathCommitLog=/data/rocketmq/store/commitlogmaxMessageSize=65536flushCommitLogLeastPages=4flushConsumeQueueLeastPages=2flushCommitLogThoroughInterval=10000flushConsumeQueueThoroughInterval=60000brokerRole=ASYNC_MASTERflushDiskType=ASYNC_FLUSHcheckTransactionMessageEnable=falsesendMessageThreadPoolNums=128pullMessageThreadPoolNums=128

(2)、Master2服务器

# vim /usr/local/rocketmq/conf/2m-noslave/broker-b.propertiesbrokerClusterName=AdpMqClusterbrokerName=broker-bbrokerId=1namesrvAddr=mqnameserver1:9876;mqnameserver2:9876defaultTopicQueueNums=4autoCreateTopicEnable=trueautoCreateSubscriptionGroup=truelistenPort=10911deleteWhen=04fileReservedTime=120mapedFileSizeCommitLog=1073741824mapedFileSizeConsumeQueue=50000000destroyMapedFileIntervalForcibly=120000redeleteHangedFileInterval=120000diskMaxUsedSpaceRatio=88storePathRootDir=/data/rocketmq/storestorePathCommitLog=/data/rocketmq/store/commitlogmaxMessageSize=65536flushCommitLogLeastPages=4flushConsumeQueueLeastPages=2flushCommitLogThoroughInterval=10000flushConsumeQueueThoroughInterval=60000brokerRole=ASYNC_MASTERflushDiskType=ASYNC_FLUSHcheckTransactionMessageEnable=falsesendMessageThreadPoolNums=128pullMessageThreadPoolNums=128

(3)、runbroker.sh参数调整

runbroker.sh需要根据内存大小进行适当地调整

JAVA_OPT_1="-server-Xms80g -Xmx80g -Xmn20g -XX:PermSize=1g -XX:MaxPermSize=1g"

6、服务启动

# mkdir -p /data/rocketmq/store/commitlog  /data/logs# cd /usr/local/rocketmq/conf && sed -i  's#${user.home}#/data#g' *.xml

(1)、启动NameServer【master1、master2】

# cd /usr/local/rocketmq/bin# nohup sh mqnamesrv &

(2)、启动BrokerServer A【master1】

# cd /usr/local/rocketmq/bin# nohup sh mqbro ker -c ../conf/2m-noslave/broker-a.properties  >/dev/null 2>&1 &

(3)、启动BrokerServer B【master2】

# cd /usr/local/rocketmq/bin# nohup sh mqbroker -c ../conf/2m-noslave/broker-b.properties  >/dev/null 2>&1 &# netstat -ntlp# jps

四、RocketMQ服务健康监控

1、依赖组件安装

# yum -y install nmap

2、nameserver监控

# vim /data/scripts/check_nameserver_health.sh

#!/bin/sh PATH=/sbin:/bin:/usr/sbin:/usr/bin:/usr/local/bin:/usr/local/sbin   SRV_PORT="9876"                    ## 端口号 SRV_PROT="tcp"                     ## 协议类型 SRV_NAME="rocketmq_nameserver"     ## 服务名    ## 是否已正确扫描 SCAN_FLAG=0    for ETH_NAME in `/sbin/ifconfig | grep eth2 | awk '{print $1}'` do       ETH1_ADDR=`/sbin/ifconfig ${ETH_NAME} | awk -F ':' '/inet addr/{print $2}' | sed 's/[a-zA-Z ]//g'`        [[ -z "${ETH1_ADDR}" ]] && continue || breakdone   TMP_SRV_PROT=`echo ${SRV_PROT} | tr '[A-Z]' '[a-z]'`    if [[ "${TMP_SRV_PROT}" == "tcp" ]]; then       PROT_OPT="S"elif [[ "${TMP_SRV_PROT}" == "udp" ]]; then       PROT_OPT="U"else       echo "未知的协议类型！" && exit1 fi   ## 最多扫描3次，成功一次即可，以避免网络抖动而导致误判 for ((i=0; i<3; i++)); do       RETVAL=`/usr/bin/nmap -n -s${PROT_OPT} -p ${SRV_PORT} ${ETH1_ADDR} | grep open`        [[ -n "${RETVAL}" ]] && SCAN_FLAG=1;break || sleep 10 done   if [[ ${SCAN_FLAG} -ne 1 ]]; then       [[ -n `ps aux | grep java | grep namesrv` ]] && kill -9 `ps aux | grep java | awk '/namesrv/{print $2}'`        cd /usr/local/rocketmq/bin && nohup sh mqnamesrv & fi

3、brokerserver监控

# vim /data/scripts/check_brokerserver_health.sh

#!/bin/sh PATH=/sbin:/bin:/usr/sbin:/usr/bin:/usr/local/bin:/usr/local/sbin   SRV_PORT="10911"                      ## 端口号 SRV_PROT="tcp"                        ## 协议类型 SRV_NAME="rocketmq_brokerserver"      ## 服务名    ## 是否已正确扫描 SCAN_FLAG=0    for ETH_NAME in `/sbin/ifconfig | grep eth2 | awk '{print $1}'` do       ETH1_ADDR=`/sbin/ifconfig ${ETH_NAME} | awk -F ':' '/inet addr/{print $2}' | sed 's/[a-zA-Z ]//g'`        [[ -z "${ETH1_ADDR}" ]] && continue || breakdone   TMP_SRV_PROT=`echo ${SRV_PROT} | tr '[A-Z]' '[a-z]'`    if [[ "${TMP_SRV_PROT}" == "tcp" ]]; then       PROT_OPT="S"elif [[ "${TMP_SRV_PROT}" == "udp" ]]; then       PROT_OPT="U"else       echo "未知的协议类型！" && exit1 fi   ## 最多扫描3次，成功一次即可，以避免网络抖动而导致误判 for ((i=0; i<3; i++)); do       RETVAL=`/usr/bin/nmap -n -s${PROT_OPT} -p ${SRV_PORT} ${ETH1_ADDR} | grep open`        [[ -n "${RETVAL}" ]] && SCAN_FLAG=1;break || sleep 10 done   if [[ ${SCAN_FLAG} -ne 1 ]]; then       [[ -n `ps aux | grep java | grep broker` ]] && kill -9 `ps aux | grep java | awk '/broker/{print $2}'`        cd /usr/local/rocketmq/bin && nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties & fi

以上红色标注部分，在master2上的名称为"broker-b.properties"

4、crontab信息添加

# touch /var/run/check_rocketmq_nameserver.lock# touch /var/run/check_rocketmq_brokerserver.lock # echo 'touch /var/run/check_rocketmq_nameserver.lock' >> /etc/rc.d/rc.local # echo 'touch /var/run/check_rocketmq_brokerserver.lock' >> /etc/rc.d/rc.local# crontab -e*/2 * * * * (flock --timeout=0 /var/run/check_rocketmq_nameserver.lock /data/scripts/check_nameserver_health.sh >/dev/null 2>&1)*/2 * * * * (flock --timeout=0 /var/run/check_rocketmq_brokerserver.lock /data/scripts/check_brokerserver_health.sh >/dev/null 2>&1)

以上是"分布式消息队列RocketMQ如何部署与监控"这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注行业资讯频道！

很赞哦！