RocketMQ客户端PUSH消费中并发消费与顺序消费的示例分析

1524990177 • 08/17 18:11 • Linux技术 • 阅读 129

这篇文章主要介绍了RocketMQ客户端PUSH消费中并发消费与顺序消费的示例分析，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。1.消息拉取
小结：PullMessageService处理拉取消息请求。通过组织RequetHeader需要包含从哪里开始拉取（ConsumerGroup、Topic，Queue，queueOffset）等信息，向Broker发起请求，取回消息后对消息进行处理。当该Queue的消息数量超过1000，或者最小与最大偏移量之间的差距超过默认2000也会触发限流，即：延迟50毫秒放入请求队列。也可以通过挂起消费线程来延迟（1秒）香港云主机消息拉取，从而达到消费限流作用。
2.消息处理小结：PullMessageService处理消息部分流程：将消息提交给了processQueue红黑树缓存；同时将消息提交给consumeMessageService来处理具体的消息内容。
1.ConsumeMessageConcurrentlyService职责
小结：ConsumeMessageService并发消费（ConsumeMessageConcurrentlyService）主要工作交给Listener（客户端传入）进行处理，并对处理结果进行统计和处理；对于失败消息，广播消费会丢弃，集群消费会发回Broker重新消费；清理ProcessQueue并更新缓存（offsetTable）消费进度。

三、顺序消费流程
1.ConsumeMessageOrderlyService职责
小结：顺序消费流程跟并发消费最大的区别在于，对要处理的队列加锁，确保同一队列，同一时间，只允许一个消费线程处理。
2.Broker端队列加锁流程小结：顺序消费时对Broker端队列加锁防止该队列在特定时间内（一次默认60秒）被分配给其他clientId处理；Broker端加锁了，一次加锁失效时长为60秒；不存在Broker加锁过期了客户端还在处理该队列的情况，Broker加锁时长为60秒，而客户端加锁时长为30秒，当客户端加锁时长失效时会重新请求Broker加锁并更新时间戳，从而可以持续延长加锁时间。
感谢你能够认真阅读完这篇文章，希望小编分享的“RocketMQ客户端PUSH消费中并发消费与顺序消费的示例分析”这篇文章对大家有帮助，同时也希望大家多多支持开发云，关注开发云行业资讯频道，更多相关知识等着你来学习!

相关推荐: C++如何实现验证二叉搜索树

本文小编为大家详细介绍“C++如何实现验证二叉搜索树”，内容详细，步骤清晰，细节处理妥当，希望这篇“C++如何实现验证二叉搜索树”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。Example 1:Input:2/1 3Output: …