RocketMQ 5.0 本地源码启动Cluster模式指南-Toy模板网

这篇具有很好参考价值的文章主要介绍了RocketMQ 5.0 本地源码启动Cluster模式指南。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党

源码版本

这里选用最新的稳定版本5.0

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据

启动方式

目前5.0的架构发生了重大调整，添加了一层rocketmq-proxy,可以通过grpc的方式接入

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据
目前部署方式分为两种

Local 模式:由于 Local 模式下 Proxy 和 Broker 是同进程部署，Proxy本身无状态，因此和之前4.0版本的部署方式基本相同
Cluster 模式:在 Cluster 模式下，Broker 与 Proxy分别部署，我可以在 NameServer和 Broker都启动完成之后再部署 Proxy。

启动

1. 下载源码

源码地址: https://github.com/apache/rocketmq

下载完成后我们切换到最新稳定分支release-5.0.0版本

2. 启动NameServer

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据
在启动这个类的时候我们需要配置一下环境信息，不然会报错找不到环境变量

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据
主要是配置Environment variables
值为:
ROCKETMQ_HOME=****/rocketmq/distribution

填写指定到distribution路径即可

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据

注意这里我们的jdk版本要是jdk8，如果是高版本会启动失败，而且同时存在多个版本的jdk会有交叉编译bug
具体解决方案可以参考这里 https://www.morling.dev/blog/bytebuffer-and-the-dreaded-nosuchmethoderror/

启动成功后会输出如下log
rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据

3. 启动rocketmq-proxy+broker

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据

同上nameserver配置环境变量

rocketmq源码启动,消息中间件,# RocketMQ,java-rocketmq,rocketmq,大数据

ROCKETMQ_HOME=****/rocketmq/distribution
添加启动参数

org.apache.rocketmq.proxy.ProxyStartup
-n
127.0.0.1:9876
-bc
/Users/xx/Desktop/sofe/java/rocketmq/distribution/conf/2m-2s-async/broker-a.properties
-pm
Local