RocketMQ下載
wget http://apache.01link.hk/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip
解壓安裝包
unzip rocketmq-all-4.3.0-bin-release.zip
啟動(dòng)和關(guān)閉NameServer
- 進(jìn)入解壓的根目錄，運(yùn)行命令：
nohup sh bin/mqnamesrv &
注意：NameServer默認(rèn)配置的JVM堆內(nèi)存為4G，確認(rèn)當(dāng)前系統(tǒng)內(nèi)存是否足夠，可到bin/runserver.sh中修改 JAVA_OPT="${JAVA_OPT} -server 中的JVM配置
- 如果啟動(dòng)成功，會(huì)在用戶默認(rèn)目錄下生成/logs/rocketmqlogs/namesrv.log
- 如果啟動(dòng)不成功根目錄下會(huì)生成一個(gè)hs開頭的log文件，可查看啟動(dòng)失敗的原因
- 關(guān)閉NameServer,運(yùn)行命令：
nohup sh bin/mqshutdown namesrv
啟動(dòng)和關(guān)閉Broker
- 進(jìn)入解壓的根目錄，運(yùn)行命令：
nohup sh bin/mqbroker -n localhost:9876&
注意：Broker默認(rèn)配置的JVM堆內(nèi)存為8G，確認(rèn)當(dāng)前系統(tǒng)內(nèi)存是否足夠，可到bin/broker.sh中修改 JAVA_OPT="${JAVA_OPT} -server 中的JVM配置
- 如果啟動(dòng)成功，會(huì)在用戶默認(rèn)目錄下生成/logs/rocketmqlogs/broker.log
- 如果啟動(dòng)不成功根目錄下會(huì)生成一個(gè)hs開頭的log文件，可查看啟動(dòng)失敗的原因
- 關(guān)閉Broker,運(yùn)行命令：
nohup sh bin/mqshutdown broker
注意：運(yùn)行關(guān)閉命令后，broker不會(huì)立刻關(guān)閉，需要大約10秒時(shí)間，不要直接殺死broker進(jìn)程，否則會(huì)造成消息丟失
使用官方demo測試
- 配置環(huán)境變量NAMESRV_ADDR=localhost:9876，或直接執(zhí)行命令：
export NAMESRV_ADDR=localhost:9876配置臨時(shí)的環(huán)境變量
- 啟動(dòng)Producer,根目錄執(zhí)行：
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
見面彈出多行如下記錄即為啟動(dòng)啟動(dòng)成功
SendResult [sendStatus=SEND_OK, msgId=AC1500103D114B67CF4D2DFC...
- 啟動(dòng)Consumer,根目錄執(zhí)行：
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
見面彈出多行如下記錄即為啟動(dòng)啟動(dòng)成功
ConsumeMessageThread_16 Receive New Messages: [MessageExt [queueId=...
