消息消费之前的内容主要针对消息发送相关的内容进行了较为深入的分析和说明，本篇文章内容主要针对RocketMQ消息消费的主要流程进行分析说明，主要针对Consumer的Push操作进行分析，以集群消费为例。 对于Consumer的消费理解，首先要从客户端的启动说起，如下是一个最简单的MQConsumer的消费逻辑： 123456789101112public static void main(Str

✨✨✨✨✨✨ ：自由而不孤立，自爱而不自私，理智判断而不找合理化借口，拥有信仰而不迷信与神学 ：自由虽给人带来了独立于理性，但也使他孤立并感到无能为力， ：精神孤独与物质孤独，在所有的孤独中，精神孤独是最可怖的 ：弗洛伊德：人基本上是反社会的，社会必须驯化他，社会对人自然冲动的压抑会转化成奋斗动力，会变成文化的人文基础，但不可压抑过度，否则会适得其反。 ：“从事强迫性的非理性活动”、”非理性的浪漫

慢不该慢到不值得，快不该快到有损于满足与理解 在挫败中产生了沮丧，因而才感到厌倦 毫无理解便同意只是愚蠢，还不清楚便不同意也是无理 争论时应多一点理性的光，少一点激情的热 理性是人类表达同意的力量源泉。人类的兽性与理性中不完美的部分，则是造成许多不同意的原因。人是情绪与偏见的动物。他们必须用来沟通的语言是不完美的额媒介，被情绪遮盖着，被个人的喜好渲染着，被不恰当的思想穿梭着 阅读的层次初学者的

背景：前面几篇文章分别针对RocketMQ的存储原理和内存映射相关逻辑做了简要的分析和说明，本篇内容主要针对RocketMQ数据刷盘机制做简要的分析和说明 RocketMQ刷盘机制主要有两部分： 同步刷盘 异步刷盘 1234public enum FlushDiskType { SYNC_FLUSH, // 同步 ASYNC_FLUSH // 异步} 刷盘

内存映射文件概念——摘自百度百科 内存映射文件，是由一个文件到一块内存的映射。内存映射文件与虚拟内存有些类似，通过内存映射文件可以保留一个地址空间的区域，同时将物理存储器提交给此区域，内存文件映射的物理存储器来自一个已经存在于磁盘上的文件，而且在对该文件进行操作之前必须首先对文件进行映射。使用内存映射文件处理存储于磁盘上的文件时，将不必再对文件执行I/O操作，使得内存映射文件在处理大数据量的文件

消息存储消息的存储做为RocketMQ设计中极为重要的一个环节和架构设计，非常值得去学习它的设计和思想，本文主要针对消息存储的部分逻辑做简要的说明和分析，做一个简单的入门学习。存储本身是该中间件的一个核心组件，包含了诸多的设计理念和设计思想，关于它的一些细节设计和思想会到后续的文章中进行细致的说明和分析。 消息存储触发时机前面的文章中对消息发送的逻辑做了细致的分析和说明，Producer将消息发送

消息存储架构RocketMQ作为一款高性能的消息中间件，和他的存储设计有很大的关系，本文主要针对重要的几个文件做简要的说明，部分内容都来自官网，便于后续源码的分析和理解。 如下为RocketMQ的消息存储架构图（来源官网） RocketMQ存储文件主要构成CommitLog1、CommitLog文件 CommitLog文件时Rocket存储消息的主要文件 生产者发送到Broker端的消息，都会

简介阿尔弗雷德·阿德勒，奥地利精神病学家，个体心理学创始人 个体心理学，阿德勒创立的精神分析心理学体系 本书革核心思想时分析人类潜在自卑，鼓励创造性自我，追求优越，超越自我。 如下内容摘抄自书本： 美句鉴赏 如果一个人的身体不能与周围环境适应，身体达不到环境的要求，那么这个人的精神负担就会很重 环境不能左右一个人的思想，他的思想应该时通过他自己本身对于环境的看法来决定的 读后感“每个人都

一平方英寸的寂静网站 网站地址：https://onesquareinch.org/ 网站说明：外网，部分资源资源访问不了，需要翻墙“一平方英寸的寂静”它是一个地方，也是一个想法，意在呼吁民众重视自然静谧，作者将这些通过网站来传递给众人 网站封面： 翻译： 一平方英寸的寂静可能是美国最安静的地方。这是一个独立的研究项目，位于奥林匹克国家公园的可可雨林，这是美国最原始、未受破坏、生态多样的环

背景基于上一篇文章对事务消息发送的原理分析，本文继续对事务消息原理做进一步的梳理说明 本文主要针对事务消息的回查机制做对应的分析和说明 TransactionalMessageCheckServiceBroker在启动的时候（BrokerController#start），会在start方法中调用startProcessorByHa逻辑，在该逻辑中会判断当前Broker的角色是否是Master，如