集群搭建參考:https://blog.csdn.net/zkn_CS_DN_2013/article/details/85329310
第一部分:RocketMq安裝和簡單測試
1. 下載RocketMQ的二進制文件
https://rocketmq.apache.org/dowloading/releases/? 選擇? Binary: rocketmq-all-4.x.x-bin-release.zip
2.配置
1)環(huán)境配置
在.bash_profile中加入mq的環(huán)境變量
export rocketMq_home=/Users/sunww/Documents/JAVA/MQ/rocketmq-all-4.x.x-bin-release
export JAVA_HOME="/Library/Java/JavaVirtualMachines/jdk1.8.0_231.jdk/Contents/Home"
?PATH=/usr/bin:/usr/local/bin:/usr/sbin:/bin:/sbin:/usr/X11R6/binx:$maven_home/bin:$gradle_home/bin:$mysql_home/bin:$rocketMq_home/bin:$JAVA_HOME/bin
mac jdk8不需要配置環(huán)境變量,查詢安裝路徑宛裕,終端通過命令:/usr/libexec/java_home查看jdk的安裝目錄威蕉。
2)rocketMq配置
vim rocketmq-all-4.9.1-bin-release/conf/broker.conf
# 添加如下配置
brokerIP1 =127.0.0.1
brokerIP2 =127.0.0.1
namesrvAddr =127.0.0.1:9876
啟動broker的時候請注意梗逮。broker默認運行初始化和最大內存都是8G,如果你分配虛擬機的內存過形艽埂(8g也有問題劲室。因為可用內存不到8g)的問題。請修改修改bin/runbroker.sh:
? ?JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
3结窘、啟動rocketmq
1)啟動namesrv:nohup sh bin/mqnamesrv & ?
2)啟動broker:nohup sh bin/mqbroker -n localhost:9876 &
3)查看日志:查看是否成功啟動
4很洋、發(fā)送消息:使用安裝包的Demo測試發(fā)送消息
export NAMESRV_ADDR=127.0.0.1:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
5、接收消息:使用安裝包的Demo測試消費消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
6隧枫、關閉服務
sh bin/mqshutdown broker ? ?//停止 broker
sh bin/mqshutdown namesrv ? //停止 nameserver
第二部分:RocketMq-console安裝
1喉磁、下載工程代碼: https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0
2、idea mvn工程導入工程代碼:修改namesrv地址即可官脓;
3协怒、啟動:
1)mvn clean package -Dmaven.test.skip=true
2)java -jar target/rocketmq-console-ng-1.0.0.jar
命令行管理工具
上面已經講過命令行管理工具已經包含在RocketMQ項目中,我們進入項目下的bin文件夾卑笨,并執(zhí)行命令bash mqadmin,有命令和詳細說明孕暇。具體如何使用這些命令,可以通過執(zhí)行bash mqadmin help <command>來了解細節(jié)赤兴,我們以常用命令updateTopic為例妖滔,執(zhí)行bash mqadmin help updateTopic,打印如下信息:
第三部分:官方開發(fā)文檔資料:
https://rocketmq-1.gitbook.io/rocketmq-connector/