RocketMQ(4.8.0)——Broker 主从同步机制
Broker 主从同步机制 一、主从同步概述 Broker 有2种角色： Master：主要用于处理生产者、消费者的请求和存储数据。 Slave：从 Master 同步所有数据到本地。具体体现在以下2个方面 ...
原文：RocketMQ(4.8.0)——Broker 过期文件删除机制
Broker 过期文件删除机制 RocketMQ 中主要保存了 CommitLog Consume Queue Index File 三种数据文件。由于内存和磁盘都是有限的资源，Broker 不可能永久地保存所有数据，所以一些超过保存期限的数据会被定期删除。RocketMQ 通过设置数据过期时间来删除额外的数据文件，具体的实现逻辑是通过 D: rocketmq master store src m ...
2021-03-01 20:42 0 300 推荐指数：
相关推荐
RocketMQ(4.8.0)——Broker消息存储机制
Broker消息存储机制 RocketMQ 使用 CommitLog 文件将消息存储到磁盘上，那么 RocketMQ 存储消息到磁盘的过程是怎么样的呢? RocketMQ 首先将消息数据写入操作系统 PageCache，然后定时将数据刷入磁盘。 一、Broker 消息存储的流程是什么 ...
RocketMQ-存储机制-文件恢复&过期文件删除
broker过期文件删除机制 RocketMQ会每隔10秒执行文件清理任务 主要是删除commitlog和consumequeue文件 commitlog文件删除 触发过期文件删除的条件： 1）达到配置的时间点 2）磁盘用了超过85% 3）手动执行 ...
RocketMQ(4.8.0)——Broker 概述、启动和停止流程
Broker 概述、启动和停止流程 Broker 是 RocketMQ 体系中核心组件之一，存储是 Broker 的核心功能之一，决定整个 RocketMQ 体系的吞吐性能、可靠性和可用性。 一、Broker 概述 1.1 什么是 Broker Broker ...
rocketMQ 删除过期文件
commitLog 删除文件的策略指定时间到了，磁盘不足，人工删除，满足任一条件，判断文件是否过期或者磁盘严重不足（超过 85%），是则删除，一批次最多删除 10 个文件。 有个地方需要注意，mmap 写文件，windows 观察，发现文件的修改时间戳一直不变，linux 还未验证 ...
RocketMQ(4.8.0)——消费进度保存机制
RocketMQ(4.8.0)——消费进度保存机制 在消费者启动时会同时启动位点管理器，那么位点具体是怎么管理的呢？ RocketMQ 设计了2种位点管理方式： 远程位点管理方式（集群消费时，位点由客户端交给 Broker 保存，代码路径：D ...
RocketMQ(4.8.0)——事务消息机制
RocketMQ——事务消息机制 一、事务消息概述 2018 年 07 月 24 日，RocketMQ 社区发布 4.3.0 版本，开始正式支持事务消息。 事务消息的实现方案目前分为2种： 两阶段提交方案 三阶段提交方案 ...
RocketMQ：(2) Broker
Broker是RocketMQ的核心，大部分“重量级”工作都是由Broker完成的，包括接收Producer发过来的信息、处理Consumer的消费消息请求、消息的持久化存储、消息的HA机制以及服务端过滤功能等。 一、消息存储文件 分布式队列因为有高可靠性的要求，所以数据要通过磁盘进行 ...