消费组是消息消费端的身份标识。消息消费端以消费组身份接入物联网平台,并接收物联网平台转发到消费组的消息。本文介绍如何在物联网平台添加、查看和删除消费组。
背景信息
- 功能说明:
您可通过以下方法监听消费组,获取转发的消息。
- 配置AMQP服务端订阅:使用AMQP服务端订阅功能,订阅某产品下全部设备的指定类型消息,并将消息流转到指定消费组。
- 设置数据流转规则:使用云产品流转功能,将指定Topic中的消息流转到AMQP服务端订阅消费组。
服务端订阅和云产品流转的区别,请参见数据流转方案对比。
- 使用说明:
将消费组ID配置到AMQP客户端上,AMQP客户端以消费组身份接入物联网平台,接收消息。具体说明,请参见AMQP客户端接入说明。
多个AMQP客户端(最多64个)可以使用同一个消费组ID,组成消息消费集群。当设备消息到达时,物联网平台将消息随机发往消费组ID中的任一个客户端。
创建消费组
- 登录物联网平台控制台。
- 在实例概览页面,找到对应的实例,单击实例进入实例详情页面。重要 目前华东2(上海)、华北2(北京)、华南1(深圳)地域开通了企业版实例服务。其他地域,请跳过此步骤。
- 在左侧导航栏,选择消费组列表页签。 ,单击
- 单击创建消费组。
- 在创建消费组对话框中,输入组名,单击确认。消费组名称支持中文、英文字母、日文、数字和下划线(_),长度范围为4~30个字符。一个中文或日文占2个字符。
查看和监控消费组
您可以查看消费组内的消息消费速率、消息堆积量,也可以设置云监控报警规则来监控消费组。
- 在消费组列表中,找到要查看的消费组,并单击对应的查看。
- 在消费组状态页签,查看订阅消息的实时消息消费速率、堆积消息消费速率、消息堆积量、最近消费时间和在线客户端列表。当消息堆积量大于等于(≥)1时,消息堆积量右侧会显示清空按钮,您可清除堆积消息。说明 消息组创建后:
- 若未上线过,此时消费组处于离线状态,向消费组发送消息时,不会有消息堆积。
- 若已上线,然后离线,此时消费组处于离线状态,向消费组发送消息时,会有消息堆积。
- 在消费组状态页签,单击报警配置,然后在创建报警规则页面,配置云监控阈值报警规则,监控消费组消息堆积数、消费组消息消费速率,并接收报警消息。
- 在消费组详情页面,单击消费日志页签,可查看具体的消费记录。
删除消费组
您创建的消费组可以删除,物联网平台的默认消费组不可删除。删除消费组后,该组内的所有消费端会停止接收消息。
警告 删除消费组成功后,如果服务端订阅中使用了该消费组,会导致服务端订阅服务不可用、用户业务中断。请谨慎操作。
- 解除订阅。如果消费组已关联订阅关系,则需先解除订阅;如果消费组无订阅关系,请忽略此步骤。
- 在服务端订阅页面的消费组列表页签下,单击消费组对应的删除,然后单击确认。
相关文档
将消费组ID配置到AMQP客户端上,以接收消息,请参见:
相关API
API | 描述 |
---|---|
CreateConsumerGroup | 创建一个消费组,用于创建AMQP服务端订阅。 |
UpdateConsumerGroup | 修改消费组名称。 |
QueryConsumerGroupByGroupId | 根据消费组ID查询消费组详情。 |
QueryConsumerGroupList | 查询用户所有消费组列表,或按消费组名称进行模糊查询。 |
QueryConsumerGroupStatus | 使用AMQP服务端订阅时,查询某个消费组的状态,包括在线客户端信息、消息消费速率、消息堆积数、最近消息消费时间。 |
ResetConsumerGroupPosition | 使用AMQP服务端订阅时,清空某个消费组的堆积消息。 |
DeleteConsumerGroup | 删除消费组。 |