RocketMQ5.0中的几个角色NameServer、Broker 和 Proxy,它们的作用如下:
总之,NameServer、Broker 和 Proxy 都是 RocketMQ 分布式消息代理服务器的重要组成部分,它们共同协作,实现消息的传输和处理。
在5.0版本中 Proxy 和 Broker 可以根据实际诉求可以分为 Local 模式和 Cluster 模式。
没有特殊的需求或者遵循从早期版本平滑升级的思路,可以选用Local模式。I
系统要求
64位操作系统,推荐 Linux/Unix/macOS
64位 JDK 1.8+
下载源码编译(Apache RocketMQ 5.1.4的源码包): https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1.4-source-release.zip
下载二进制包(可直接运行): https://dist.apache.org/repos/dist/release/rocketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip
找到 bin 目录下的 mqnamesrv 和 mqbroker,分别启动 NameServer 和 Broker
### name server 默认端口 9876
nohup sh bin/mqnamesrv &
### broker server 绑定name server
nohup sh bin/mqbroker -n localhost:9876 &
这里使用MacOS环境源码包编译安装
解压源码包
unzip rocketmq-all-5.1.4-source-release.zip
编译源码包
cd rocketmq-all-5.1.4-source-release/
mvn -Prelease-all -DskipTests -Dspotbugs.skip=true clean install -U
编译完成后,进入
distribution/target/rocketmq-5.1.4/rocketmq-5.1.4
目录
cd distribution/target/rocketmq-5.1.4/rocketmq-5.1.4
nohup sh bin/mqnamesrv &
查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log
nohup sh bin/mqbroker -n localhost:9876 --enable-proxy &
查看日志
验证broker是否启动成功, 比如, broker的ip是192.168.1.2 然后名字是broker-a
tail -f ~/logs/rocketmqlogs/proxy.log
RocketMQ Dashboard
是 RocketMQ 的管控利器,为用户提供客户端和应用程序的各种事件、性能的统计信息,支持以可视化工具代替 Topic 配置、Broker 管理等命令行操作。
面板 | 功能 |
---|---|
运维 | 修改nameserver 地址; 选用 |
驾驶舱 | 查看 broker, topic 消息量 |
集群 | 集群分布,broker 配置、运行信息 |
主题 | 搜索、筛选、删除、更新/新增主题,消息路由,发送消息,重置消费位点 |
消费者 | 搜索、删除、新增/更新消费者组,终端,消费详情,配置 |
消息 | 消息记录,私信消息,消息轨迹等消息详情 |
64位操作系统,推荐Linux/Unix/Mac;
64位JDK 1.8+;
Maven 3.2.x;
Idea 直接运行
使用git克隆项目
git clone https://github.com/apache/rocketmq-dashboard.git
idea打开该项目找到src直接运行
imgMaven spring-boot 运行
mvn spring-boot:run
Maven build and run
cd rocketmq-dashboard
mvn clean package -Dmaven.test.skip=true
java -jar target/rocketmq-dashboard-1.0.1-SNAPSHOT.jar
访问端口
application.properties
配置文件 更改端口
可前往 http://localhost:8080/ 访问 RocketMQ Dashboard
输入我们启动的 name server 地址 默认端口 9876
本期结束咱们下次再见👋~
🌊 关注我不迷路,如果本篇文章对你有所帮助,或者你有什么疑问,欢迎在评论区留言,我一般看到都会回复的。大家点赞支持一下哟~ 💗
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。