RockerMQ里有个非常重要的数据结构叫ProcessQueue，很多功能，例如消费进度，消费等等功能的底层核心数据保存都是有ProcessQ...

队列选择 在HA的文章里大概讲了一下Producer如何为高可用贡献出一份力量的，当时只是说了遍历列表选择队列，然后选择一个，没有深入分析，这篇...

总体流程 首先从demo为入口分析整个启动过程 DefaultMQProducer构造方法如下： 然后调用start方法后，即开始初始化流程，其...

上一篇文章分析了MS之间的同步，Client端在多Matser多Slave下的情况，这一篇文章主要从NameServer的角度来分析，在整个 架...

废话 这篇文章主要讲RocketMQ的长轮询，为什么叫长轮询我也不清楚....主要别人这样叫我也这样叫吧，大家明白意思就好。 正文 Rcocke...

延时消息的例子 和普通消息发送没多大区别，只是多了个句设置延时级别的代码 level为3那么代表10s后消费者10s后能拉到这条消息，消费者端的...

废话 很久没写过看过RocketMQ源码了，就刚开始用MQ的时候，顺便看了下源码，由于当时水平较差，写了几篇文章，现在感觉真JB乱....有种想...