RocketMQ5.0 搭建 Name Server And Broker+Proxy 同进程部署、搭建RocketMQ控制台图形化界面

前言

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

安装启动

二进制包安装启动

img

找到 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 管理等命令行操作。

功能概览

下载

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直接运行

img

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

img

绑定 name server

img

输入我们启动的 name server 地址 默认端口 9876

最后

本期结束咱们下次再见👋~

🌊 关注我不迷路，如果本篇文章对你有所帮助，或者你有什么疑问，欢迎在评论区留言，我一般看到都会回复的。大家点赞支持一下哟~ 💗

我正在参与2023腾讯技术创作特训营第二期有奖征文，瓜分万元奖池和键盘手表

输入图片说明