多元网站,做创业网站赚钱,网站备案快速,大学生怎么做网站大家好#xff0c;我是君哥。今天来分享怎样搭建 RocketMQ 集群。本文搭建集群使用的环境是 2 个云主机#xff0c;架构如下#xff1a;在 47.xx.xx.xx 和 39.xx.xx.xx 上分别部署一个 Name Server 和 Broker 主节点#xff0c;这里不搭建从节点。也就是官网介绍的 2m-nosl…大家好我是君哥。今天来分享怎样搭建 RocketMQ 集群。本文搭建集群使用的环境是 2 个云主机架构如下在 47.xx.xx.xx 和 39.xx.xx.xx 上分别部署一个 Name Server 和 Broker 主节点这里不搭建从节点。也就是官网介绍的 2m-noslave 构建模式。注意官网有三种配置模式2m-2s-sync、2m-2s-async、2m-noslave。这三种配置都是使用异步刷盘策略ASYNC_FLUSH。集群搭建成功后Broker 会向 Name Server 注册 Topic 路由信息Producer 和 Consumer 则从 Name Server 获取路由信息然后 Producer 根据路由信息向 Broker 发送消息Consumer 则根据路由信息从 Broker 拉取消息。1 准备工作 要安装 RocketMQ首先需要在云主机上安装 Java 环境Maven 环境。这里就不做详细介绍了。Java 和 Maven 环境安装好以后从官网下载最新版本地址如下https://dlcdn.apache.org/rocketmq/4.9.4/rocketmq-all-4.9.4-bin-release.zip下载完成后进行解压和编译执行如下命令 unzip rocketmq-all-4.9.4-source-release.zipcd rocketmq-all-4.9.4-source-release/mvn -Prelease-all -DskipTests clean install -Ucd distribution/target/rocketmq-4.9.4/rocketmq-4.9.4看到下图输出时编译成功:2 启动 2.1 启动 Name Server因为我的云主机内存比较小而 RocketMQ 默认启动 Name Server 需要的 JVM 堆内存默认是 4g所以需要修改默认堆内存。修改文件为rocketmq-all-4.9.4-source-release/distribution/target/rocketmq-4.9.4/rocketmq-4.9.4/bin/runserver.sh修改后的配置如下JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m修改完成后执行下面命令nohup sh bin/mqnamesrv 启动成功后nohup.out 文件中打印如下日志The Name Server boot success. serializeTypeJSON搭建好一台机器后用同样的方式搭建第二台机器。2.2 启动 Broker同样RocketMQ 启动 Broker 需要的 JVM 堆内存默认是 8g所以需要修改堆内存。修改文件为rocketmq-all-4.9.4-source-release/distribution/target/rocketmq-4.9.4/rocketmq-4.9.4/bin/runbroker.sh修改后的配置如下JAVA_OPT${JAVA_OPT} -server -Xms512m -Xmx512m创建 conf.properties 文件内容如下brokerClusterName MyTestCluster
brokerName broker-a
brokerId 0
deleteWhen 04
fileReservedTime 48
brokerRole ASYNC_MASTER
flushDiskType ASYNC_FLUSH
namesrvAddr127.0.0.1:9876;47.xx.xx.xx:9876配置好后启动 broker-a 节点启动 命令如下nohup bash bin/mqbroker -c conf/broker.properties Broker 启动成功后Name Server 的日志如下图用同样的方式启动 broker-bconf.properties 文件配置如下#集群名称
brokerClusterName MyTestCluster
#broker名称
brokerName broker-b
brokerId 0
#删除消息存储过期文件的时间为凌晨4点
deleteWhen 04
#未发生更新的消息存储文件的保留时长为48小时48小时后过期将会被删除
fileReservedTime 48
brokerRole ASYNC_MASTER
flushDiskType ASYNC_FLUSH
namesrvAddr127.0.0.1:9876;xx.xx.xx.xx:9876启动成功后执行 mqadmin 命令查看集群信息[rootrocketmq-4.9.4]# ./bin/mqadmin topicList -n 127.0.0.1:9876
MyTestCluster
RMQ_SYS_TRANS_HALF_TOPIC
BenchmarkTest
OFFSET_MOVED_EVENT
iZ8vbfyc7hfzygtpgapblyZ
TBW102
SELF_TEST_TOPIC
DefaultCluster
iZ2ze4m2ri7irk6au5mbfgZ
SCHEDULE_TOPIC_XXXX
DefaultCluster_REPLY_TOPIC
broker-b
broker-a
MyTestCluster_REPLY_TOPIC注意执行上面命令需要修改 bin/tools.sh 中的 JVM 参数配置如下JAVA_OPT${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize128m -XX:MaxMetaspaceSize128m3 dashboard 3.1 安装安装 dashboard需要编译源代码源码 github 地址如下https://github.com/apache/rocketmq-dashboard下载之后修改 application.yml 参数我这里只修改了 Name Server 地址rocketmq:config:namesrvAddrs:- 127.0.0.1:9876- 47.xx.xx.xx:9876然后执行 Maven 打包命令打出 jar 包mvn clean package -Dmaven.test.skiptrue打好 jar 包后上传到服务器执行下面命令启动java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar启动成功后输出下图的日志3.2 测试浏览器输入 http://39.xx.xx.xx:8080/ 界面如下:使用下面命令创建一个 Topic名字叫 MyTestTopicsh bin/mqadmin updateTopic -n 127.0.0.1:9876\;47.92.71.246:9876 -c MyTestCluster -t MyTestTopic这是可以在界面上看到创建的 Topic如下图:使用命令发送一条消息[rootrocketmq-4.9.4]# sh bin/mqadmin sendMessage -n 127.0.0.1:9876 -t MyTestTopic -p hello test message
#Broker Name #QID #Send Result #MsgId
broker-a 1 SEND_OK 7F000001D3C3339097527B50D1740000在界面上查看消息如下图4 总结 这篇文章主要讲述了 RocketMQ 集群的搭建希望能对大家理解 RocketMQ 有所帮助。
