RocketMQ安裝

1、安裝

下載地址:http://rocketmq.apache.org/docs/quick-start/
選擇binary release下載(也可以下載source release,但是需要maven編譯)。
我下載的版本是rocketmq-all-4.7.1-bin-release.zip。
1、解壓文件:

> unzip rocketmq-all-4.7.1-bin-release.zip #解壓
> mv rocketmq-all-4.7.1-bin-release rocketmq #重命名文件夾
> cd rocketmq

2、修改runserver.sh文件

> vim bin/runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改成
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn64m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

3、修改runbroker.sh文件:

> vim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"
修改成
JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn64m"

這里設(shè)置了server、broker運(yùn)行時需要的內(nèi)存。如果不修改,服務(wù)器可能沒有足夠的內(nèi)存,導(dǎo)致server或broker無法啟動。
4、啟動name server

> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log # 查看nameserv日志
> jps # 查看java進(jìn)程
12642 Jps
12622 NamesrvStartup

5、啟動broker

> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log #查看broker日志
> jps
12709 BrokerStartup
12838 Jps
12622 NamesrvStartup

注意:啟動namesrv和broker時會有這樣一個提示:nohup: ignoring input and appending output to 'nohup.out',直接按回車鍵即可。

6、測試
發(fā)送消息

> export NAMESRV_ADDR=localhost:9876 # 設(shè)置環(huán)境變量
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer #使用安裝包的Demo發(fā)送消息

接受消息

> export NAMESRV_ADDR=localhost:9876 # 設(shè)置環(huán)境變量(我這里是打開了一個新的會話,如果是同一個會話,這一步操作可以省略)
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer # 接受消息

7、關(guān)閉服務(wù)

> sh bin/mqshutdown broker
> sh bin/mqshutdown namesrv
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容