1、安装前准备
Java环境1.8+
Maven环境3.5+
2、下载RocketMQ
官方下载地址：https://archive.apache.org/dist/rocketmq/
选择最新的版本
选择已经编译好的解压包进行下载
3、安装RocketMQ
创建文件夹,进入文件价
mkdir /opt/rocketmq && cd /opt/rocketmq
上传第二步下载的解压包，并解压
unzip rocketmq-all-5.1.2-bin-release.zip
没有unzip命令，可先安装
yum install -y unzip
启动rocketmq默认占用的内存是很大的，但是我们用不到那么多，可以进到配置文件修改。
vim /opt/rocketmq/rocketmq-all-5.1.2-bin-release/bin/runserver.sh
修改内存：JAVA_OPT="$ -server后面的参数改为1G(可根据自身需求进行调整)
同样broker也要进行修改
vim /opt/rocketmq/rocketmq-all-5.1.2-bin-release/bin/runbroker.sh
修改内存：JAVA_OPT="$ -server后面的参数改为1G(可根据自身需求进行调整)
在云服务器的安全组或者防火墙中添加规则，增加9876,10911,10909三个端口号
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --zone=public --add-port=10911/tcp --permanent
firewall-cmd --zone=public --add-port=10909/tcp --permanent
4、安装RocketMq-dashboard
进入目录并下载RocketMq-dashboard源码
cd /opt && git clone https://github.com/apache/rocketmq-dashboard.git
没有unzip命令，可先安装
yum install -y git
下载完后进入目录
cd rocketmq-dashboard/
Maven打包
mvn clean package -Dmaven.test.skip=true
启动服务
nohup java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar &
如果提示install-node-and-yarn下载失败，大概率是国内访问不了Node官方源，切换成Node的国内源
编辑maven配置vim /opt/rocketmq-dashboard/pom.xml找到此位置并加上国内源地址
<downloadRoot>https://npmmirror.com/mirrors/node/</downloadRoot>
打开页面
地址: http://host:8080
5、启动RocketMQ服务
进入rocketmq目录
cd /opt/rocketmq/rocketmq-all-5.1.2-bin-release
启动服务
nohup sh bin/mqnamesrv &
nohup sh bin/mqbroker -n localhost:9876 &
# 指定conf配置文件
nohup sh mqbroker -n localhost:9876 -c /usr/local/rocketmq/conf/broker.conf
# 启动broker时加上自动创建topic的参数其中autoCreateTopicEnable=true表示自动创建topic
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true > ../broker.log &
关闭服务
# 关闭NameServer
sh bin/mqshutdown namesrv
# 关闭Broker
sh bin/mqshutdown broker
6、测试RocketMQ
接收消息
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
发送消息
# 1.设置环境变量
export NAMESRV_ADDR=localhost:9876
# 2.使用安装包的Demo发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
评论区