下载
https://archive.apache.org/dist/rocketmq/
修改启动配置
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn512m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改runbroker.sh 中原有内存配置,更改为
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
修改/home/rocketmq-4.9.3/conf/broker.conf文件,添加配置
namesrvAddr=10.101.37.145:9876
brokerIP1=10.101.37.145
3.启动
进入/home/rocketmq-4.9.3,启动 NameServer
nohup sh bin/mqnamesrv &
nohup sh mqnamesrv & 属于后台启动
sh mqnamesrv
属于终端启动,直接输出日志信息,按 ctrl+c 可直接关闭退出
在当前目录下会有一个 nohup.out 的日志文件,可以打开查看 namesrv 的启动情况。看到 The Name Server boot success.serializeType=JSON 表示启动成功
进入/home/rocketmq-4.9.3,启动 Broker
# 启动命令,10.101.37.145:9876为namesrv的IP和端口,保证地址以及端口能够访问。并且指定配置文件启动
nohup sh bin/mqbroker -n 10.101.37.145:9876 -c ./conf/broker.conf &
nohup sh bin/mqbroker -n 10.101.37.145:9876 & 属于后台启动
sh bin/mqbroker -n 10.101.37.145:9876 属于终端启动,直接输出日志信息,按 ctrl+c 可直接关闭退出
同样去看nohup.out 文件,看到 boot success 表示启动成功
Console管理后台安装
RocketMQ有一个可视化的的dashboard,通过该控制台可以直观的看到很多数据
1.下载
下载地址:https://github.com/apache/rocketmq-externals/releases master分支看不到rocketmq-console时,可以切换develop分支
2.修改配置
修改其src/main/resources中的application.properties配置文件。
默认端口号为 8080 ,修改为一个不常用的 指定RocketMQ的name server地址
3.修改pom
修改rocketmq.version为4.4.0,(因develop当时查看采用的开发环境为4.4.0-SNAPSHOT,故改为4.4.0兼容性最好,不然需要修改部分代码兼容新版本。
4.打包 在rocketmq-console目录下执行打包命令
mvn clean package -Dmaven.test.skip=true
打好包后在target目录下会生成可执行的jar包
5.启动
java -jar rocketmq-console-ng-1.0.0.jar