Mac安装RocketMQ和可视化控制台教程
1:下載:?http://rocketmq.apache.org/docs/quick-start/, 直接下載源代碼版本
?
?
?
?
2:使用maven進行源碼編譯:
mvn -Prelease-all -DskipTests clean install -U
?
?
3:環境配置
找到已經安裝好的 jdk 位置,通過命令:/usr/libexec/java_home
?
在.zshrc中加入JAVA_HOME的環境變量
export JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_201.jdk/Contents/Home
在.zshrc中加入JAVA_HOME的環境變量
ROCKETMQ_HOME=/Users/wangzeyu/Downloads/software/rocketmq/rocketmq-all-4.8.0-source-release
保存完生效
source ~/.bash_profile
調整啟動內存 vim bin/runserver.sh #調整nameserver啟動的內存(如果服務器內存比較大,可以不調整),如果內存較小,不調整此文件,可能導致無法啟動 JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m" vim bin/runbroker.sh JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"?
?
以守護進程的方式啟動mqnamesrv
nohup sh bin/mqnamesrv & 這個命令可能會nohup: ignoring input and appending output to ‘nohup.out’,如果出現這個,執行: tail -f nohup.out這個時候ctrl+c就不會退出程序,僅僅是讓程序后臺運行使用jsp查看啟動
?
?
啟動Broker
[root@wangzhi apache-rocketmq]# sh bin/mqbroker -n localhost:9876使用jps查看啟動
?
測試投遞消息
需要先配置 NAMESRV_ADDR 到環境變量中 具體方法可以直接在終端輸入命令,這種方式記錄的?NAMESRV_ADDR 是臨時的,關閉終端就生效了
export?NAMESRV_ADDR=localhost:9876
發送消息測試??
可以看到終端輸出大量日志,已經發送不了很多消息 ?
?
?
測試接受消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
同樣是終端輸出大量日志,接受了很多消息 ? 以上說明 RocketMQ 已經能正常使用了?
?
?
?
?
二、安裝可視化控制臺
1.下載項目
在 GitHub 中搜索?rocketmq-externals,其中 rocketmq-console 就是 RocketMQ 可視化控制臺,我們可以將源碼克隆下來,然后自己 mvn package,然后運行 jar 包。
或者直接下載官方提供的 1.0.0 版本的 rocketmq-console
https://github.com/apache/rocketmq-externals/releases/tag/rocketmq-console-1.0.0
下載 zip 包或者 tar 包
?
?
下載完后解壓zip包
?
?
進入rocketmq-console文件夾
進入rocketmq-console的src/main/resources/文件夾
?
?
修改配置文件application.properties
配置rocketmq.config.namesrvAddr屬性的值,即nameserver的服務地址
rocketmq.config.namesrvAddr=127.0.0.1:9876?
?
保存修改后的配置文件,返回rocketmq-console目錄
使用maven打包命令打包
mvn clean package -Dmaven.test.skip=true?
打包完成后進入target目錄
?
rocketmq-console-ng-2.0.0.jar即為打包后得到的jar包
啟動程序
nohup java -jar rocketmq-console-ng-2.0.0.jar &?
?
訪問http://127.0.0.1:8080/
就可以了
總結
以上是生活随笔為你收集整理的Mac安装RocketMQ和可视化控制台教程的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 友盟分享错误码
- 下一篇: RocketMQ角色介绍