RocketMQ - 文集

RocketMQ

13篇文章 · 19901字 · 23人关注

RocketMQ源码解析(十三)-事务消息
什么是事务消息首先我们用一个场景来讲一下事务消息解决的问题。分布式消息队列多用来解决多个微服务之间的调用解耦，不会因为单个服务的服务质量问题而...

0.1 1530 0 3
RocketMQ源码解析(十二)-顺序消息
什么是顺序消息顺序消息是RocketMQ相对于其它分布式消息队列方案一个很有特色的特性。所谓顺序就是consumer端用户Listener收到...

0.3 4368 0 7

RocketMQ源码解析(十一)-Broker#消息消费
终于讲到Broker消息处理流程的最后一步了。讲Consumer的时候说到消费消息分为Pull和Push两种模式，底层其实都是依靠Pull实现的...

0.2 2111 3 4
RocketMQ源码解析(十)-Broker#消息存储Index
IndexFile作用 MessageStore中存储的消息除了通过ConsumeQueue提供给consumer消费之外，还支持通过Messa...

0.1 2400 0 3
RocketMQ源码解析(九)-Broker#消息存储ConsumeQueue
ConsumeQueue的作用上一篇文章讲到Broker在收到消息后，通过MessageStore将消息存储到commitLog中，但是con...

0.3 2466 1 5
RocketMQ源码解析(八)-Broker#消息发送
从这篇文章开始，主要看一下Broker处理一条消息的完整过程：接收Producer发来的消息->存储消息->将消息推给Consumer。这一篇主...

0.3 2125 6 3 1
RocketMQ源码解析(七)-Topic创建
用了前面几篇文章，终于把RocketMQ的各个组件介绍完了。可以看到一条消息整个流转过程都是要有一个topic的，一般日常业务使用过程中，都是使...

0.4 4127 0 3

RocketMQ源码解析(六)-Broker#MessageStore
Broker将消息存储抽象成MessageStore接口，默认实现类是DefaultMessageStore。主要提供如下方法：保存消息，包括...

0.3 2879 0 4
RocketMQ源码解析(五)-Broker架构及服务启动
之前几篇文章讲了Producer如何发送消息，Consumer如何收消息。后面会用更多的几篇来讲Broker，其实也就是消息队列的核心-分布式Q...

0.5 2761 0 3