RocketMQ 安裝教程
TIPS
本文基於RocketMQ 4.5.1,理論支持RocketMQ 4.0
本文詳細探討如何搭建RocketMQ
一、下載
前往 http://rocketmq.apache.org/release_notes/release-notes-4.5.1/ ,下載 Binary 文件即可。
例如RocketMQ 4.5.1的下載地址:
Binary: rocketmq-all-4.5.1-bin-release.zip
二、系統要求
64位操作系統,生產環境建議Linux/Unix/MacOS(Windows操作系統安裝說明詳見 Windows操作系統安裝教程)
64位JDK 1.8
4G 的可用磁碟
三、Linux/Unix/MacOS安裝教程
3.1 搭建
解壓壓縮包
unzip rocketmq-all-4.5.1-bin-release.zip
切換目錄到RocketMQ根目錄
cd rocketmq-all-4.5.1-bin-release
啟動Name Server
nohup sh bin/mqnamesrv
驗證是否啟動OK:
tail -f ~/logs/rocketmqlogs/namesrv.log
# 如果成功啟動,能看到類似如下的日誌:
2019-07-18 17:03:56 INFO main - The Name Server boot success. ...
啟動 Broker
nohup sh bin/mqbroker -n localhost:9876
驗證是否啟動OK:
tail -f ~/logs/rocketmqlogs/broker.log
# 如果啟動成功,能看到類似如下的日誌:
2019-07-18 17:08:41 INFO main - The broker[itmuchcomdeMacBook-Pro.local, 192.168.43.197:10911] boot success. serializeType=JSON and name server is localhost:9876
3.2 驗證RocketMQ功能正常(可選)
3.2.1 驗證生產消息正常
執行如下命令:
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
能看到類似如下輸出:
SendResult [sendStatus=SEND_OK, msgId=C0A82BC5F36C511D50C05B41...
3.2.2 驗證消費消息正常
執行如下命令:
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
能看到類似如下輸出:
ConsumeMessageThread_4 Receive New Messages: [MessageExt [queueId=3,? stor....
3.3 停止
依次執行以下兩條命令即可
四、Windows操作系統安裝教程
詳見 Windows下RocketMQ安裝部署
五、生產可用集群搭建教程
RocketMQ集群搭建說明 ,集群安裝模式非常多,本文不展開了。請各位看客根據自己的需求,選擇適合自己的模式自行搭建。


※使用AOP功能和ThreadLocal類實現自定義事務管理
※MySQL存儲引擎、MyISAM、InnoDB
TAG:千鋒JAVA開發學院 |