1. 程式人生 > >RocketMQ 安裝配置及叢集主從配置

RocketMQ 安裝配置及叢集主從配置

1.       需要軟體:

Maven,Java,RocketMQ當前最新版本是4.2.0,必須的java1.8來支援


2 .  Java 安裝解壓完成後配置環境變數,

#Java環境變數配置

export JAVA_HOME=/usr/local/java/jdk1.8.0_171

export JRE_HOME=/usr/local/java/jdk1.8.0_171/jre

export PATH=$PATH:/usr/local/java/jdk1.8.0_171/bin

exportCLASSPATH=./:/usr/local/java/jdk1.8.0_171/lib:/usr/local/java/jdk1.8.0_171/jre/lib

export PATH=$PATH

3       Maven安裝完成需要配置maven環境變數

#maven環境變數配置配置位置 /etc/profile

MAVEN_HOME=/usr/local/java/apache-maven-3.5.3 

export MAVEN_HOME 

export PATH=${PATH}:${MAVEN_HOME}/bin

使用source/etc/profile 是配置生效,java  -version 測試配置是否正確。


使用mvn -v 測試環境配置是否正確;


   RocketMQ安裝完成後配置環境變數

rocketmq環境變數配置,配置位置~/.bash_profile

Source  ~/.bash_profile 是環境變數生效

5.啟動執行

  進入到安裝目錄/usr/local/java/rocketmq/下

         使用命令 sh./bin/mqnamesrv  & 開啟 server服務。一般情況下直接會提示記憶體溢位的錯誤


重新設定RocketMQ 檔案中runserver.sh 和runbroker.sh 對jvm的要求,因為RocketMQ對jvm配置要求太高。


因為是安裝在虛擬機器中記憶體只有512M,以上資料是修改後的,原檔案中的資料是4G。runbroker.sh修改和runserver.sh相同。在修改完成後重新啟動sh ./bin/mqnamesrv  &

啟動成功之後顯示如圖所示:


Sh ./bin/mqbroker –n 127.0.0.1:9876 &

可以在eclipse 使用官方用例來測試。注意linux防火牆開放埠。

官方學習地址:http://rocketmq.apache.org/docs/simple-example/

至此RocketMQ的安裝完成

6.   RocketMQ 的主從配置。

在安裝包conf 目錄下有官方自帶配置檔案模板從上自下以此是:兩主兩從非同步;兩主兩從同步;兩主,


在虛擬機器中安裝的linux 可通過克隆方式快速克隆其他三臺機器

其中namesrvAddr 主機地址,brokerClusterName 叢集名稱,brokerName  分片名稱 ,brokerId 分片id編號 ;brokerRole分片角色。注意:其中主從之間的分片名稱相同。主從區分是brokerId 主 0,從 1。brokerRole 主MASTER從SLAVE。

配置完成之後啟動個主機的RocketMQ服務。


7.測試

執行通過執行rocketmq-console控制檯可以看到:表示搭建成功。

因為只見了三臺伺服器所以是兩主一從。

1.       需要軟體:

Maven,Java,RocketMQ當前最新版本是4.2.0,必須的java1.8來支援

2 .  Java 安裝解壓完成後配置環境變數,

#Java環境變數配置

export JAVA_HOME=/usr/local/java/jdk1.8.0_171

export JRE_HOME=/usr/local/java/jdk1.8.0_171/jre

export PATH=$PATH:/usr/local/java/jdk1.8.0_171/bin

exportCLASSPATH=./:/usr/local/java/jdk1.8.0_171/lib:/usr/local/java/jdk1.8.0_171/jre/lib

export PATH=$PATH

3       Maven安裝完成需要配置maven環境變數

#maven環境變數配置配置位置 /etc/profile

MAVEN_HOME=/usr/local/java/apache-maven-3.5.3 

export MAVEN_HOME 

export PATH=${PATH}:${MAVEN_HOME}/bin

使用source/etc/profile 是配置生效,java  -version 測試配置是否正確。

使用mvn -v 測試環境配置是否正確;

         RocketMQ安裝完成後配置環境變數

rocketmq環境變數配置,配置位置~/.bash_profile

Source  ~/.bash_profile 是環境變數生效

5.啟動執行

  進入到安裝目錄/usr/local/java/rocketmq/下

         使用命令 sh./bin/mqnamesrv  & 開啟 server服務。一般情況下直接會提示記憶體溢位的錯誤

重新設定RocketMQ 檔案中runserver.sh 和runbroker.sh 對jvm的要求,因為RocketMQ對jvm配置要求太高。

因為是安裝在虛擬機器中記憶體只有512M,以上資料是修改後的,原檔案中的資料是4G。runbroker.sh修改和runserver.sh相同。在修改完成後重新啟動sh ./bin/mqnamesrv  &

啟動成功之後顯示如圖所示:

Sh ./bin/mqbroker –n 127.0.0.1:9876 &

可以在eclipse 使用官方用例來測試。注意linux防火牆開放埠。

官方學習地址:http://rocketmq.apache.org/docs/simple-example/

至此RocketMQ的安裝完成

6.   RocketMQ 的主從配置。

在安裝包conf 目錄下有官方自帶配置檔案模板從上自下以此是:兩主兩從非同步;兩主兩從同步;兩主,

在虛擬機器中安裝的linux 可通過克隆方式快速克隆其他三臺機器

其中namesrvAddr 主機地址,brokerClusterName 叢集名稱,brokerName  分片名稱 ,brokerId 分片id編號 ;brokerRole分片角色。注意:其中主從之間的分片名稱相同。主從區分是brokerId 主 0,從 1。brokerRole 主MASTER從SLAVE。

配置完成之後啟動個主機的RocketMQ服務。

7.測試

執行通過執行rocketmq-console控制檯可以看到:表示搭建成功。


因為只見了三臺伺服器所以是兩主一從。


參考一下文件