前往小程序，Get更优阅读体验！
立即前往
文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
首页
学习
活动
专区
工具
TVP最新优惠活动
返回腾讯云官网
社区首页 >专栏 >RocketMQ本地集群配置

RocketMQ本地集群配置

作者头像
青山师
发布于 2023-05-05 19:14:31
3830
发布于 2023-05-05 19:14:31
举报
文章被收录于专栏：IT当时语_青山师_JAVA技术栈IT当时语_青山师_JAVA技术栈IT当时语_青山师_JAVA技术栈

RocketMQ本地集群配置

更多完整的配置参数参考

修改NameServer默认端口达到本地集群配置

conf目录下新建一个配置文件conf/namesrv.properties，文件内容为：

listenPort=2058

使用 mqnamesrv -c ../conf/namesrv.properties 指定nameserver配置文件，示例：

PS E:\111softwares\rocketmq-all-4.4.0-bin-release\bin> .\mqnamesrv -c ../conf/namesrv.properties
"set java env ok."
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
load config properties file OK, ../conf/namesrv.properties
The Name Server boot success. serializeType=JSON

配置Broker本地集群

./mqbroker -n localhost:9876 -c ../conf/2m-2s-sync/broker-a.properties

在conf/broker-*.properties配置文件中指定nameserver：

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
autoCreateTopicEnable=true
namesrvAddr=localhost:9876;localhost:2058
listenPort=10911

2主2从同步(2m-2s-sync)集群配置

2m-2s-sync目录下：

第一个主从节点

broker-a.properties
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=localhost:9876;localhost:2058
listenPort=10911
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/usr/local/rocketmq/store
#commitLog存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
#abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
broker-a-s.properties
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=localhost:9876;localhost:2058
listenPort=20911
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/usr/local/rocketmq/as/store
#commitLog存储路径
storePathCommitLog=/usr/local/rocketmq/as/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/usr/local/rocketmq/as/store/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/as/store/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/as/store/checkpoint
#abort 文件存储路径
abortFile=/usr/local/rocketmq/as/store/abort
broker-b.properties
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=localhost:9876;localhost:2058
listenPort=30911
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/usr/local/rocketmq/bm/store
#commitLog存储路径
storePathCommitLog=/usr/local/rocketmq/bm/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/usr/local/rocketmq/bm/store/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/bm/store/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/bm/store/checkpoint
#abort 文件存储路径
abortFile=/usr/local/rocketmq/bm/store/abort
broker-b-s.properties
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=localhost:9876;localhost:2058
listenPort=40911
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#存储路径
storePathRootDir=/usr/local/rocketmq/bs/store
#commitLog存储路径
storePathCommitLog=/usr/local/rocketmq/bs/store/commitlog
#消费队列存储路径
storePathConsumeQueue=/usr/local/rocketmq/bs/store/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/bs/store/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/bs/store/checkpoint
#abort 文件存储路径
abortFile=/usr/local/rocketmq/bs/store/abort

在bin目录下分别执行，依次启动2主2从集群的Broker：

./mqbroker -n localhost:9876;localhost:2058 -c ../conf/2m-2s-sync/broker-a.properties
./mqbroker -n localhost:9876;localhost:2058 -c ../conf/2m-2s-sync/broker-a-s.properties
./mqbroker -n localhost:9876;localhost:2058 -c ../conf/2m-2s-sync/broker-b.properties
./mqbroker -n localhost:9876;localhost:2058 -c ../conf/2m-2s-sync/broker-b-s.properties
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2019-05-06，如有侵权请联系 cloudcommunity@tencent.com 删除
文件存储
存储
rocketmq
集群
配置

本文分享自 作者个人站点/博客 前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ，欢迎热爱写作的你一起参与！

文件存储
存储
rocketmq
集群
配置
评论
登录后参与评论
0 条评论
热度
最新
登录 后参与评论
推荐阅读
LV.
文章
0
获赞
0
目录
  • RocketMQ本地集群配置
    • 修改NameServer默认端口达到本地集群配置
      • 配置Broker本地集群
        • 2主2从同步(2m-2s-sync)集群配置
          • 第一个主从节点
      相关产品与服务
      文件存储
      文件存储（Cloud File Storage，CFS）为您提供安全可靠、可扩展的共享文件存储服务。文件存储可与腾讯云服务器、容器服务、批量计算等服务搭配使用，为多个计算节点提供容量和性能可弹性扩展的高性能共享存储。腾讯云文件存储的管理界面简单、易使用，可实现对现有应用的无缝集成；按实际用量付费，为您节约成本，简化 IT 运维工作。
      产品介绍产品文档
      精选特惠 用云无忧
      领券

      腾讯云开发者

      扫码关注腾讯云开发者

      扫码关注腾讯云开发者

      领取腾讯云代金券

      热门产品

      热门推荐

      更多推荐

      Copyright © 2013 - 2024 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

      深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

      腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号 | 京公网安备号11010802020287

      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档

      Copyright © 2013 - 2024 Tencent Cloud.

      All Rights Reserved. 腾讯云 版权所有

      登录 后参与评论