一、環境準備
在開始安裝RocketMQ之前,我們需要準備以下環境:
1、JDK:請確保已經在Windows操作系統中安裝了JDK,並能夠正常運行。
2、存儲:確保有足夠的硬碟空間用於存儲RocketMQ程序和數據。
3、下載RocketMQ:從官方網站http://rocketmq.apache.org/release_notes/release-notes-4.8.0下載安裝包。
二、安裝步驟
1、解壓安裝包
tar -zxvf rocketmq-all-4.8.0-bin-release.zip
解壓後的文件夾包含了大部分文件,我們將在此文件夾中完成RocketMQ的安裝。
2、創建Name Server和Broker實例
在解壓後的根目錄下,有兩個主要的文件夾實例文件夾和namesrv文件夾。
在實例目錄文件夾中,我們將創建Broker實例文件夾:
mkdir broker-a
mkdir broker-b
在namesrv文件夾中,我們將創建Name Server實例文件夾:
mkdir namesrv-a
3、修改配置文件
修改 namesrv-a/conf 目錄下的配置文件:
rocketmq.namesrv.addr=192.168.0.1:9876
修改 broker-a/conf 文件夾下的配置文件:
brokerClusterName = MyBroker_Cluster
brokerName = MyBroker_A
brokerId = 0
deleteWhen= 04
fileReservedTime = 48
修改 broker-b/conf 文件夾下的配置文件:
brokerClusterName = MyBroker_Cluster
brokerName = MyBroker_B
brokerId = 1
deleteWhen= 04
fileReservedTime = 48
4、啟動Name Server
在解壓後的根目錄中,進入 namesrv 目錄,然後運行以下命令:
nohup sh bin/mqnamesrv &
5、啟動Broker
在解壓後的根目錄中,進入 broker-a 目錄,然後運行以下命令:
nohup sh bin/mqbroker -c conf/broker-a.properties &
在解壓後的根目錄中,進入 broker-b 目錄,然後運行以下命令:
nohup sh bin/mqbroker -c conf/broker-b.properties &
三、檢查RocketMQ是否啟動
1、檢查Name Server狀態
在任意命令窗口中輸入以下命令:
ps -ef|grep mqnamesrv |grep -v grep
如果看到一個名稱為 mqnamesrv 的進程,表示Name Server已經啟動。
2、檢查Broker狀態
在任意命令窗口中輸入以下命令:
ps -ef|grep mqbroker |grep -v grep
如果看到兩個名稱為 mqbroker 的進程,表示兩個Broker都已經啟動。
四、使用RocketMQ
現在可以在您的應用程序中使用 Apache RocketMQ。
在您的應用程序中,您需要指定以下屬性:
namesrvAddr = "localhost:9876";
producerGroup = "producer";
consumerGroup = "consumer";
請將上述屬性值修改為您安裝時的正確值。
原創文章,作者:NHTK,如若轉載,請註明出處:https://www.506064.com/zh-tw/n/146159.html