最近在學習消息隊列,針對RocketMQ進行了初步研究,這里記錄下安裝配置的過程,與大家共同分享
一、選擇合適的版本
注:安裝、運行過程中需要依賴JDK,因此安裝之前需要保證當前linux環境下具備上述環境(JDK安裝步驟)
此處我們直接選擇二進制版本,省去編譯的步驟
https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip
版本選擇:4.7.1
二、在linux下創建安裝目錄
此處我們安裝在“/usr/rocketMQ”目錄下
mkdir /usr/rocketMQ
#將安裝文件上傳至該目錄
#由於文件是zip壓縮包形式,需要提前安裝unzip組件
yum -y install unzip
#安裝完畢后,對壓縮包直接解壓
unzip rocketmq-all-4.7.1-bin-release.zip
三、啟動服務
四、啟動Broker服務
sh mqbroker -n localhost:9876 此時可能會報錯:Cannot allocate memory(原因是由於使用虛擬機,內存不足)
需要修改rocketMq啟動文件的內存設置
#進入目錄 cd /usr/rocketMQ/rocketmq-all-4.7.1-bin-release/bin #使用vi 編輯文件runbroker.sh,修改如下代碼
再次啟動,此時可能會報如下錯誤:
ERROR RocketmqCommon - Failed to obtain the host name
java.net.UnknownHostException: localhost.rocketmq-master: localhost.rocketmq-master: 未知的名稱或服務
此時需要修改linux本地域名
#打開host配置 vi /etc/hosts #添加如下代碼
其中標記紅色的就是報錯代碼的域名
修改完畢后再次啟動,啟動成功
五、模擬發送/接收消息
此處我們直接使用rocketMq自帶的demo進行驗證
執行命令:sh tools.sh org.apache.rocketmq.example.quickstart.Producer(執行之前先聲明環境變量NAMESRV_ADDR)
運行完畢之后,demo會模擬發送消息
結果如下:
執行接收命令:sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
至此,rocketMq安裝以及驗證基本完成,本文只是簡單的安裝說明,后續將針對rocketMQ的各種模式以及實際應用場景進行詳細介紹,敬請期待