一、前言
在安装 RocketMQ 前需要确保 JDK 已安装并正确配置环境变量
二、下载安装
1.下载
下载 | RocketMQ
2.安装
# 打开存放目录
cd /usr/local
# 创建目录
mkdir rocketMQ
# 进入目录
cd rocketMQ
# 把下载的压缩包上传到 rocketMQ 目录中
# 解压
$ unzip rocketmq-all-5.0.0-bin-release.zip
# 进入 rocketMq 目录中
$ cd rocketmq-all-5.0.0-bin-release
3.配置环境变量
vim /etc/profile
配置如下:
# rocketmq 安装目录
export ROCKETMQ_HOME=/opt/rocketmq/rocketmq-all-5.0.0-bin-release
# 客户端NameServer的地址
export NAMESRV_ADDR=localhost:9876
# 将 rocketmq 环境变量加入到 PATH中
export PATH=$ROCKETMQ_HOME/bin:$PATH
刷新配置
source /etc/profile
4.修改bin目录下配置
4.1 修改runbroker.sh
cd /usr/local/rocketMQ/rocketmq-all-5.0.0-bin-release/bin
vim runbroker.sh
原始数值:
JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=16g"
修改数值:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=128m"
4.2 修改runserver.sh
vim runserver.sh
原始数值:
JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
修改数值:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
5.启动服务
# 进入 rocketMQ 安装目录,我的安装目录如下
cd /opt/rocketmq/rocketmq-all-5.0.0-bin-release/
5.1 启动namesrv
nohup sh bin/mqnamesrv &
# 出现忽略输入并把输出追加到"nohup.out" 直接回车即可# 查看是否启动成功
tail nohup.out
# 提示 The Name Server boot success... 启动成功
5.2 启动 broker
nohup sh bin/mqbroker &
### 验证broker是否启动成功
tail nohup.out
# The broker[broker-a,192.169.1.2:10911] boot success...# 提示 The broker[broker-a,192.169.1.2:10911] boot success...启动成功,
未成功可以关闭防火墙再操作 systemctl stop firewalld
5.3 使用 jps 命令查看是否启动成功
jps
6、测试
# 发送消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# SendResult [sendStatus=SEND_OK, msgId= ...# 接收消息
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
# ConsumeMessageThread_%d Receive New Messages: [MessageExt...
生产者
消费者
三、卸载RocketMQ
# 查询rocketmq进程
ps -ef | grep rocketmq
# kill 进程
kill -9 进程id# 回到安装目录
cd /usr/local/
# 删除rocketMQ目录
四、控制台搭建
在【下载 | RocketMQ】拉到最下方,下载 RocketMQ Dashboard
解压后使用开发工具打开,配置好maven 工具,然后修改配置 rocketmq.config.namesrvAddr
使用 maven 插件进行打包:
在Linux 系统中执行以下命令启动 rocketmq-dashboard
:
java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar
用自己服务器ip+8081(上述的端口我改了8081,默认是8080)访问控制台就可以了