发表评论取消回复
相关阅读
相关 RocketMQ源码解析-消费策略源码解析
1. 消费者的两种消费方式 1. Push消费--底层通过长轮询来实现(DefaultMQPushConsumer来实现的) 2. Pull消费--(4.7.0中代码
相关 RocketMQ源码:顺序消费实现原理
1. 介绍 全局有序 在RocketMQ中,如果使消息全局有序,可以为Topic设置一个消息队列,使用一个生产者单线程发送数据,消费者端也使用单线程进行消费,从而保证
相关 RocketMQ源码:顺序消费实现原理
1. 介绍 全局有序 在RocketMQ中,如果使消息全局有序,可以为Topic设置一个消息队列,使用一个生产者单线程发送数据,消费者端也使用单线程进行消费,从而保证
相关 RocketMQ源码:consumer 提交消费偏移量
1.什么是消费偏移量offset? 我们先看一幅图 ![format_png][] 消费偏移量`offset`就是记录消费者的消费进度的。也是`rocketmq保证消
相关 RocketMQ重置消费位点源码分析
背景 最近在使用RocketMQ的重置消费位点的时候经常出现报错,所以就打算研究下RocketMQ是如何重置消费者的消费位点的 RocketMQ版本 5.1
相关 RocketMQ源码21-顺序消费实现原理
1. 介绍 全局有序 在RocketMQ中,如果使消息全局有序,可以为Topic设置一个消息队列,使用一个生产者单线程发送数据,消费者端也使用单线程进行消费,从而保证
相关 RocketMQ基础-源码分析
1.源码仓库 [https://github.com/apache/rocketmq][https_github.com_apache_rocketmq] 2.Nam
相关 RocketMQ源码解析九(消息消费失败重试流程)
> RocketMQ版本4.6.0,记录自己看源码的过程 Consumer 直接从ConsumeMessageConcurrentlyService发送重试消息方法开始
相关 RocketMQ有序消费模式源码解析及关键点总结
有序消费模式和并发消费模式有一些关键地方不同,我这里只讲相对于并发模式下的不同点,以及对这些不同点做一些总结,说明为什么如此,所以看这篇博客之前希望你对并发消费模式的原理有一定
相关 Rocketmq源码分析
Consumer端: ![20190123103907420.png][] RocketMQ提供了两种消费模式:PUSH(pull进行监听)和PULL(长轮训)
还没有评论,来说两句吧...