Linux環境下安裝RocketMQ


最近在學習消息隊列,針對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的各種模式以及實際應用場景進行詳細介紹,敬請期待

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM