上云无忧 > 文档中心 > 天翼云分布式消息服务RocketMQ消费者应用进程、消费组、消费者实例的关系
分布式消息服务RocketMQ
天翼云分布式消息服务RocketMQ消费者应用进程、消费组、消费者实例的关系

文档简介:
消费组可以有多个消费者实例,如图:
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

消费组可以有多个消费者实例:

同一进程,同一个消费组不允许有相同的消费者实例。

不同进程,不能创建相同消费者实例,可能产生两个实例分配到相同的队列,部分队列却没有消费的情部。

不同进程,不能创建相同消费者实例,如上图中的实例A,两个实例均连到Q1跟Q2,但Q3与Q4并无消费。
应用在创建消费者实例时,指定消费者实例名,应用需要保证不同的进程间,同一消费组不能有相同的实例名。或者应用在创建消费者实例时,不指定实例名,RocketMQ会创建唯一的实例名(JAVA SDK),规则是:groupName|ip|pid|线程id|uuid。

相似文档
  • RocketMQ 里的一个 Consumer Group 代表一个 Consumer 群组。对于大多数分布式应用来说,一个 Consumer Group 下通常会有多个 Consumer 实例。订阅关系一致指的是同一个 Consumer Group 下所有 Consumer 实例的处理逻辑必须完全一致,一旦订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。
  • 使用CTGFactory进行创建实例【强制规范】; Consumer是重量级的实例,每次创建、销毁都会消耗系统资源,建议系统启动的时候创建,系统退出的时候关闭,禁止每次消费消息都创建新的实例【强制规范】。
  • 一个Topic,可以使用多个消费组消费消息,每个消费组将在服务端独立保存进度。 集群消费意味着多个消费者均衡消费Topic的消息,由于经常不同的程序由多个开发者进行研发和调试,如果使用同一个消费组,在调试过程中存在被其他程序消费者消费的可能,因此应该尽量避免多种类型的应用程序使用同一个消费组。
  • 管理员可以通过《运维管理命令手册.docx》,重置消费进度,使用注意事项如下: 消费重置时间是指:消息的生产时间,而不是消息的消费时间。 resetOffsetByTimeOffline 客户端必须离线,重置后启动。 resetOffsetToLatest 客户端必须离线,重置后启动,重置到最新。
  • 不建议高堆积量的消费,为了预防出现高堆积的情况,建议: 边生产边消费,如果消费速度跟不上,增加消费者。 消费者一直在线,不要等生产了一段时间再开启消费者,这样会造成消费的堆积。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部