源码分析云消息队列 MQ dledger副本的相关内容

文章 2022-05-28 来自：开发者社区

源码分析 RocketMQ DLedger 多副本即主从切换实现原理

DLedger 基于 raft 协议，故天然支持主从切换，即主节点(Leader)发生故障，会重新触发选主，在集群内再选举出新的主节点。RocketMQ 中主从同步，从节点不仅会从主节点同步数据，也会同步元数据，包含 topic 路由信息、消费进度、延迟队列处理队列、消费组订阅配置等信息。那主从切换后元数据如何同步呢？特别是主从切换过程中，对消息消费有多大的影响，会丢失消息吗？1、BrokerC....

文章 2022-05-28 来自：开发者社区

源码分析 RocketMQ DLedger(多副本) 之日志复制-下篇

3、EntryHandler 详解EntryHandler 同样是一个线程，当节点状态为从节点时激活。3.1 核心类图其核心属性如下：long lastCheckFastForwardTimeMs上一次检查主服务器是否有 push 消息的时间戳。ConcurrentMap>> writeRequestMapappend 请求处理队列。BlockingQueue>> com....

文章 2022-05-28 来自：开发者社区

源码分析 RocketMQ DLedger(多副本) 之日志复制-上篇

本文紧接着源码分析 RocketMQ DLedger(多副本) 之日志追加流程，继续 Leader 处理客户端 append 的请求流程中最至关重要的一环：日志复制。温馨提示：由于微信单篇文章的字数限制，RocketMQ DLedger 日志复制分为两篇文章介绍。DLedger 多副本的日志转发由 DLedgerEntryPusher 实现，接下来将对其进行详细介绍。温馨提示：由....

文章 2022-05-28 来自：开发者社区

源码分析 RocketMQ DLedger(多副本) 之日志追加流程

上一篇我们详细分析了源码分析RocketMQ多副本之Leader选主，本文将详细分析日志复制的实现。有了前篇源码分析 RocketMQ DLedger 多副本存储实现，本文将直接从 Leader 处理客户端请求入口开始，其入口为：DLedgerServer 的 handleAppend 方法开始讲起。1、日志复制基本流程在正式分析 RocketMQ DLedger 多副本复制之前，我们首先来....

文章 2022-05-28 来自：开发者社区

源码分析 RocketMQ DLedger 多副本存储实现

RocketMQ DLedger 的存储实现思路与 RocketMQ 的存储实现思路相似，本文就不再从源码角度详细剖析其实现，只是点出其实现关键点。我们不妨简单回顾一下 CommitLog 文件、ConsumeQueue 文件设计思想。其文件组成形式如下：正如上图所示，多个 commitlog 文件组成一个逻辑上的连续文件，使用 MappedFileQueue 表示，单个 commitlog 文....

文章 2019-10-11 来自：开发者社区

源码分析 RocketMQ DLedger 多副本即主从切换实现原理

DLedger 基于 raft 协议，故天然支持主从切换，即主节点(Leader)发生故障，会重新触发选主，在集群内再选举出新的主节点。 RocketMQ 中主从同步，从节点不仅会从主节点同步数据，也会同步元数据，包含 topic 路由信息、消费进度、延迟队列处理队列、消费组订阅配置等信息。那主从切换后元数据如何同步呢？特别是主从切换过程中，对消息消费有多大的影响，会丢失消息吗？温馨提示：本文....

文章 2019-09-23 来自：开发者社区

源码分析 RocketMQ DLedger(多副本) 之日志复制(传播)

本文紧接着源码分析 RocketMQ DLedger(多副本) 之日志追加流程，继续 Leader 处理客户端 append 的请求流程中最至关重要的一环：日志复制。 DLedger 多副本的日志转发由 DLedgerEntryPusher 实现，接下来将对其进行详细介绍。温馨提示：由于本篇幅较长，为了更好的理解其实现，大家可以带着如下疑问来通读本篇文章：1、raft 协议中有一个非常重.....

文章 2019-09-15 来自：开发者社区

源码分析 RocketMQ DLedger 多副本存储实现

文章 2019-09-15 来自：开发者社区

源码分析 RocketMQ DLedger 多副本之 Leader 选主

本文将按照《RocketMQ 多副本前置篇：初探raft协议》的思路来学习RocketMQ选主逻辑。首先先回顾一下关于Leader的一些思考：节点状态需要引入3种节点状态：Follower(跟随者)、Candidate(候选者)，该状态下的节点会发起投票请求，Leader(主节点)。选举计时器Follower、Candidate两个状态时，需要维护一个定时器，每次定时时间从150ms-30.....