鏡像下載、域名決議、時間同步請點擊 阿里云開源鏡像站

部署rocketmq和可視化客戶端

一、 服務器資源

服務名稱：Linux服務器

IP：[請查看資源分配檔案]

作業系統：CentOS 7.8 x64

二、rocketmq安裝

2.1下載

下載地址：rocketmq.apache.org/dowloading/…

這里，咋們下載4.8.0版本

2.2、將壓縮包放到 tools目錄下并解壓

把rocketmq-all-4.8.0-bin-release.zip上傳到/opt/tools目錄下并解壓并重命名

# cd /opt/tools

# unzip -d /opt/apps/ rocketmq-all-4.8.0-bin-release.zip

# cd /opt/apps/

# mv rocketmq-all-4.8.0-bin-release rocketmq-4.8.0

2.3、配置環境變數

# vi /etc/profile

在檔案末尾添加以下內容：

#rocketmq env

export ROCKETMQ_HOME=/opt/apps/rocketmq-4.8.0

export PATH=$PATH:$ROCKETMQ_HOME/bin

使修改生效：

# source /etc/profile

2.4、創建存盤路徑和日志目錄

# mkdir -p /opt/apps/rocketmq-4.8.0/store/{store,commitlog,consumequeue,index}

# mkdir /opt/apps/rocketmq-4.8.0/logs

2.5、broker配置

備份原組態檔

# cd /opt/apps/rocketmq-4.8.0/conf

# mv broker.conf broker.conf.bak

# vi broker.conf

添加以下內容：

#ip為服務器內網地址，port可自由設定一般為9876

namesrvAddr=xxx.xxx.x.xx:9876

messageIndexSafe=true

#是否允許Broker 自動創建，Topic，建議線下開啟，線上關閉

autoCreateTopicEnable=true

waitTimeMillsInSendQueue=5000

#發送訊息執行緒池數量

sendMessageThreadPoolNums=64

useReentrantLockWhenPutMessage=true

defaultReadQueueNums = 16

defaultWriteQueueNums = 16

#ip設定外網ip，不需要連接外網的話，可以在引數前面加#注釋掉

#brokerIP1=ip（外網ip）

#默認值為DefaultCluster，可以修改為broker所屬的哪個集群

brokerClusterName=DefaultCluster

#原始值為本機主機名，Broker名稱

brokerName=broker-a

#BrokerId，必須是大等于 0 的整數，0 表示Master，>0 表示 Slave，一個 Master 可以掛多個 Slave，Master 與 Slave通過 BrokerName 來配對，原始值為0

brokerId=0

deleteWhen=04

fileReservedTime=48

brokerRole=ASYNC_MASTER

flushDiskType=ASYNC_FLUSH

#port可自由設定，一般設定10911

listenPort=10911

storePathRootDir=/opt/apps/rocketmq-4.8.0/store

storePathCommitLog=/opt/apps/rocketmq-4.8.0/store/commitlog

storePathConsumeQueue=/opt/apps/rocketmq-4.8.0/store/consumequeue

storePathIndex=/opt/apps/rocketmq-4.8.0/store/index

修改啟動腳本引數，根據自己linux的配置進行調整：

# vi /opt/apps/rocketmq-4.8.0/bin/runbroker.sh

調整以下內容：

JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

注意：Xms和Xmx至少是1G  否則啟動不起來  Xmn一般是前者的一半，這邊設定的記憶體不能大于機器實際的記憶體，根據實際情況調整

# vi /opt/apps/rocketmq-4.8.0/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -XX:PermSize=128m -XX:MaxPermSize=320m"

注意：Xms和Xmx至少是1G  否則啟動不起來  Xmn一般是前者的一半，這邊設定的記憶體不能大于機器實際的記憶體，根據實際情況調整

2.6、啟動NameSrv

# nohup sh mqnamesrv > /opt/apps/rocketmq-4.8.0/logs/mqnamesrv.log 2>&1 &

驗證是否啟動成功

# tail -f /opt/apps/rocketmq-4.8.0/logs/mqnamesrv.log

# jps

2.7、啟動broker

# nohup sh mqbroker -c /opt/apps/rocketmq-4.8.0/conf/broker.conf >/opt/apps/rocketmq-4.8.0/logs/broker.log 2>&1 &

驗證是否啟動成功

# tail -f /opt/apps/rocketmq-4.8.0/logs/broker.log

# jps

2.8、停止broker

# sh mqshutdown broker

備注：停止這個任務時不能用kill，如果用kill的話，重新啟動的話，broker是啟動不了的，

2.9、停止namesrv

# sh mqshutdown namesrv

備注：停止這個任務時不能用kill，如果用kill的話，重新啟動的話，broker是啟動不了的，

三、配置防火墻

3.1、配置防火墻

啟動9876、10911埠

# firewall-cmd --permanent --add-port=9876/tcp

# firewall-cmd --permanent --add-port=10911/tcp

重啟防火墻

# systemctl restart firewalld

四、可視化客戶端

這里，rocketmq提供了可視化客戶端，就是rocketmq-console-ng

4.1下載

下載地址

4.2原始碼打包

mvn clean package -Dmaven.test.skip=true

如果你下載依賴慢，可以配置一下maven倉庫地址，修改maven的settings.xml檔案

<mirrors>
    <mirror>
          <id>alimaven</id>
          <name>aliyun maven</name>
          <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
          <mirrorOf>central</mirrorOf>        
    </mirror>
</mirrors>

4.3jar包啟動

打包成功后，可以看到target下，生成rocketmq-console-ng-1.0.0.jar

啟動即可：

java -jar target/rocketmq-console-ng-1.0.0.jar --server.port=7777 --rocketmq.config.namesrvAddr=xxxx:9876

• server.port是指定啟動埠
• rocketmq.config.namesrvAddr是指定rocketmq的nameserver地址

可以看到啟動成功！！！

• 直接訪問localhost:7777，即可看到rocketmq的可視化客戶端

好了，rocketmq部署成功，可視化客戶端部署成功！！！

本文轉自：https://juejin.cn/post/7091642840651923486

標籤：Linux

上一篇：linux命令_tree

下一篇：阿里云Linux服務器檔案上傳與檔案編輯