源本科技 | 码上会

logo
源本科技 码上会
一站式数字化转型技能学习平台

分布式消息队列 RocketMQ 可视化管理

2026/05/30
2
0

引言

RocketMQ Dashboard 是 RocketMQ 的官方可视化管控平台，提供客户端与应用程序的事件追踪、性能指标统计，支持以图形化界面替代命令行操作，完成 Topic 配置、Broker 管理、消息查询等核心运维工作

功能概述

面板

功能

运维

修改 NameServer 地址；配置 VIPChannel；系统参数管理；安全设置

驾驶舱

查看 Broker、Topic 消息量；监控 TPS、消息延迟、堆积情况；集群健康度概览

集群

集群分布拓扑；Broker 配置与运行信息；节点状态监控；存储容量分析

主题

搜索、筛选、删除、更新 / 新增主题；消息路由查看；发送测试消息；重置消费位点；权限配置

消费者

搜索、删除、新增 / 更新消费者组；终端连接管理；消费进度追踪；消费模式配置

消息

消息记录查询；消息轨迹追踪；死信消息处理；消息重试管理；消息内容查看

Docker Compose

  • 主要新增了 Dashboard 配置

services:
  namesrv:
    image: apache/rocketmq:5.3.2
    container_name: rmqnamesrv
    ports:
      - 9876:9876
    networks:
      - rocketmq
    command: sh mqnamesrv
    restart: always

  broker:
    image: apache/rocketmq:5.3.2
    container_name: rmqbroker
    ports:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    depends_on:
      - namesrv
    networks:
      - rocketmq
    command: sh mqbroker -n rmqnamesrv:9876
    restart: always

  proxy:
    image: apache/rocketmq:5.3.2
    container_name: rmqproxy
    ports:
      - 8080:8080
      - 8081:8081
    environment:
      - NAMESRV_ADDR=rmqnamesrv:9876
    depends_on:
      - broker
      - namesrv
    networks:
      - rocketmq
    restart: on-failure
    command: sh mqproxy

  # 新增 Dashboard 配置
  dashboard:
    image: apacherocketmq/rocketmq-dashboard:2.1.0
    container_name: rmqdashboard
    ports:
      - 9090:8082
    environment:
      - JAVA_OPTS=-Drocketmq.namesrv.addr=rmqnamesrv:9876 -Drocketmq.config.loginRequired=false
      - ROCKETMQ_DASHBOARD_ROCKETMQ_SERVERS=http://rmqproxy:8081
    depends_on:
      - namesrv
      - proxy
    networks:
      - rocketmq
    restart: always

networks:
  rocketmq:
    driver: bridge

启动

docker compose up -d

验证

docker compose ps

访问

  • 在浏览器中输入以下地址（替换为你的服务器 IP）：

http://192.168.203.200:9090

核心面板

运维面板

  • 修改 NameServer 地址：在运维面板输入新的 NameServer 地址（格式：ip:port），支持多个地址用分号分隔

  • VIPChannel 配置：勾选启用 VIPChannel，提高消息传输安全性

  • 安全设置：

    • 开启 / 关闭登录认证（需重启 Dashboard 生效）

    • 配置 ACL 权限，设置 AccessKey/SecretKey

    • 管理 IP 访问白名单，限制 Dashboard 访问范围

驾驶舱面板

  • 实时监控：查看集群 TPS、消息延迟、堆积总量等核心指标

  • 资源分布：直观展示各 Broker 节点的消息存储、磁盘使用情况

  • 告警中心：查看系统告警信息，支持自定义告警规则

  • 操作建议：定期查看驾驶舱，当消息堆积超过阈值时及时排查消费者问题

集群面板

  1. 集群概览：查看集群节点分布、Broker 角色（Master/Slave）、版本信息

  2. Broker 详情：

    • 点击 Broker 名称进入详情页，查看运行参数、配置信息

    • 监控 Broker 内存、CPU、磁盘 I/O 等系统指标

    • 查看 Topic 分布、消息存储路径、日志位置

  3. 配置管理：支持在线修改 Broker 部分运行参数（需重启生效）

主题面板

  1. 主题管理：

    • 搜索 / 筛选 Topic，支持按名称、集群、Broker 过滤

    • 新增 Topic：输入名称、选择集群、设置读写队列数

    • 更新 Topic：调整队列数、权限配置

    • 删除 Topic：需先确认无消费者订阅，避免业务影响

  2. 消息操作：

    • 消息路由：查看 Topic 在各 Broker 上的队列分布

    • 发送测试消息：输入消息内容、Tag、Key，测试 Topic 可用性

    • 重置消费位点：选择消费者组，设置重置策略（按时间、偏移量）

  3. 权限配置：为 Topic 设置读写权限，配合 ACL 控制访问范围

消费者面板

  1. 消费者组管理：

    • 搜索 / 筛选消费者组，查看组内消费者实例数量

    • 新增消费者组：输入组名、选择集群、设置消费模式

    • 删除消费者组：需先停止所有消费者实例

  2. 消费详情：

    • 查看消费进度：各队列的消费偏移量、堆积量

    • 终端管理：查看消费者客户端 IP、版本、连接状态

    • 消费模式切换：集群消费 / 广播消费（需重启消费者生效）

  3. 问题排查：

    • 识别消费失败的消息，查看失败原因

    • 重置消费位点，重新消费异常消息

消息面板

  1. 消息查询：

    • 按 Topic、消息 ID、Key、时间范围查询消息

    • 查看消息内容、发送时间、存储位置、消费状态

  2. 消息轨迹：

    • 输入消息 ID，追踪消息从生产到消费的完整路径

    • 查看各节点处理时间、状态，定位延迟或丢失问题

  3. 死信处理：

    • 查看死信队列中的消息，分析消费失败原因

    • 重新发送死信消息到原 Topic，或转移至其他 Topic 处理

  4. 消息重试：管理消费者重试队列，设置重试策略和最大重试次数