前言
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的源码包): 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启动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.gitmvn 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
最后
本期结束咱们下次再见👋~
🌊 关注我不迷路，如果本篇文章对你有所帮助，或者你有什么疑问，欢迎在评论区留言，我一般看到都会回复的。大家点赞支持一下哟~ 💗
我正在参与2023腾讯技术创作特训营第二期有奖征文，瓜分万元奖池和键盘手表
