RocketMq中组的概念_rocketmq group概念

GroupName
和现实世界中一样，RocketMQ中也有组的概念。代表具有相同角色的生产者组合或消费者组合，称为生产者组或消费者组。

作用是在集群HA的情况下，一个生产者down之后，本地事务回滚后，可以继续联系该组下的另外一个生产者实例，不至于导致业务走不下去。在消费者组中，可以实现消息消费的负载均衡和消息容错目标。

另外，有了GroupName，在集群下，动态扩展容量很方便。只需要在新加的机器中，配置相同的GroupName。启动后，就立即能加入到所在的群组中，参与消息生产或消费。
1
2
3

来自官方文档

Producer Group

生产者组
每一个生产者组只能有一个实例存在.

Producers of the same role are grouped together.

A different producer instance of the same producer group may be contacted by a broker to commit or roll back a transaction in case the original producer crashed after starting the transaction.

同一角色的生产组合在一起。

同一生产者组的 不同的生产者实例 可以通过broker提交或回滚事务的情况下，原始的生产开始交易后坠毁联系。

一类 Producer 的集合名称，这类 Producer 通常发送一类消息，且发送逻辑一致。

通常具有同样属性（处理的消息种类-topic、以及消息处理逻辑流程—分布式多个客户端）的一些producer可以归为同一个group。

在事务消息 机制中，如果发送某条消息的producer-A宕机，使得事务消息一直处于PREPARED状态并超时，则broker会回查同一个group的其他producer，确认这条消息应该commit 还是 rollback。

Warning: Considering the provided producer is sufficiently powerful at sending messages, only one instance is allowed per producer group and process to avoid unnecessarily initializing of producer instances.
翻译:
考虑到提供的生产者在发送消息方面足够强大，每个生产者组和过程只允许一个实例，以避免不必要地初始化生产者实例。

Consumer Group

Similar to previously mentioned producer group, consumers of the exactly same role are grouped together and named Consumer Group.

类似于前面提到的生产者组的完全相同的作用，消费者被组合在一起并命名消费组。

Consumer Group is a great concept with which achieving goals of load-balance and fault-tolerance, in terms of message consuming, is super easy.

消费群体是一个很大的概念，实现了负载平衡和容错性，在信息消费方面，超容易。

Warning: consumer instances of a consumer groupmusthave exactly same topic subscription(s).