基于 Linux 環境安裝部署 RocketMQ 教程
這里是 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 路徑配置到環境變量中。
//使剛修改的配置文件生效
# source /etc/profile
//驗證剛剛的路徑配置是否生效
# echo $ROCKETMQ_HOME
//顯示出路徑地址代表配置沒有問題
/data/rocketmq
配置完成后,退出保存,如何輸入以下命令使其生效
啟動 nameserver
# nohup sh bin/mqnamesrv &
查看是否啟動成功
# nohup sh bin/mqnamesrv &
可以看到 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