首页
学习
活动
专区
圈层
工具
发布
社区首页 >专栏 >034. RocketMQ 架构方案及角色详解

034. RocketMQ 架构方案及角色详解

作者头像
山海散人
发布2021-03-03 10:55:02
发布2021-03-03 10:55:02
4480
举报
文章被收录于专栏:山海散人技术山海散人技术

1. RocketMQ 角色介绍


四个角色
  • Producer:消息生产者
  • Consumer:消费者
  • Broker:MQ 服务,负责接收、分发消息
  • NameServer:负责 MQ 服务之间的协调

2. RocketMQ 架构方案


NameServer Cluster
  • NameServer 提供轻量级服务发现和路由。
  • 每个名称服务器记录完整的路由信息,提供相应的读写服务,并支持快速存储扩展。

3. RocketMQ 集群部署配置


Broker 配置文件说明
代码语言:javascript
复制
# 所属集群名字
brokerClusterName=DefaultCluster
# broker 名字,注意此处不同的配置文件填写的不一样
brokerName=broker-a|broker-b
# 0 表示 Master,>0 表示 Slave
brokerId=0
# nameServer 地址,分号分割
namesrvAddr=10.10.1.31:9876;10.10.1.32:9876
# 在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数
defaultTopicQueueNums=4
# 是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true
# 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true
# Broker 对外服务的监听端口
listenPort=10911
# 删除文件时间点,默认凌晨 4 点
deleteWhen=04
# 文件保留时间,默认 48 小时
fileReservedTime=120
# commitLog 每个文件的大小默认 1G
mapedFileSizeCommitLog=1073741824
# ConsumeQueue 每个文件默认存 30w 条,根据业务情况调整
mapedFileSizeConsumeQueue=300000
# destroyMapedFileIntervalFarcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
# 存储路径
storePathRootDir=/usr/local/alibaba-rocketmq/store
# commitLog 存储路径
storePathCommitLog=/usr/local/alibaba-rocketmq/store/commitlog
# 消费队列存储路径
storePathConsumeQueue=/usr/local/alibaba-rocketmq/store/consumequeue
# 消费索引存储路径
storePathIndex=/usr/local/alibaba-rocketmq/store/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/alibaba-rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/usr/local/alibaba-rocketmq/store/abort
# 限制的消息大小
maxMessageSize=65536
# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
# - ASYNC_MASTER 异步复制 Master
# - SYNC_MASTER 同步双写 Master
# - SLAVE
brokerRole=ASYNC_MASTER
# 刷盘方式
# - ASYNC_FLUSH 异步刷盘
# - SYNC_FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH
# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
pullMessageThreadPoolNums=128
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020/07/16 ,如有侵权请联系 cloudcommunity@tencent.com 删除

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

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

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 1. RocketMQ 角色介绍
    • 四个角色
  • 2. RocketMQ 架构方案
    • NameServer Cluster
  • 3. RocketMQ 集群部署配置
    • Broker 配置文件说明
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档