前言
RocketMQ5.0中的几个角色NameServer、Broker 和 Proxy，它们的作用如下：
- NameServer: NameServer 是 RocketMQ 的名称服务器，负责管理消息队列和消费者组。
- Broker：Broker 是 RocketMQ 的消息代理服务器，负责接收、处理和存储消息。
- Proxy: Proxy 是 RocketMQ 的代理服务器，用于扩展消息代理服务器的性能和容量。Proxy 可以将消息路由 到多个 Broker 上，以实现负载均衡和容错。Proxy 还提供了一些接口，如队列管理、消费者管理、配置管理 等，供客户端使用。
总之，NameServer、Broker 和 Proxy 都是 RocketMQ 分布式消息代理服务器的重要组成部分，它们共同协作，实现消息的传输和处理。
在5.0版本中 Proxy 和 Broker 可以根据实际诉求可以分为 Local 模式和 Cluster 模式。
没有特殊的需求或者遵循从早期版本平滑升级的思路，可以选用Local模式。I
- 在 Local 模式下，Broker 和 Proxy 是同进程部署，只是在原有 Broker 的配置基础上新增 Proxy 的简易配置就可以运行。
- 在 Cluster 模式下，Broker 和 Proxy 分别部署，即在原有的集群基础上，额外再部署 Proxy 即可。
RocketMQ5.0 搭建
系统要求 64位操作系统，推荐 Linux/Unix/macOS 64位 JDK 1.8+
下载安装Apache RocketMQ
下载源码编译(Apache RocketMQ 5.1.4的源码包)
下载二进制包(可直接运行
安装启动
二进制包安装启动
找到 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
启动NameServer
nohup sh bin/mqnamesrv &
查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log
启动Broker+Proxy
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控制台图形化界面
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直接运行
Maven 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 配置文件 更改端口
访问 RocketMQ Dashboard
可前往 http://localhost:8080/ 访问 RocketMQ Dashboard
绑定 name server
输入我们启动的 name server 地址 默认端口 9876
最后
本期结束咱们下次再见👋~
🌊 关注我不迷路，如果本篇文章对你有所帮助，或者你有什么疑问，欢迎在评论区留言，我一般看到都会回复的。大家点赞支持一下哟~ 💗
