RocketMq安装（rocketmq搭建教程）

RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等1) 准备RocketMq安装包下载地址：https://archive.apache.org/dist/rocketmq/4.7.0/rocketmq-all-4.7.0-bin-release.zip将压缩包上传服务器上，解压缩文件压缩包到/opt/rocketmq

# unzip rocketmq-all-4.7.0-source-release.zip

2)    开放端口
开放端口9876 ：
# firewall-cmd --zone=public --add-port=9876/tcp --permanent
开放端口10911：
# firewall-cmd --zone=public --add-port=10911/tcp --permanent

3)    修改配置文件

`如果内存空间较小考虑如下操作，否则跳过`
默认启动占用内存较大，修改jvm配置
# vim /opt/rocketmq/rocketmq-all-4.7.0-bin-release/bin/runserver.sh
将大小修改为如下图:

# vim /opt/rocketmq/rocketmq-all-4.7.0-bin-release/bin/runbroker.sh
将大小修改为如下图:

修改其他配置项
# cd /opt/rocketmq/rocketmq-all-4.7.0-bin-release/conf
# vim broker.conf
添加namesrvAddr 值为本机ip:9876
添加brokerIP1值为本机ip

4)    启动name server
启动命令 # nohup sh bin/mqnamesrv &
查看启动日志# tail -f ~/logs/rocketmqlogs/namesrv.log
出现 The Name Server boot success... 表示启动成功
5)    启动broke
执行启动命令:
# nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
查看启动日志:
# tail -f ~/logs/rocketmqlogs/broker.log
出现 The broker[%s, ip:port] boot success... 表示启动成功
6)    添加topic
# cd /opt/rocketmq/rocketmq-all-4.7.0-bin-release/bin
# sh mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t easytong_acc
6)    添加consumer group
# sh mqadmin updateSubGroup -n localhost:9876 -c DefaultCluster -g easytong_acc_change