快捷導(dǎo)航

RocketMQ單結(jié)點(diǎn)安裝/Dashboard安裝過(guò)程分享

更新時(shí)間：2024年07月22日 14:42:32 作者：景慶197

RocketMq屬于天生集群,需要同時(shí)啟動(dòng)nameServer和Broker進(jìn)行部署,在通過(guò)Dashboard進(jìn)行監(jiān)控,本文給大家介紹RocketMQ單結(jié)點(diǎn)安裝/Dashboard安裝過(guò)程,感興趣的朋友跟隨小編一起看看吧

yum -y install java-1.8.0-openjdk-devel.x86_64
sudo cat >> /etc/profile <<-'EOF'
export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk
export JRE_HOME=$JAVA_HOME/jre
export CLASSPATH=$JAVA_HOME/lib:$JRE_HOME/lib:$CLASSPATH
export PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH
EOF
source /etc/profile
echo $JAVA_HOME

1.安裝NameServer

下載壓縮包后通過(guò)

#進(jìn)行解壓
unzip rocketmq-all-5.3.0-bin-release.zip
cd 到對(duì)應(yīng)解壓壓縮包內(nèi)
#修改runserver
sed -i 's/-Xms4g -Xmx4g -XX:MetaspaceSize=128m/-Xms1g -Xmx1g -XX:MetaspaceSize=128m/g' ./bin/runserver.sh
#nameServer默認(rèn)使用9876端口，如果使用虛擬機(jī)啟動(dòng)可以忽略這行
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --reload
# 非后臺(tái)啟動(dòng)
# sh ./bin/mqnamesrv
#后臺(tái)啟動(dòng)并查看日志 
nohup sh ./bin/mqnamesrv > nqnamesrv.log &

查看啟動(dòng)日志cat nqnamesrv.log 如果輸出結(jié)果是seccess則表示啟動(dòng)成功

2.安裝Broker

在另外一臺(tái)的虛擬機(jī)上，也需要

#進(jìn)行解壓
unzip rocketmq-all-5.3.0-bin-release.zip
cd 到對(duì)應(yīng)解壓壓縮包內(nèi)
#修r(nóng)unbroker
sed -i 's/-Xms8g -Xmx8g/-Xms1g -Xmx1g/g' ./bin/runbroker.sh
#創(chuàng)建broker的的配置
cat > single-master.properties <<-'EOF'
#集群名稱，同一個(gè)集群下的broker要求統(tǒng)一
brokerClusterName=DefaultCluster
#broker名稱
brokerName=broker-a
#brokerId=0代表主節(jié)點(diǎn)，大于零代表從節(jié)點(diǎn)
brokerId=0
#刪除日志文件時(shí)間點(diǎn)，默認(rèn)凌晨 4 點(diǎn)
deleteWhen=04
#日志文件保留時(shí)間，默認(rèn) 48 小時(shí)
fileReservedTime=48
#Broker 的角色
#- ASYNC_MASTER 異步復(fù)制Master
#- SYNC_MASTER 同步雙寫Master
brokerRole=SYNC_MASTER
#刷盤方式
#- ASYNC_FLUSH 異步刷盤，性能好宕機(jī)會(huì)丟數(shù)
#- SYNC_FLUSH 同步刷盤，性能較差不會(huì)丟數(shù)
flushDiskType=SYNC_FLUSH
#末尾追加，NameServer節(jié)點(diǎn)列表，使用分號(hào)分割
namesrvAddr=192.168.10.100:9876
autoCreateTopicEnable=true
EOF
#防火墻設(shè)置
firewall-cmd --zone=public --add-port=10911/tcp --permanent
firewall-cmd --reload
#啟動(dòng)日志
#sh ./bin/mqbroker -c ./single-master.properties
nohup sh ./bin/mqbroker -c ./single-master.properties > broker.log &

查看cat broker.log ，如果為success則表示啟動(dòng)成功

3.使用自帶工具測(cè)試數(shù)據(jù)發(fā)送

在nameServer端

export NAMESRV_ADDR=192.168.10.100:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

在broker端接收消息

export NAMESRV_ADDR=192.168.10.100:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

4.使用DashBoard進(jìn)行查看

https://github.com/apache/rocketmq-dashboard

倉(cāng)庫(kù)服務(wù) (aliyun.com) rocketmq-dashboard

默認(rèn)啟動(dòng)是8080端口

nohup java -jar rocketmq-dashboard-1.0.0.jar > dashboard.log &

啟動(dòng)訪問(wèn)地址http://192.168.10.100:8080/

5.關(guān)閉相關(guān)設(shè)備

# 停止NameServer
sh bin/mqshutdown namesrv
# 停止Broker
sh bin/mqshutdown broker
#查看關(guān)閉是否成功，如果沒(méi)有返回結(jié)果則表示關(guān)閉成功
ss -anp | grep 9876
ss -anp | grep 10911

6.啟動(dòng)腳本

虛擬機(jī)安裝完之后每次啟動(dòng)都很麻煩，所以補(bǔ)充一個(gè)一件啟動(dòng)腳本

vim start_mq.sh
#!/bin/bash
nohup sh /home/nameSrv/bin/mqnamesrv > /home/nameSrv/nqnamesrv.log 2>&1 &
nohup sh /home/brokerSrv/bin/mqbroker -c /home/brokerSrv/single-master.properties > /home/brokerSrv/broker.log 2>&1 &
nohup java -jar /home/mq-dash.jar > /home/dashboard.log 2>&1 &
chmod 777 start_mq.sh
#再次重啟
sh ./路徑/start_mq.sh

到此這篇關(guān)于RocketMQ單結(jié)點(diǎn)安裝/Dashboard安裝的文章就介紹到這了,更多相關(guān)RocketMQ單結(jié)點(diǎn)安裝內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: