一、RocketMQ安装

1.下载

从apache的文件库下载 https://archive.apache.org/dist/rocketmq/这里我们选择最新版

项目解压

unzip rocketmq-all-4.9.3-bin-release.zip

2.修改启动配置

修改目录/home/rocketmq-4.9.3/bin下的配置文件： runserver.sh、runbroker.sh不然会报insufficient memory
修改runserver.sh 中原有内存配置，更改为

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 表示启动成功

二、RocketMQ修改默认端口

修改namesrv默认端口（默认9876）

在rocketmq的conf目录下添加namesrv.properties文件，文件中添加端口配置

listenPort=8876

使用配置信息后台启动namesrv

nohup sh bin/mqnamesrv -c conf/namesrv.properties &

修改broker默认端口（默认10911）

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
# 新增的配置，broker默认端口
namesrvAddr=10.238.57.206:8876
brokerIP1=10.238.57.206
listenPort=8911

使用配置信息后台启动broker

nohup sh bin/mqbroker -n localhost:8876 -c conf/broker.conf &

三、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

结尾

• 感谢大家的耐心阅读，如有建议请私信或评论留言。
• 如有收获，劳烦支持，关注、点赞、评论、收藏均可，博主会经常更新，与大家共同进步