rocketmq 的分组
时间: 2024-08-14 08:03:21 浏览: 40
RocketMQ基本概念
RocketMQ是一个分布式消息中间件,它采用了主从(Master-Slave)架构,并且支持基于Topic和Tag两种消息分发模式。其中,关于分组(Grouping)主要是针对Consumer的设计,主要有以下几种:
1. **消费分组**(Consumer Group):RocketMQ的每个消费者都属于某个消费分组,所有成员共享相同的订阅主题。当一条消息发布到主题时,会广播给该主题的所有消费组。每个消费组内部的消息是有序的,通过精确的消息ID保证消息顺序。
2. **轮询消费**:默认情况下,每个消息只会被每个分组的一个Consumer实例消费一次。这可以避免多个Consumer竞争导致的消息重复消费。
3. **消息过滤**(Message Filter):在消费分组内,可以设置Message Filter,只有满足条件的消息才会被投递给某个Consumer,增加了灵活性。
4. **广播消费**(Broadcast Consumption):在某些场景下,可以选择广播模式,即每条消息都会被分组内的所有Consumer消费,适合对数据处理速度要求不高的情况。
阅读全文