prince的文章

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

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

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

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

RocketMQ 存储基础回顾：源码分析RocketMQ之CommitLog消息存储机制 本文主要从源码的角度分析 Rocketmq 消费队列 ConsumeQueue 物理文件的构建与存储结构，同时分析 RocketMQ 索引文件Inde...

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

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

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

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

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

1、消息消费需要解决的问题 首先再次重复啰嗦一下 RocketMQ 消息消费的一些基本元素的关系 主题—》 消息队列(MessageQueue) 1 对多。 主题—》 消息生产者，一般主题会由多个生产者组成，生产者组。 主题—》 消息消费者...

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

1、 消息消费需要解决的问题； 首先再次重复啰嗦一下RocketMQ消息消费的一些基本元素的关系 主题—》 消息队列(MessageQueue) 1 对多 主题—-》 消息生产者，，，一般主题会由多个生产者组成，生产者组 主题—- 》 消息...

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

1、消息消费概述 消息消费方式 拉取、推送。 消费者组与消费模式 多个消费者组成一个消费组，两种模式：集群（消息被其中任何一个消息者消费）、广播模式（全部消费者消费）。 ConsumeFromWhere consumeFromWhere 从...

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

本文重点分析 Broker 接收到生产者发送消息请求后如何存储在 Broker 上，本文暂不关注事务消息机制。 本文前置篇:RocketMQ源码分析之Broker概述与同步消息发送原理与高可用设计及思考 。 RocketMQ 的存储核心类为...

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

1、Broker概述 Broker 在 RocketMQ 架构中的角色，就是存储消息，核心任务就是持久化消息，生产者发送消息给 Broker,消费者从 Broker 消费消息，其物理部署架构图如下： 备注：以上摘录自官方 RocketMQ ...

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