发表评论取消回复
相关阅读
相关 RocketMQ源码解析-消费策略源码解析
1. 消费者的两种消费方式 1. Push消费--底层通过长轮询来实现(DefaultMQPushConsumer来实现的) 2. Pull消费--(4.7.0中代码
相关 RocketMQ源码:ACK机制及消费进度管理
1. 消息的ACK机制 consumer的每个实例是靠AllocateMessageQueueStrategy队列分配来决定如何消费消息的。那么消费进度具体是如何管理的,
相关 RocketMQ源码:顺序消费实现原理
1. 介绍 全局有序 在RocketMQ中,如果使消息全局有序,可以为Topic设置一个消息队列,使用一个生产者单线程发送数据,消费者端也使用单线程进行消费,从而保证
相关 RocketMq4.7源码解析之七(消息消费)
文章目录 启动流程 消息拉取 消息消费客户端发送拉取消息请求 消息服务端Broker处理拉取消息请求 消息消费客户端消
相关 RocketMQ生产者消息发送源码解析总结
RocketMQ在发送消息时,内部使用DefaultMQProducerImpl\sendDefaultImpl(…)来做消息的发送工作。看其代码: / 发送消息。
相关 RocketMQ刷盘策略源码解析及总结
Broker通过CommitLog类来完成数据的落盘工作,对于前面的流程我们直接略过,直接从关键方法putMessage(….)开始。 public class Co
相关 RocketMQ事务消息源码解析及关键点总结(基于4.0.0+版本)
RocketMQ在3.1.2以前有事务消息回查机制,也就是Broker对CommitLog内长时间处于Prepared状态的事务消息,向发送器消息的Producer发送请求,询
相关 RocketMQ主从同步机制源码解析及关键点总结(二)
这篇博客接着上篇的讲,主要讲以下两个问题: 1. Slave接收到Master的数据后的处理 2. 同步/异步Master (SYNC\_MASTER) 下的主从同步机制
相关 RocketMQ主从同步机制源码解析及关键点总结(一)
我主要依照以下问题点及顺序来依次讲解: 1. Slave角色配置以及基于配置下如何实现不同于Master的运行机制 2. Master的数据传输以及Slave的进度上报
相关 RocketMQ有序消费模式源码解析及关键点总结
有序消费模式和并发消费模式有一些关键地方不同,我这里只讲相对于并发模式下的不同点,以及对这些不同点做一些总结,说明为什么如此,所以看这篇博客之前希望你对并发消费模式的原理有一定
还没有评论,来说两句吧...