前文回顾 CommitLog篇 ——【RocketMQ源码分析】深入消息存储（1） ConsumeQueue篇 ——【RocketMQ源码分析】深入消息存储（2） 前面两篇已经说过了消息如何存储到CommitLog，以及ConsumeQueue的构建流程，到了第三篇，我们有一个不得不跨过 ...

一、简介 RocketMQ 是阿里巴巴开源的分布式消息中间件，它借鉴了 Kafka 实现，支持消息订阅与发布、顺序消息、事务消息、定时消息、消息回溯、死信队列等功能。RocketMQ 架构上主要分为四部分，如下图所示： Producer：消息生产者，支持分布式集群方式部署 ...

Broker和前面分析过的NameServer类似，需要在Pipeline责任链上通过NettyServerHandler来处理消息 【RocketMQ中NameServer的启动源码分析】 实际上就通过前面提到的SendMessageProcessor ...

一、MQ存储分类 MQ存储主要分为以下三类： 文件系统：RocketMQ/Kafka/RabbitMQ 关系型数据库DB：ActiveMQ（默认采用的KahaDB做消息存储）可选用JDBC的方式来做消息持久化 分布式KV存储：ZeroMQ 对比： 存储效率， 文件系统>分布式KV ...

　　RocketMQ的具体消息存储结构是怎样的呢？如何尽量保证顺序写的呢？先来看看整体的架构图， 　　RocketMQ消息的存储是由ConsumeQueue和CommitLog配合完成的，消息真正的物理存储文件是 CommitLlog，ConsumeQueue是消息的逻辑队列 ...

转载：RocketMQ源码学习--消息存储篇 消息中间件—RocketMQ消息存储（一） RocketMQ高性能之底层存储设计 存储架构 RMQ存储架构 上图即为RocketMQ的消息存储整体架构，RocketMQ采用的是混合型的存储结构，即为Broker单个实例下所有的队列共用一个 ...

两篇精彩的文章： 《RocketMQ源码 — 三、 Producer消息发送过程》 《RocketMQ源码解析：Message存储》 rocketmq通过netty获取到消息请求后，直接掉处理模块，比如：SendMessageProcessor 这个处理类主要负责处理客户端发送消息的请求 ...

http://www.tuicool.com/articles/umQfMzA 1.序言 今天来和大家探讨一下RocketMQ在消息存储方面所作出的努力，在介绍RocketMQ的存储模型之前，可以先探讨一下MQ的存储模型选择。 2.MQ的存储模型选择 个人看来，从MQ的类型来看，存储模型分 ...