Mac M1芯片 搭建RocketMQ
RocketMQ需要启动三个组件
1、nameserver 路由中心,为整个MQ集群提供服务协调与治理
2、broker 提供消息的转发和存储功能
3、console 控制台面板工具
1、下载RocketMQ
https://rocketmq.apache.org/dowloading/releases/
选择 Binary: rocketmq-all-4.9.3-bin-release.zip
2.环境配置(可不配置,方便启动)
打开终端进入到根目录
编辑.bash_profile文件
vim .bash_profile
把下面代码复制进去,记得把 rocketmq目录地址 修改为你下载的rocketmq目录
如: export ROCKETMQ_HOME=/Users/xxx/software/rocketmq-4.9.3
export ROCKETMQ_HOME=rocketmq目录地址
export PATH=$PATH:$ROCKETMQ_HOME/bin
配置完成之后需重新加载配置文件
source .bash_profile
3、启动路由
(配置第二步可忽略:cd到bin目录)
//启动
nohup sh mqnamesrv &
// 查看namaserver日志
tail -f ~/logs/rocketmqlogs/namesrv.log
#显示以下内容代表启动成功
INFO main - The Name Server boot success
4. 启动broker
(配置第二步可忽略:cd到bin目录)
//启动
nohup sh mqbroker -n localhost:9876 &
// 查看broker日志
tail -f ~/logs/rocketmqlogs/broker.log
// 启动成功
The broker[TF012778.local, 10.50.62.53:10911] boot success
5.关闭rocketmq(需关闭MQ时使用)
//停止 broker
sh mqshutdown broker
//停止 nameserver
sh mqshutdown namesrv
6、下载console控制台面板
RocketMQ控制台安装
6.1 下载地址源码
https://github.com/apache/rocketmq-externals/tags
下载 rocketmq-externals-rocketmq-console-1.0.0 这个压缩包就行
解压压缩包备用
6.2 修改配置信息
进入rocketmq-externals\rocketmq-console\src\main\resources文件夹,打开application.properties进行配置,如下图
6.3 打成jar包
进入路径 C:\Users\wqf\Desktop\rocketmq-externals-rocketmq-console-1.0.0\rocketmq-console
打开命令控制台(按住shift键,鼠标右键)//或者可以用idea打开项目进行打包。
执行命令(跳过测试文件)
mvn clean package -Dmaven.test.skip=true
6.4启动jar包
java -jar jar包路径
web访问地址:http://127.0.0.1:8088/#/
1.查看帮助:在 mqadmin 下可以查看有哪些命令
1): 查看具体命令的使用 : sh mqadmin
2): sh mqadmin help 命令名称
2. 关闭nameserver和所有的broker:
sh mqshutdown namesrv
sh mqshutdown broker
3. 查看所有消费组group:
sh mqadmin consumerProgress -n 192.168.1.23:9876
注:-n,即配置的namesrvAddr参数
4. 查看指定消费组下的所有topic数据堆积情况:
sh mqadmin consumerProgress -n 192.168.1.23:9876 -g warning-group
5. 查看所有topic :
sh mqadmin topicList -n 192.168.1.23:9876
6. 查看topic信息列表详情统计
sh mqadmin topicstatus -n 192.168.1.23:9876 -t topicWarning
7. 新增topic
sh mqadmin updateTopic –n 192.168.1.23:9876 –c DefaultCluster –t topicWarning
注:-c,即配置的brokerClusterName参数;-t,topic
8. 删除topic
sh mqadmin deleteTopic –n 192.168.1.23:9876 –c DefaultCluster –t topicWarning
9、查询集群消息
sh mqadmin clusterList -n 192.168.1.23:9876