在 macOS 上安装部署RocketMQ 以及 控制台进行前端访问


头像
眷恋
原创
发布时间: 2026-05-22 15:21:38 | 阅读数 0收藏数 0评论数 0
封面
这个项目主要演示了如何在 macOS 上安装和运行 Apache RocketMQ,并用控制台来管理消息队列。整个过程很直观:先下载 RocketMQ 二进制包、调整一些配置,然后依次启动 NameServer 和 Broker,最后启动控制台。通过控制台,你可以直接看到消息的发送和消费情况,还能管理生产者、消费者和主题。整个过程让你快速上手 RocketMQ,既能做消息测试,也能直观地掌握队列的运行状态,非常适合想在本地环境练习或熟悉消息队列的小伙伴。
1

安装前提条件

Java Development Kit (JDK): RocketMQ 需要 JDK 1.8 或更高版本。 RocketMQ控制台需要jdk17

  1. 确认安装: 打开终端,运行 java -version。
  2. 如果未安装,请从 Oracle JDK 或 OpenJDK 下载并安装合适的 macOS 版本。


2

下载

访问 Apache RocketMQ 官方下载页面: 下载地址为https://rocketmq.apache.org/download/

我们点击后方的 Binary 下载 下载二进制包

大家可以直接在附件中自行下载 官网下的会很慢

ZIP
rocketmq-all-5.5.0-bin-release.zip
96.89MB
3

修改配置

  1. 把压缩包移动到你们的存放路径 然后解压
  2. 解压之后进入到rocketmq的目录下
  3. 然后调整 JVM 内存设置 (可选): macOS(尤其是开发机)可能没有足够的空闲内存运行 RocketMQ 默认的较大堆设置
  4. 输入命令 vim bin/runserver.sh 然后找到 JAVA_OPT="${JAVA_OPT} -server -Xms4g -Xmx4g -Xmn2g 的位置把他调小 如图3 图4所示
  5. 输入vi bin/runbroker.sh 同理找到包含 -Xms4g -Xmx4g ,改为较小的值(例如 -Xms512m -Xmx512m) 如图5

4

启动

启动 NameServer

  1. NameServer 是 RocketMQ 的服务注册与发现中心,必须首先启动。
  2. 输入命令 nohup sh bin/mqnamesrv & (后面加&代表在后台运行。
  3. 可以通过查看日志判断启动情况 tail -f ~/logs/rocketmqlogs/namesrv.log



启动 Broker

  1. Broker 是存储和传输消息的核心组件,它需要连接到已运行的 NameServer。
  2. 输入命令 nohup sh bin/mqbroker -n localhost:9876 &
  3. 可以通过查看日志判断启动情况 tail -f ~/logs/rocketmqlogs/broker.log



5

构建RocketMQ 控制台

  1. https://github.com/apache/rocketmq-dashboard 这个是github的官方地址 去官方把这个项目下载下来
  2. 然后移动到你存放的地址进行解压
  3. 然后如图3 cd进入到这个项目里面
  4. 然后输入命令 mvn clean package -DskipTests 进行项目构建。确保您的系统已安装 Maven如图4 图5所示


6

启动RocketMQ 控制台

输入命令 java -jar target/rocketmq-dashboard-2.1.1-SNAPSHOT.jar --rocketmq.config.namesrvAddr=localhost:9876 后面的(2.1.1-SNAPSHO)有可能会有变化大家根据具体情况来


然后大家访问日志中的端口号就可以访问了 一般都是 8080

7

测试消费数据

  1. 如图1所示创建一个 Topic
  2. 发送消息:使用 RocketMQ 提供的工具类向 Topic 发送测试消息。进入 RocketMQ 安装目录,执行以下命令:
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
  1. 消费消息:使用以下命令消费测试消息:
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer


然后看看控制台有没有数据 如图

8

关闭RocketMQ


输入以下命令 进行关闭

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv


输入以下命令进行验证是否关闭成功

ps -ef | grep mqbroker
ps -ef | grep mqnamesrv
阅读记录0
点赞0
收藏0
禁止 本文未经作者允许授权,禁止转载
猜你喜欢
评论/提问(已发布 0 条)
头像
评论 评论
收藏 收藏
分享 分享
pdf下载 下载
pdf下载 举报