這里是 RocketMQ 系列的第一篇文章，工欲善其事，必先利其器，先不講理論，也不具體介紹 RocketMQ,我們先把 RocketMQ先安裝上，讓你們實(shí)地感受下 RocketMQ 整個(gè)安裝流程，安裝完后我們再后續(xù)文章對 RocketMQ 手術(shù)刀式一層一層進(jìn)行剖析。

下載安裝包

直接從 RocketMQ 官網(wǎng)下載最新的安裝包

下載地址：

https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip

解壓安裝包

下載后，我們將它放入linux服務(wù)器中任意目錄并解壓，我這里使用的是云服務(wù)器，放到了data目錄下，你們也可以自己搭建服務(wù)器。

// 解壓安裝包
# unzip rocketmq-all-4.9.2-bin-release.zip 
//解壓后修改文件夾名稱，也可不修改
# mv rocketmq-4.9.2/ rocketmq

配置環(huán)境變量

我們需要將剛剛解壓的 rocketmq 路徑配置到環(huán)境變量中。

//使剛修改的配置文件生效
# source /etc/profile
//驗(yàn)證剛剛的路徑配置是否生效
# echo $ROCKETMQ_HOME
//顯示出路徑地址代表配置沒有問題
/data/rocketmq

配置完成后，退出保存，如何輸入以下命令使其生效

啟動 nameserver

# nohup sh bin/mqnamesrv &

查看是否啟動成功

# nohup sh bin/mqnamesrv &

可以看到 nameServer 我們就已經(jīng)啟動成功了。

配置 jvm參數(shù)

RocketMQ Broker 默認(rèn)配置的 jvm 虛擬機(jī)內(nèi)存大小可能比較大，如果不修改會導(dǎo)致啟動不起來，這里我們根據(jù)自己的實(shí)際需要進(jìn)行修改。

# vi bin/runbroker.sh

默認(rèn)指定的是 8g，我這里修改為 256m。

啟動 Broker

//啟動 NameServer 命令
# nohup sh bin/mqbroker -c conf/broker.conf &
# 查看是否啟動成功
# jps -l

模擬發(fā)送消息 和 消費(fèi)消息

目前 我們 NameServer 和 Broker 都已經(jīng)啟動成功，就可以進(jìn)行發(fā)送和消費(fèi)消息，RocketMQ 安裝包默認(rèn)提供了一個(gè)模擬發(fā)送消息和消費(fèi)消息的測試類，我們來驗(yàn)證一下。

發(fā)送消息

//創(chuàng)建生產(chǎn)者發(fā)送消息
# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

我們發(fā)現(xiàn)沒有啟動起來，出現(xiàn)了錯(cuò)誤，這是為什么呢?

RocketMQ NameServer 默認(rèn)端口號是 9876 ，如果你開啟了防火墻，你要么關(guān)閉防火墻，要么在安全組中將 9876 端口號設(shè)置允許訪問，我這里就設(shè)置了允許訪問。

此時(shí)，模擬發(fā)送成功了，默認(rèn)是發(fā)送 1000 條消息。

消費(fèi)消息

# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

通過模擬發(fā)送和消費(fèi)，也就驗(yàn)證了我們整個(gè) RocketMQ 就搭建成功了。

還有個(gè) NameServer 和 Broker 關(guān)閉命令也介紹下：

// 關(guān)閉 Broker
sh bin/mqshutdown broker
// 關(guān)閉 NameServer
sh bin/mqshutdown namesrv