深入研究RocketMQ消费者是如何获取消息的

小伙伴们,国庆都过的开心吗?国庆后的第一个工作日是不是很多小伙伴还沉浸在假期的心情中,没有工作状态呢?

那王子今天和大家聊一聊RocketMQ的消费者是如何获取消息的,通过学习知识来找回状态吧。

废话不多说,我们开始吧。

 

消费者组

首先我们了解一个概念,什么是消费者组

消费者组你就可以把它理解为,给一组消费者起一个名字。

假设我们有一个订单Topic名字是OrderTopic,然后库存系统和积分系统都要消费这个Topic中的数据,我们分别给库存系统和积分系统起一个消费组名字:stock_consumer_group、integral_consumer_group。

设置消费者组名字是在代码中实现的,如下:

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("stock_consumer_group");

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zzxgjp.html