Broker 概述、启动和停止流程 Broker 是 RocketMQ 体系中核心组件之一,存储是 Broker 的核心功能之一,决定整个 RocketMQ 体系的吞吐性能、可靠性和可用性。 ...
Broker 概述、启动和停止流程 Broker 是 RocketMQ 体系中核心组件之一,存储是 Broker 的核心功能之一,决定整个 RocketMQ 体系的吞吐性能、可靠性和可用性。 ...
Broker消息存储机制 RocketMQ 使用 CommitLog 文件将消息存储到磁盘上,那么 RocketMQ 存储消息到磁盘的过程是怎么样的呢? RocketMQ 首先将消息数据写 ...
RocketMQ(4.8.0)——生产者 一、生产者概述 发送消息的一方被称为生产者,它在整个RocketMQ的生产者和消费体中扮演角色如下: 基本概念: 生产者组: 一个逻辑概念,在 ...
Broker 主从同步机制 一、主从同步概述 Broker 有2种角色: Master:主要用于处理生产者、消费者的请求和存储数据。 Slave:从 Mast ...
RocketMQ——事务消息机制 一、事务消息概述 2018 年 07 月 24 日,RocketMQ 社区发布 4.3.0 版本,开始正式支持事务消息。 事务消息的实现方案目前分为2种 ...
RocketMQ(4.8.0)——消费进度保存机制 在消费者启动时会同时启动位点管理器,那么位点具体是怎么管理的呢? RocketMQ 设计了2种位点管理方式: ...
Broker 过期文件删除机制 RocketMQ 中主要保存了 CommitLog、Consume Queue、Index File 三种数据文件。由于内存和磁盘都是有限的资源,Broker 不 ...