prince的文章

根据上节Demo示例，发送事务消息的入口为：TransactionMQProducer#sendMessageInTransaction： public TransactionSendResult sendMessageInTransact...

赞(0)princeRocketMQ 源码分析 阅读(366)

RocketMQ事务消息阅读目录指引： RocketMQ源码分析之从官方示例窥探RocketMQ事务消息实现基本思想 RocketMQ源码分析之RocketMQ事务消息实现原理上篇 RocketMQ源码分析之RocketMQ事务消息实现原理...

赞(0)princeRocketMQ 源码分析 阅读(370)

关于主从同步最新理解：RocketMQ 主从同步若干问题答疑 RocketMQ在消息拉取时是如何根据消息消费队列MessageQueue来选择Broker的呢？消息消费队列如图所示： RocketMQ根据MessageQueue查找Brok...

赞(0)princeRocketMQ 源码分析 阅读(391)

关于主从同步最新理解：RocketMQ 主从同步若干问题答疑 HA主从同步的核心类图如图所示： 初始RocketMQ HA HAService：主从同步核心实现类。 AtomicInteger connectionCount：Master维...

赞(0)princeRocketMQ 源码分析 阅读(384)

由于RocketMQ操作CommitLog、ConsumeQueue文件，都是基于内存映射方法并在启动的时候，会加载commitlog、ConsumeQueue目录下的所有文件，为了避免内存与磁盘的浪费，不可能将消息永久存储在消息服务器上，...

赞(0)princeRocketMQ 源码分析 阅读(458)

本节目录 1、 消息队列负载； 2、 消息拉取； 3、 消息顺序消息消费； 3.1核心属性与构造函数 3.2 start方法 3.3 submitConsumeRequest 3.4 ConsumeMessageOrderlyService...

赞(0)princeRocketMQ 源码分析 阅读(404)

本节目录 1、 长轮询、短轮询概述； 2、 RocketMQ拉轮询拉取任务创建； 3、 源码分析PullRequestHoldService线程； 3.1 PullRequestHoldService#suspendPullRequest ...

赞(0)princeRocketMQ 源码分析 阅读(380)

本节目录 1、 RocketMQ推拉模式简介； 2、 DefaultMQPullConsumer核心属性； 3、 消息消费者启动流程分析； 1、RocketMQ 推拉模式简介 消费者与消息存储方 Broker一般有两种通信机制：推（PUSH...

赞(0)princeRocketMQ 源码分析 阅读(400)

继上篇源码分析了 Tag 过滤机制实现原理，本文主要阐述 RocketMQ SQL92 表达式与 ClassFilte r过滤机制实现。 1、RocketMQ SQL92实现原理分析 入口：PullMessageProcessor#proc...

赞(0)princeRocketMQ 源码分析 阅读(379)

1、消息消费过滤机制 1.1 根据 tagcode 过滤 1.2 高级过滤 上述资源来源于 RocketMQ 官方文档。 通过官方文档，我们基本可以知道，消息的过滤机制与服务端息息相关，更细一点的讲，与拉取消息实现过程脱离不了关系，事实上也...

赞(0)princeRocketMQ 源码分析 阅读(402)