RocketMQ 控制台

RocketMQ 控制台 是一个用于管理 RocketMQ 的工具，它提供有关客户端和应用程序事件和性能的各种统计信息，并支持可视化工具来替换命令行操作，例如主题配置和代理管理。

简介

功能概述

控制台	功能
OPS	修改 nameserver 地址；使用 VIPChannel
控制台	检查代理、主题消息量
集群	集群分布、代理配置、运行时信息
主题	搜索、过滤、删除、更新/添加主题、消息路由、发送消息、重置消费点
消费者	搜索、删除、添加/更新消费者组、终端、消费详情、配置
消息	消息记录、私信、消息跟踪等消息详情

操作面板：

快速入门

系统要求：

1. Linux/Unix/Mac
2. 64 位 JDK 1.8+
3. Maven 3.2.x
4. 启动 RocketMQ

网络配置：

1. 云服务器可以远程访问或本地虚拟机可以 PING 外网
2. rocketmq 配置文件 broker.conf / broker-x.properties 设置 nameserver 的地址和端口。
3. 使用配置文件启动代理

1. Docker 镜像安装

① 安装 docker 并拉取 rocketmq-dashboard 镜像

docker pull apacherocketmq/rocketmq-dashboard:latest

② 在 docker 容器中运行 rocketmq-dashboard

docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=127.0.0.1:9876" -p 8080:8080 -t apacherocketmq/rocketmq-dashboard:latest

提示

将 namesrv.addr:port 替换为 rocketmq 中配置的 nameserver 地址和端口

1. 打开端口号：8080、9876、10911、11011

• 云服务器：设置安全组访问规则
• 本地虚拟机：关闭防火墙，或 -add-port

2. 源码安装

源码地址：apache/rocketmq-dashboard

下载、解压缩，并导航到源代码目录 rocketmq-dashboard-master/

① 编译 rocketmq-dashboard

mvn clean package -Dmaven.test.skip=true

② 运行 rocketmq-dashboard

java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar

提示

Started App in x.xxx seconds (JVM running for x.xxx) ，表示启动成功。

浏览器页面访问：namesrv.addr:8080

关闭 rocketmq-dashboard : ctrl + c

重启：执行 ②

提示：下载的源代码需要上传到 Linux 系统进行编译，本地编译可能会返回错误

教程

1. 创建主题-主题

主题 > 添加/更新

2. 创建消费者组-消费者

消费者 > 添加/更新

3. 重置消费偏移量

主题 > 重置消费者偏移量

提示

• 集群消费支持重置消费偏移量，但广播模式不支持。
• 如果消费者不在线，则无法重置消费偏移量。

4. 扩展主题队列

主题 > 主题配置

5. 扩展代理

• 要安装和部署一个与当前集群具有相同 nameserver 地址的新代理

  

• 要更新主题的 BROKER_NAME

  主题 > 添加/更新 > BROKER_NAME

6. 发送消息

• 要向特定主题发送消息

  主题 > 发送消息

  

• 发送结果