0x01:下载安装
http://rocketmq.apache.org/docs/quick-start/
0x02:主要目录介绍
0x03:启动与关闭
进入bin目录,建议修改runbroker.sh和runserver.sh默认JVM的大小,防止内存不足启动失败。参考设置如下
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
runserver.cmd
runbroker.cmd
具体大小可以根据实际情况修改。
nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log
window系统启动截图
nohup sh bin/mqbroker -n localhost:9876 &
tail -f ~/logs/rocketmqlogs/broker.log
window系统启动截图
注:如果是windows系统需要设置ROCKET_HOME环境变量
0x04:rocketmq-console控制台
进入官网下载rocketmq-console源码,下载地址如下
https://github.com/apache/rocketmq-externals
下载完成之后,进入如下文件夹
rocketmq-externals\rocketmq-console\src\main\resources
打开application.properties配置文件进行配置
进入如下文件夹
\rocketmq-externals\rocketmq-console
执行meven命令(前提条件安装了maven)
mvn clean package -Dmaven.test.skip=true
编译,将会在target目录中生成一个rocketmq-console-ng-2.0.0.jar文件(因为rocketmq-console一个springboot项目)
使用如下命令,运行rocketmq-console,启动管理控制台
java -jar rocketmq-console-ng-2.0.0.jar
启动成功后,通过浏览器访问http://localhost:8080进入控制台界面,如下图