RocketMQ單機版安裝

安裝前的準備

JDK1.8+

rocketmq-all-4.9.1-bin-release

安裝過程

安裝JDK

首先把jdk1.8.tar.gz解壓到目前目錄下，如下圖所示

修改/etc/profile檔案，添加環境變量，代碼段如下面所示，其中/opt/jdk1.8.0_144的值為上圖中解壓的路徑。

#JAVA_HOME
export JAVA_HOME=/opt/jdk1.8.0_144
export PATH=$PATH:$JAVA_HOME/bin      

檢視是否安裝成功

echo $JAVA_HOME      

安裝RocketMQ

下載下傳、解壓并且修改配置

下載下傳RocketMQ安裝包并解壓，進入解壓後的目錄如下圖所示

修改rocketmq-all-4.9.1-bin-release/bin/runserver.sh檔案

修改rocketmq-all-4.9.1-bin-release/bin/runbroker.sh檔案、

啟動NameServer和Broker

參考：

RocketMQ官方文檔 http://rocketmq.apache.org/docs/quick-start/

> nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...      

> nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...      

收發消息測試

參考：

RocketMQ官方文檔 http://rocketmq.apache.org/docs/quick-start/

> export NAMESRV_ADDR=localhost:9876
 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
 SendResult [sendStatus=SEND_OK, msgId= ...

 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
 ConsumeMessageThread_%d Receive New Messages: [MessageExt...      

RocketMQ可視化控制台安裝

下載下傳位址：https://github.com/apache/rocketmq-externals/tags

下載下傳下來以後是一個SpringBoot項目，修改配置檔案裡的端口和nameServer，如下圖所示

進入rocketmq-externals-rocketmq-console-1.0.0\rocketmq-console目錄下并執行打包指令

mvn clean package -Dmaven.test.skip=true      

打包以後啟動，并且在控制台輸入http://ip:7000/#/

JavaAPI

​​https://gitee.com/cbeann/Demooo/tree/master/rocketmq-demo​​

參考