网站首页编程语言正文

RocketMQ消费模式

作者：数据驱动生活更新时间： 2024-01-06 编程语言

RocketMQ消费模式分为负载均衡模式和广播模式。

负载均衡模式（CLUSTERING）：同一个主题中的消息会被多个消费者交替消费，队列会被消费者分摊，队列数量>=消费者数量避免消费者空闲，MQ服务器会记录消费位点。

广播模式（BROADCASTING）：同一个主题中的消息会被每一个消费者都处理一次，MQ服务器不会记录消费位点，消费失败也不会重试。

@RocketMQMessageListener(
	messageModel = MessageModel.CLUSTERING // 负载均衡模式
	messageModel = MessageModel.BROADCASTING // 广播模式
)

原文链接：https://blog.csdn.net/m0_62129859/article/details/135068138