RocketMQ Dashboard
RocketMQ Dashboard
是一个用于管理 RocketMQ 的工具,提供客户端和应用程序的事件和性能的各种统计信息,并支持可视化工具来替代命令行操作,如 Topic 配置和 Broker 管理。
简介
功能概览
仪表盘 | 功能 |
---|---|
运维 | 修改 nameserver 地址;使用 VIPChannel |
仪表盘 | 检查 broker、topic 消息量 |
集群 | 集群分布、broker 配置、运行时信息 |
Topic | 搜索、筛选、删除、更新/添加 Topic,消息路由、发送消息、重置消费点 |
Consumer | 搜索、删除、添加/更新消费组、终端、消费详情、配置 |
消息 | 消息记录、私有消息、消息追踪等消息详情 |
操作面板:
快速开始
系统要求:
- Linux/Unix/Mac
- 64位 JDK 1.8+
- Maven 3.2.x
- 启动 RocketMQ
网络配置:
- 云服务器可远程访问或本地虚拟机可 PING 外网
rocketmq
配置文件broker.conf / broker-x.properties
设置 nameserver 的地址和端口。- 使用配置文件启动 broker
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 地址和端口
- 开放端口号: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
提示
App started in x.xxx seconds (JVM running for x.xxx) ,表示启动成功。
浏览器页面访问:namesrv.addr:8080
关闭 rocketmq-dashboard
: ctrl + c
重新启动:执行 ②
提示:下载的源码需要上传到 Linux 系统进行编译,本地编译可能会返回错误
教程
1.创建 Topic-Topic
Topic >
ADD/UPDATE
2. 创建消费组-Consumer
Consumer >
ADD/UPDATE
3. 重置消费位点
Topic >
RESET CONSUMER OFFSET
提示
- 集群消费支持重置消费位点,但广播模式不支持。
- 如果消费者不在线,则无法重置消费位点。
4. 扩容 Topic 队列
Topic >
TOPIC CONFIG
5. 扩容 Broker
安装并部署与当前集群拥有相同 nameserver 地址的新 broker
更新 Topic 的
BROKER_NAME
Topic
>
ADD/UPDATE>
BROKER_NAME
6. 发送消息
向指定 Topic 发送消息
Topic
>
SEND MESSAGE发送结果