Mac M1芯片 搭建RocketMQ_rocketmq m1

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
1

把下面代码复制进去,记得把 rocketmq目录地址 修改为你下载的rocketmq目录
如: export ROCKETMQ_HOME=/Users/xxx/software/rocketmq-4.9.3

export ROCKETMQ_HOME=rocketmq目录地址
export PATH=$PATH:$ROCKETMQ_HOME/bin
1
2

配置完成之后需重新加载配置文件

source .bash_profile
1

3、启动路由

（配置第二步可忽略:cd到bin目录）

//启动
nohup sh mqnamesrv &   
// 查看namaserver日志
tail -f ~/logs/rocketmqlogs/namesrv.log   
 
#显示以下内容代表启动成功
INFO main - The Name Server boot success
1
2
3
4
5
6
7

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
1
2
3
4
5
6
7
8

5.关闭rocketmq（需关闭MQ时使用）

//停止 broker
sh mqshutdown broker
 
//停止 nameserver
sh mqshutdown namesrv
1
2
3
4
5

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包

进入路径 \rocketmq-externals-rocketmq-console-1.0.0\rocketmq-console
打开命令控制台（按住shift键，鼠标右键）//或者可以用idea打开项目进行打包。
执行命令（跳过测试文件）

 mvn clean package -Dmaven.test.skip=true 
1

6.4启动jar包

 java -jar jar包路径
1

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
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22