【RocketMQ源码分析】深入消息存储（3）
前文回顾 CommitLog篇 ——【RocketMQ源码分析】深入消息存储（1） ConsumeQueue篇 ——【RocketMQ源码分析】深入消息存储（2） 前面两篇已经说过了消息如何存储到CommitLog，以及ConsumeQueue的构建流程，到了第三篇，我们有一个不得不跨过 ...
原文：RocketMQ 源码分析(二) —— Message 存储
CommitLog 结构 CommitLog MappedFileQueue MappedFile 的关系如下： CommitLog : MappedFileQueue : MappedFile : : N。 反应到系统文件如下： Yunai MacdeMacBook Pro :commitlog yunai pwd Users yunai store commitlog Yunai MacdeM ...
2018-06-04 23:19 0 1055 推荐指数：
相关推荐
【RocketMQ源码分析】深入消息存储（2）
前文回顾 CommitLog篇 ——【RocketMQ源码分析】深入消息存储（1） MappedFile篇 ——【RocketMQ源码分析】深入消息存储（3） 前文说完了一条消息如何被持久化到本地磁盘CommitLog，本篇就要谈谈如何从CommitLog来构建我们消息消费的核心队列结构 ...
RocketMQ中Broker的消息存储源码分析
Broker和前面分析过的NameServer类似，需要在Pipeline责任链上通过NettyServerHandler来处理消息 【RocketMQ中NameServer的启动源码分析】 实际上就通过前面提到的SendMessageProcessor ...
阿里消息队列中间件 RocketMQ 源码分析 —— Message 拉取与消费（上）
🙂🙂🙂关注微信公众号：【芋艿的后端小屋】有福利： RocketMQ / MyCAT / Sharding-JDBC 所有源码分析文章列表 RocketMQ / MyCAT / Sharding-JDBC 中文注释源码 GitHub 地址 您对于源码的疑问每条 ...
RocketMQ源码（一）Message 发送与接收
1、概述 Producer 发送消息。主要是同步发送消息源码，涉及到 异步/Oneway发送消息，事务消息会跳过。 Broker 接收消息。 2、Producer 发送消息 21.DefaultMQProducerImpl#sendDefaultImpl() 说明 ：发送消息 ...
RocketMQ源码分析——消费端
长轮询 （RocketMQ使用） Consumer -> Broker RocketMQ采用的长轮询建立连接 consumer的处理能力Broker不知道 直接推送消息 broker端压力较大 采用长连接有可能consumer不能及时处理推送过来的数据 pull主动权 ...
源码分析RocketMQ消息轨迹
本文沿着《RocketMQ消息轨迹-设计篇》的思路，从如下3个方面对其源码进行解读： 发送消息轨迹 消息轨迹格式 存储消息轨迹数据 @ 目录 1、发送消息轨迹流程 1.1 DefaultMQProducer构造函数 1.2 ...
Android Handler机制（一）---Message源码分析
Message: 定义： public final class Message implements Parcelable Message类是个final类，就是说不能被继承，同时Message类 ...