RocketMQ安裝及部署

版本信息

Windows

• OS : Windows 10 x64
• RocketMQ : 4.2.0
• JDK : 1.8.0_131
• Maven : 3.5.0

Linux

• OS : Ubuntu 16.04LTS x64
• RocketMQ : 4.2.0
• JDK : 1.8.0_151
• Maven : 3.5.2

安裝步驟

Windows

1. 若下載源碼，使用Maven進行編譯
2. 配置環境變量(值爲RocketMQ的安裝路徑)
   ROCKETMQ_HOME=D:\RocketMQ
3. 修改runbroker.cmd第40行，添加雙引號
   將set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%"
   改成set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""

Linux

1. 若下載源碼，使用Maven進行編譯

2. 配置環境變量(值爲RocketMQ的安裝路徑)
   export ROCKETMQ_HOME=/usr/local/rocketmq/ export PATH=$ROCKETMQ_HOME/bin:$PATH

3. 修改默認配置。因爲RocketMQ默認配置要求很高，好比內存至少就要4個G，開發調試環境根本吃不消，因此咱們開始啓動前須要先修改這些參數。不然的話，咱們頗有會遇到內存分配或者不夠的問題。
   (1). 修改target/apache-rocketmq-all/bin/runserver.sh
   JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:PermSize=128m -XX:MaxPermSize=320m"
   (2). 修改target/apache-rocketmq-all/bin/runbroker.sh
   JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m
   (3). 修改target/apache-rocketmq-all/bin/tools.sh
   JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:PermSize=128m -XX:MaxPermSize=128m"

啓動步驟

1. 啓動Name Server。在bin目錄下運行：
   nohup sh mqnamesrv & tail -f ~/logs/rocketmqlogs/namesrv.log
2. 啓動Broker。在bin目錄下運行：
   nohup sh mqbroker -n localhost:9876 & tail -f ~/logs/rocketmqlogs/broker.log
   這裏-n後面跟的是Name Server的地址。
3. 若要對Broker進行配置。在bin目錄下運行：
   sh mqbroker -m > broker1.properties
   而後能夠對生成的.properties文件進行修改。
4. 根據配置啓動：
   sh mqbroker -c broker1.properties
5. 關閉Broker：
   sh mqshutdown broker（通用）
   sh mqadmin wipeWritePerm -b brokerName -n namerverAddr（可選）

常見錯誤

1. 啓動Name Server的時候報：
   Please set the ROCKETMQ_HOME variable in your environment!
   配置一下ROCKETMQ_HOME的環境變量。
2. 啓動Broker的時候報找不到主類JDK，修改runbroker.cmd第40行
   set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%""
   原來的%CLASSPATH%少了雙引號。
3. 啓動Producer報錯
   org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1:10909> failed
   多種緣由：

• 檢查IP地址，經檢查對應服務器安裝有其餘網橋，將其卸載便可
• 在Producer中將VIP通道關閉：producer.setVipChannelEnabled(false);

4. 啓動Producer報錯
   org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest2

• Broker沒有正確鏈接到Name Server 或

• Producer沒有正確鏈接到Name Server 或

• Broker禁止自動建立Topic，且用戶沒有經過手工方式建立Topic

  默認配置啓動broker時autoCreateTopicEnable=true已設置，因此檢查鏈接便可