1 前言上一章节，我们大致上了解了消息的存储机制，其中在消息写入时，RocketMQ有两种不同的写入机制： 常规方式：通过MMAP(Memory Map，内存映射)写内存映射文件(Memory-Mapped File，MMF)，然后通过同

1 整体流程消息存储整体流程 消息存储架构设计 2 核心类2.1 DefaultMessageStoreDefaultMessageStore 部分属性： private final MessageStoreConfig messag

1 Consumer样例这里以集群消费、并发消费为例，采用一般的推模式进行消息消费。 public class BalanceConsumer { public static void main(String[] args

1 Producer样例public class TestProducer { public static void main(String[] args) throws MQClientException, Interr

1 问题给你一棵二叉树的根节点，返回该树的直径。 二叉树的直径是指树中任意两个节点之间最长路径的长度。这条路径可能经过也可能不经过根节点 root 。 两节点之间路径的长度由它们之间边数表示。 示例 1 输入：root = [1

1 问题给你一个含重复值的二叉搜索树（BST）的根节点 root ，找出并返回 BST 中的所有众数（即，出现频率最高的元素）。 如果树中有不止一个众数，可以按任意顺序返回。 假定 BST 满足如下定义： 结点左子树中所含节点的值小于等于

0 前言RocketMQ消息队列集群主要包括NameServer、Broker(Master/Slave)、Producer、Consumer4个角色。在【RocketMQ学习】1.基础知识一文中，我们了解了其物理架构，本章将深入

1 准备JDK：1.8.0_181Maven：apache-maven-3.5.3RocketMQ：4.8.0（官网目前最新版本是5.1.3），参见 快速指南 ，各版本源码及二进制执行文件下载参见 这里下载环境变量：ROCKETMQ_HOM

1 问题给定一棵二叉树的根节点root ，请找出该二叉树中每一层的最大值。 示例1示例1 输入: root = [1,3,2,5,3,null,9]输出: [1,3,9] 示例2 输入: root = [1,2,3

1 问题给定一个二叉树的根节点 root，请找出该二叉树的最底层、最左边节点的值。 假设二叉树中至少有一个节点。 示例 1示例1 输入: root = [2,1,3]输出: 1 示例 2示例2 输入: [1,2,3,4

1 前言2 RocketMQ中的高可用机制RocketMQ分布式集群是通过 Master 和 Slave 的配合达到高可用性的。 RocketMQ的HA架构 Master和Slave的区别： 在Broker的配置文件中，参数broke

1 前言自5.0开始，RocketMQ开始用DDD思想划分，包括Topic、Message、Queue、Producer、Consumer、ConsumerGroup、Subscription等。这些概念已经在基础知识一文中有做介绍。 本章