RocketMQ(4.8.0)——Broker 主从同步机制
Broker 主从同步机制 一、主从同步概述 Broker 有2种角色： Master：主要用于处理生产者、消费者的请求和存储数据。 Slave：从 Master 同步所有数据到本地。具体体现在以下2个方面 ...
原文：RocketMQ(4.8.0)——消费进度保存机制
RocketMQ . . 消费进度保存机制 在消费者启动时会同时启动位点管理器，那么位点具体是怎么管理的呢 RocketMQ 设计了 种位点管理方式： 远程位点管理方式 集群消费时，位点由客户端交给 Broker 保存，代码路径：D: rocketmq master client src main java org apache rocketmq client consumer store Rem ...
2021-02-20 16:55 0 316 推荐指数：
相关推荐
RocketMQ(4.8.0)——事务消息机制
RocketMQ——事务消息机制 一、事务消息概述 2018 年 07 月 24 日，RocketMQ 社区发布 4.3.0 版本，开始正式支持事务消息。 事务消息的实现方案目前分为2种： 两阶段提交方案 三阶段提交方案 ...
RocketMQ(4.8.0)——Broker消息存储机制
Broker消息存储机制 RocketMQ 使用 CommitLog 文件将消息存储到磁盘上，那么 RocketMQ 存储消息到磁盘的过程是怎么样的呢? RocketMQ 首先将消息数据写入操作系统 PageCache，然后定时将数据刷入磁盘。 一、Broker 消息存储的流程是什么 ...
RocketMQ(4.8.0)——Broker 过期文件删除机制
Broker 过期文件删除机制 RocketMQ 中主要保存了 CommitLog、Consume Queue、Index File 三种数据文件。由于内存和磁盘都是有限的资源，Broker 不可能永久地保存所有数据，所以一些超过保存期限的数据会被定期删除。RocketMQ 通过设置数据过期 ...
RocketMQ(4.8.0)——生产者
RocketMQ(4.8.0)——生产者 一、生产者概述 发送消息的一方被称为生产者，它在整个RocketMQ的生产者和消费体中扮演角色如下： 基本概念： 生产者组： 一个逻辑概念，在使用生产者实例的时候需要制定一个组名。一个生产者组可以生产多个Topic的消息。 生产者实例 ...
RocketMQ——ack机制保证消费成功
ACK简介 在实际使用RocketMQ的时候我们并不能保证每次发送的消息都刚好能被消费者一次性正常消费成功，可能会存在需要多次消费才能成功或者一直消费失败的情况，那作为发送者该做如何处理呢？ RocketMQ提供了ack机制，以保证消息能够被正常消费。发送者为了保证消息肯定消费成功，只有使用方明确 ...
RocketMQ消费失败重试机制
RocketMQ消费失败重试机制分析 简介： 现象：mq消费1次，重试3次，然后停止 现象：mq消费1次，重试3次，然后停止，如下实例展示 首次（reconsumeTimes=0） MQ_CON_MSG gmcf-lsc-zhongbang-repu-calc-from-topic ...
RocketMQ-消费重试机制
介绍： RocketMQ的消息重试及时分为两种，一种是Producer端重试，一种是Consume端重试。 1、Producer端重试 ： 1.1消息发没发成功，默认情况下是3次重试。 2、Consumer端重试： 2.1 exception的情况，一般重复16次 10s ...