网站首页 > 博客文章 正文
RocketMQ 的持久化配置主要涉及到 Broker 的配置文件 broker.conf。以下是一些关键的配置项,用于控制 RocketMQ 的持久化行为:
1. 刷盘策略(FlushDiskType)
- flushDiskType=ASYNC_FLUSH:异步刷盘,消息写入到 PageCache 后立即返回成功状态,操作系统负责将数据刷写到磁盘。
- flushDiskType=SYNC_FLUSH:同步刷盘,消息写入到 PageCache 后,强制将数据刷写到磁盘后才返回成功状态。
2. 主从复制(BrokerRole)
- brokerRole=ASYNC_MASTER:异步复制的主节点,主节点写入消息后立即返回,从节点异步同步数据。
- brokerRole=SYNC_MASTER:同步复制的主节点,主节点写入消息后等待从节点同步完成才返回。
- brokerRole=SLAVE:从节点,用于数据备份。
3. 持久化配置示例
以下是一个 broker.conf 文件的示例,包含了持久化相关的配置:
# 是否允许 Broker 自动创建 Topic,建议线上设置为 false
autoCreateTopicEnable=true
# 是否允许 Broker 自动创建订阅组,建议线上设置为 false
autoCreateSubscriptionGroup=true
# Broker 的角色:ASYNC_MASTER, SYNC_MASTER, SLAVE
brokerRole=ASYNC_MASTER
# 刷盘策略:ASYNC_FLUSH, SYNC_FLUSH
flushDiskType=ASYNC_FLUSH
# 消息存储路径
storePathRootDir=/data/rocketmq/store
# CommitLog 存储路径
storePathCommitLog=/data/rocketmq/store/commitlog
# 消费队列存储路径
storePathConsumeQueue=/data/rocketmq/store/consumequeue
# 消息索引存储路径
storePathIndex=/data/rocketmq/store/index
# checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/data/rocketmq/store/abort
# 同步刷盘间隔时间,单位毫秒
flushIntervalCommitLog=1000
# 异步刷盘线程数
flushCommitLogTimed=false
# 消息到达一定数量时触发刷盘,与时间间隔配合使用
flushCommitLogLeastPages=4
# 消息到达一定大小触发刷盘,与时间间隔配合使用
flushCommitLogThoroughInterval=10000
# 主从复制相关配置
# 同步复制时,从节点向主节点拉取消息的最大间隔时间,单位毫秒
replicaWaitTimeMillsInSyncState=5000
# 主从复制时,消息复制的方式:SYNC, ASYNC
brokerId=0
# 主节点地址,从节点配置
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
请注意,以上配置只是一个示例,具体的配置需要根据你的实际部署环境和需求进行调整。在配置文件中,注释使用 # 开头。配置完成后,需要重启 Broker 服务以使配置生效。
- 上一篇: RocketMQ,如何处理消息积压问题
- 下一篇: RocketMQ集群搭建
猜你喜欢
- 2024-11-18 快速使用docker方式部署安装RocketMQ
- 2024-11-18 介绍新版RocketMQ v4.9.3 下载、安装、配置的完成过程
- 2024-11-18 docker-4:mac使用docker部署开发用rocketmq
- 2024-11-18 扩展RocketMQ 使其支持任意时间精度的消息延迟
- 2024-11-18 RocketMQ如何突破内网限制,实现内外网互通
- 2024-11-18 SpringBoot3.0 + RocketMq 构建企业级数据中台完结
- 2024-11-18 centos7安装部署RocketMQ分布式集群
- 2024-11-18 「转」Spring Cloud异步场景分布式事务怎样做?试试RocketMQ
- 2024-11-18 RocketMQ集群搭建
- 2024-11-18 RocketMQ,如何处理消息积压问题
你 发表评论:
欢迎- 08-06nginx 反向代理
- 08-06跨表插入连续的日期,sheetsname函数#excel技巧
- 08-06初中生也能学的编程,不走弯路,先用后学
- 08-06find命令的“七种武器”:远不止-name和-type
- 08-06恶意代码常见的编程方式
- 08-06kali2021ping 外网不通
- 08-06因为一个函数strtok踩坑,我被老工程师无情嘲笑了
- 08-06hadoop集群搭建详细方法
- 47℃nginx 反向代理
- 最近发表
- 标签列表
-
- ifneq (61)
- 字符串长度在线 (61)
- googlecloud (64)
- powershellfor (73)
- messagesource (71)
- plsql64位 (73)
- vueproxytable (64)
- npminstallsave (63)
- #NAME? (61)
- promise.race (63)
- 2019cad序列号和密钥激活码 (62)
- window.performance (66)
- qt删除文件夹 (72)
- mysqlcaching_sha2_password (64)
- nacos启动失败 (64)
- ssh-add (70)
- yarnnode (62)
- abstractqueuedsynchronizer (64)
- source~/.bashrc没有那个文件或目录 (65)
- springboot整合activiti工作流 (70)
- jmeter插件下载 (61)
- 抓包分析 (60)
- idea创建mavenweb项目 (65)
- qcombobox样式表 (68)
- pastemac (61)
本文暂时没有评论,来添加一个吧(●'◡'●)