RocketMQ入門

RocketMQ是阿里巴巴開源的分布式消息中間件，現在是Apache的一個頂級項目。在阿里內部使用非常廣泛，已經經過了"雙11"這種萬億級的消息流轉。

RocketMQ環境搭建

接下來我們先在linux平臺下安裝一個RocketMQ的服務

環境準備

下載RocketMQ

http://rocketmq.apache.org/release_notes/release-notes-4.4.0/

環境要求

Linux 64位操作系統

64bit JDK 1.8+

安裝RocketMQ

1 上傳文件到Linux系統

[root@leonrocketmq]# ls /usr/local/src/ rocketmq-all-4.4.0-bin-release.zip

2 解壓到安裝目錄

[root@leon src]# unzip rocketmq-all-4.4.0-bin-release.zip [root@leon src]# mv rocketmq-all-4.4.0-bin-release ../rocketmq

啟動RocketMQ

1切換到安裝目錄

[root@leon rocketmq]# ls benchmark bin conf lib LICENSE NOTICE README.md

2 啟動NameServer

[root@leon rocketmq]# nohup ./bin/mqnamesrv & [1] 1467 # 只要進程不報錯,就應該是啟動成功了,可以查看一下日志 [root@leon rocketmq]# tail -f /root/logs/rocketmqlogs/namesrv.log

3 啟動Broker

# 編輯bin/runbroker.sh 和 bin/runserver.sh文件,修改里面的 # JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g" # 為JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m" [root@leon rocketmq]# nohup bin/mqbroker -n localhost:9876 & [root@leon rocketmq]# tail -f /root/logs/rocketmqlogs/broker.log

測試RocketMQ

1 測試消息發送

[root@leon rocketmq]# export NAMESRV_ADDR=localhost:9876 [root@leon rocketmq]# bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

2 測試消息接收

[root@leon rocketmq]# export NAMESRV_ADDR=localhost:9876 [root@leon rocketmq]# bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

關閉RocketMQ

[root@leon rocketmq]# bin/mqshutdown broker [root@leon rocketmq]# bin/mqshutdown namesrv

?

總結

以上是生活随笔為你收集整理的RocketMQ环境搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。