RocketMQ源码解读 - 专题

投稿

收录了17篇文章 · 21人关注

事务消息
总览 RocketMQ事务消息（Transactional Message）是指应用本地事务和发送消息操作可以被定义到全局事务中，要么同时成功，...

0.1 93张先生 1 2
顺序消息
顺序消息顺序消息是指消息消费的顺序和生产者发送消息的顺序一样的。例如：一个订单产生了三条消息分别是订单创建、订单付款、订单完成。消费时要按照...

93张先生 0 0

消息进度管理
总览消息消费者在消费一批消息后，需要记录该批消息已经消费完毕，然后也会从ProcessQueue处理队列中移除该批消息，返回ProcessQu...

93张先生 0 0
定时消息机制
概览定时消息是指消息发送到Broker后，并不立即被消费者消费而是要等到特定的时间后才能被消费。 broker有配置项messageDelay...

93张先生 0 0
消息拉取与消息队列的负载均衡
总览消息消费的模式有两种推模式、拉模式；拉模式已经不再推荐使用，因此本章将详细介绍推模式。推模式消息到达消息服务器后，服务器推送消息给消费...

93张先生 0 1
RocketMQ消费启动流程
概览消息消费包含两种推模式和拉模式，拉模式官方已经不推荐使用，那我们今天就介绍推模式。DefaultMQPushConsumer是推模式消费的...

93张先生 0 0
RocketMQ消息消费概览
概览 RocketMQ消息消费以消费组为消费维度的，消费组之间消息消费有集群模式与广播模式两种消费模式。广播模式主题下的同一条消息将被集群内...

93张先生 0 0

RocketMQHA机制
概览 RocketMQ作为一款优秀的分布式消息中间件，分布式系统的一个很重要的特点就是要保证系统的高可用(HA)，RocketMQ则是通过主从同...

0.1 93张先生 0 1
RocketMQ刷盘机制
概览 RocketMQ的存储读写是基于JDK NIO的内存映射机制的，消息存储时首先将消息追加到内存中。在根据不同的刷盘策略在不同的时间进行刷盘...

0.9 93张先生 0 7
Broker启动历史数据加载
概览 Broker启动需要知道commitlog上次的commitWhere、flushWhere上次的位置，启动流程加载commitlog、c...

93张先生 0 1