RocketMQ服务器及管理控制台安装

0x01：下载安装

• 进入官网下载RocketMQ服务端，下载地址：
  

http://rocketmq.apache.org/docs/quick-start/

• 解压压缩包rocketmq-all-4.7.1-bin-release.zip

0x02：主要目录介绍

• bin：启动脚本，包括shell脚本和CMD脚本
  
• conf：实例配置文件 ，包括broker配置文件、logback配置文件等
  
• lib：依赖jar包，包括Netty、commons-lang、fastjson等
  

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

具体大小可以根据实际情况修改。

• 启动NameServer

nohup sh bin/mqnamesrv &

• 查看NameServer启动日志

tail -f ~/logs/rocketmqlogs/namesrv.log

window系统启动截图

• 启动Broker

nohup sh bin/mqbroker -n localhost:9876 &

• 查看Broker启动日志

tail -f ~/logs/rocketmqlogs/broker.log

window系统启动截图

注：如果是windows系统需要设置ROCKET_HOME环境变量

• 变量名：ROCKETMQ_HOME
• 变量值：MQ解压路径\MQ文件夹名

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-xxx.jar文件（因为rocketmq-console一个springboot项目）

• 运行rocketmq-console
  

使用如下命令，运行rocketmq-console，启动管理控制台

java -jar rocketmq-console-ng-1.0.0.jar

启动成功后，通过浏览器访问http://localhost:8080进入控制台界面，如下图