這里是 RocketMQ 系列的第一篇文章，工欲善其事，必先利其器，先不講理論，也不具體介紹 RocketMQ,我們先把 RocketMQ先安裝上，讓你們實地感受下 RocketMQ 整個安裝流程，安裝完后我們再后續文章對 RocketMQ 手術刀式一層一層進行剖析，
下載安裝包
直接從 RocketMQ 官網下載最新的安裝包
下載地址：https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip
解壓安裝包
下載后，我們將它放入linux服務器中任意目錄并解壓，我這里使用的是云服務器，放到了data目錄下，你們也可以自己搭建服務器，
// 解壓安裝包
# unzip rocketmq-all-4.9.2-bin-release.zip
//解壓后修改檔案夾名稱，也可不修改
# mv rocketmq-4.9.2/ rocketmq
配置環境變數
我們需要將剛剛解壓的 rocketmq 路徑配置到環境變數中，
//編輯profile檔案
# vi /etc/profile
//將以下代碼配置進去，我這里路徑是/data/rocketmq
//你們只需根據自己實際路徑進行替換即可
export ROCKETMQ_HOME=/data/rocketmq
export PATH=$PATH:$ROCKETMQ_HOME/bin:$PATH
配置完成后，退出保存，如何輸入以下命令使其生效
//使剛修改的組態檔生效
# source /etc/profile
//驗證剛剛的路徑配置是否生效
# echo $ROCKETMQ_HOME
//顯示出路徑地址代表配置沒有問題
/data/rocketmq
啟動 nameserver
# nohup sh bin/mqnamesrv &
查看是否啟動成功
# jps -l
可以看到 nameServer 我們就已經啟動成功了，
配置 jvm引數
RocketMQ Broker 默認配置的 jvm 虛擬機記憶體大小可能比較大，如果不修改會導致啟動不起來，這里我們根據自己的實際需要進行修改，
# vi bin/runbroker.sh
默認指定的是 8g，我這里修改為 256m，
啟動 Broker
//啟動 NameServer 命令
# nohup sh bin/mqbroker -c conf/broker.conf &
# 查看是否啟動成功
# jps -l
模擬發送訊息 和 消費訊息
目前 我們 NameServer 和 Broker 都已經啟動成功，就可以進行發送和消費訊息，RocketMQ 安裝包默認提供了一個模擬發送訊息和消費訊息的測驗類，我們來驗證一下，
發送訊息
//創建生產者發送訊息
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
我們發現沒有啟動起來，出現了錯誤，這是為什么呢？
RocketMQ NameServer 默認埠號是 9876 ，如果你開啟了防火墻，你要么關閉防火墻，要么在安全組中將 9876 埠號設定允許訪問，我這里就設定了允許訪問，
此時，模擬發送成功了，默認是發送 1000 條訊息，
消費訊息
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
通過模擬發送和消費，也就驗證了我們整個 RocketMQ 就搭建成功了，
還有個 NameServer 和 Broker 關閉命令也介紹下：
// 關閉 Broker
sh bin/mqshutdown broker
// 關閉 NameServer
sh bin/mqshutdown namesrv
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/423368.html
標籤：其他