RocketMQ 第3页

2020-08-12站长阅读(565)赞(0)

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

2020-08-12站长阅读(466)赞(0)

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

2020-08-12站长阅读(529)赞(0)

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

2020-08-12站长阅读(518)赞(0)

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

2020-08-12站长阅读(537)赞(0)

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

2020-08-12站长阅读(506)赞(0)

RocketMQ 刷盘支持同步刷盘和异步刷盘。为了了解其具体实现，我们以 Commitlog 的存储为例来说明 RocketMQ 是如何进行磁盘读写。 Comitlog\#putMessage首先将消息写入到 MappedFile,内存映射...

2020-08-12站长阅读(495)赞(0)

上篇主要是讲解 RocketMQ 运行过程中消息发送者发送一条消息，进入到 commitlog 文件,然后是如何被转发到 consumequeue、index 索引文件中的，本节主要剖析一下，在 RocketMQ 启动过程中，是如何根据 c...

2020-08-12站长阅读(508)赞(0)

本文主要从源码的角度分析 Rocketmq 消费队列 ConsumeQueue 物理文件的构建与存储结构，同时分析 RocketMQ 索引文件 IndexFile 文件的存储原理、存储格式以及检索方式。 RocketMQ 的存储机制是所有的...

2020-08-12站长阅读(496)赞(0)

1、消息消费进度概述 首先简要阐述一下消息消费进度： 消费者订阅消息消费队列（MessageQueue), 当生产者将消息负载发送到 MessageQueue 中时，消费订阅者开始消费消息，消息消费过程中，为了避免重复消费，需要一个地方存储...

2020-08-12站长阅读(620)赞(0)

主要关注业务方在消息消费失败后，返回 ConsumeConcurrentlyStatus.RECONSUME\_LATER ,专业术语：业务方每条消息消费后要告诉 MQ 消费者一个结果(ack,message back)，触发 MQ 消息消...