一,下載安裝包
1.官網地址:http://rocketmq.apache.org/dowloading/releases/
2.網盤下載:
鏈接:https://pan.baidu.com/s/1pir1iAVkAhhaTrT-6Jx2-w
提取碼:m281
二、安裝及啟動
1、將zip文件上傳到linux的~下,然后解壓:
我的安裝包放在了/home/RocketMQ 解壓:unzip 壓縮包名稱
2、移動 執行 mv rocketmq-all-4.3.0-bin-release /usr/local/rocketmq
看一下該文件的目錄:
啟動NameServer命令(bin目錄下)
啟動:nohup sh mqnamesrv &
查看日志:tail -f ~/logs/rocketmqlogs/namesrv.log
啟動Broker命令(bin目錄下)
啟動:nohup sh mqbroker -n localhost:9876 &
查看日志:tail -f ~/logs/rocketmqlogs/broker.log
關閉RocketMQ命令:(bin目錄下)
關閉NameServer:sh mqshutdown namesrv
關閉Borker:sh mqshutdown broker
注意:RocketMQ默認的虛擬機內存比較大,啟動Broker如果因為內存不許而失敗,需要編輯兩個配置文件,修改JVM內存大小。
編輯runbroker.sh和runserver.sh修改默認JVM的大小
vim runbroker.sh
vim runserver.sh
3.啟動nameserver,在bin目錄下執行:nohup sh mqnamesrv & 查看啟動是否成功的日志命令:tail -f ~/logs/rocketmqlogs/namesrv.log 打印如下表示啟動成功:
4.啟動broker,在bin目錄下執行:nohup sh mqbroker -n localhost:9876 & 查看日志命令:tail -f ~/logs/rocketmqlogs/broker.log,打印如下表示啟動成功:
三。測試RocketMQ
這里我用的是putty來測試,連接兩台,一個發送消息,一個接收消息
putty:
鏈接:https://pan.baidu.com/s/16huhWIZ7wm9P8Q0t1emcdQ
提取碼:q4j5
1.發送消息<bin目錄>
設置環境變量:export NAME SRV_ADDR=localhost:9876
使用安裝包demo發送消息:sh tools.sh org.apache.rocketmq.example.quickstart.Producer
2.接收消息<bin目錄>
設置環境變量:export NAME SRV_ADDR=localhost:9876
使用安裝包demo接收消息:sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
到此,RocketMQ初步完成。。。。。。。。。。。。。