总览 RocketMQ事务消息(Transactional Message)是指应用本地事务和发送消息操作可以被定...[作者空间]
顺序消息 顺序消息是指消息消费的顺序和生产者发送消息的顺序一样的。 例如:一个订单产生了三条消息分别是订单创建、订...[作者空间]
总览 消息消费者在消费一批消息后,需要记录该批消息已经消费完毕,然后也会从ProcessQueue处理队列中移除该...[作者空间]
概览 定时消息是指消息发送到Broker后,并不立即被消费者消费而是要等到特定的时间后才能被消费。 broker有...[作者空间]
总览 消息消费的模式有两种推模式、拉模式;拉模式已经不再推荐使用,因此本章将详细介绍推模式。 推模式 消息到达消息...[作者空间]
概览 消息消费包含两种推模式和拉模式,拉模式官方已经不推荐使用,那我们今天就介绍推模式。DefaultMQPush...[作者空间]
概览 RocketMQ消息消费以消费组为消费维度的,消费组之间消息消费有集群模式与广播模式两种消费模式。 广播模式...[作者空间]
概览 RocketMQ作为一款优秀的分布式消息中间件,分布式系统的一个很重要的特点就是要保证系统的高可用(HA),...[作者空间]
概览 RocketMQ的存储读写是基于JDK NIO的内存映射机制的,消息存储时首先将消息追加到内存中。在根据不同...[作者空间]
概览 Broker启动需要知道commitlog上次的commitWhere、flushWhere上次的位置,启动...[作者空间]
Index索引文件概览 消息消费队列是RocetMQ专门为消息订阅构建的索引服务,提高主题与消息队列检索消息的速度...[作者空间]
ConsumeQueue概览 RocketMQ是基于主题订阅模式实现消息消费,消费者关心的是主题Topic下的所有...[作者空间]
概览 RocketMQ的消息存储主要是在${ROCKETMQ_HOME}/store文件夹下,message消息主...[作者空间]
存储总览 业务系统大多数需要 MQ 有持久存储的能力,能大大增加系统的高可用性。从存储方式和效率来看,文件系统高于...[作者空间]
概览 RocketMQ 支持 种消息发送方式 :同步(sync)、 异步(async)、单向(oneway)。 M...[作者空间]
起因 阿里巴巴团队使用 ActiveMQ 5.x处理消息,遇到瓶颈;而此时分布式流式处理引擎 Kafka 已经兴起...[作者空间]