管理消费组 - 阿里云物联网平台

消费组是消息消费端的身份标识。消息消费端以消费组身份接入物联网平台，并接收物联网平台转发到消费组的消息。本文介绍如何在物联网平台添加、查看和删除消费组。

功能说明

您可通过以下方法监听消费组，获取转发的消息。

配置AMQP服务端订阅：使用AMQP服务端订阅功能，订阅某产品下全部设备的指定类型消息，并将消息流转到指定消费组。
服务端订阅和云产品流转的区别，请参见数据流转方案对比。
设置数据流转规则：使用云产品流转功能，将指定Topic中的消息流转到AMQP服务端订阅消费组。

将消费组ID配置到AMQP客户端上，AMQP客户端以消费组身份接入物联网平台，接收消息。具体说明，请参见AMQP客户端接入说明。

多个AMQP客户端（最多64个）可以使用同一个消费组ID，组成消息消费集群。当设备消息到达时，物联网平台将消息随机发往消费组ID中的任一个客户端。

重要

多个消费组需对应启动多个AMQP客户端，即单次启动的一个AMQP客户端中不可以配置多个消费组ID。

登录物联网平台控制台。
在实例概览页签的全部环境下，找到对应的实例，单击实例ID或备注名称。
重要
目前仅开通企业版实例服务的地域下，执行此步骤。其他地域，请跳过此步骤，执行下一步。地域及实例的支持说明，请参见实例概述。
在左侧导航栏，选择消息转发 > 服务端订阅，单击消费组列表页签。
单击创建消费组。
在创建消费组对话框中，输入组名，单击确认。
消费组名称支持中文、英文字母、日文、数字和下划线（_），长度范围为4~30个字符。一个中文或日文占2个字符。

您可以查看消费组内的消息消费速率、消息堆积量，也可以设置云监控报警规则来监控消费组。

在消费组列表中，找到要查看的消费组，并单击对应的查看。
在消费组状态页签，查看订阅消息的实时消息消费速率、堆积消息消费速率、消息堆积量、最近消费时间和在线客户端列表。
当消息堆积量大于等于（≥）1时，消息堆积量右侧会显示清空按钮，您可清除堆积消息。
说明
消息组创建后：
- 若未上线过，此时消费组处于离线状态，向消费组发送消息时，不会有消息堆积。
- 若已上线，然后离线，此时消费组处于离线状态，向消费组发送消息时，会有消息堆积。
在消费组状态页签，单击报警配置，然后在创建报警规则页面，配置云监控阈值报警规则，监控消费组消息堆积数、消费组消息消费速率，并接收报警消息。
您需选择产品为物联网平台-服务端订阅，其他参数根据您的需求设置。具体操作，请参见创建阈值报警规则。
在消费组详情页面，单击消费日志页签，可查看具体的消费记录。

您创建的消费组可以删除，物联网平台的默认消费组不可删除。删除消费组后，该组内的所有消费端会停止接收消息。

警告

删除消费组成功后，如果服务端订阅中使用了该消费组，会导致服务端订阅服务不可用、用户业务中断。请谨慎操作。

解除订阅。如果消费组已关联订阅关系，则需先解除订阅；如果消费组无订阅关系，请忽略此步骤。
1. 在消费组列表中，单击消费组对应的查看。
2. 在消费组详情页面的订阅产品页签下，单击产品名对应的解除订阅，再单击确认。
  说明
  如果该产品的服务端订阅只有一个消费组，则不能在消费组详情页面解除订阅。您可返回服务端订阅页面的订阅列表页签，编辑或删除订阅。
在服务端订阅页面的消费组列表页签下，单击消费组对应的删除，然后单击确认。

API	描述
CreateConsumerGroup	创建一个消费组，用于创建AMQP服务端订阅。
UpdateConsumerGroup	修改消费组名称。
QueryConsumerGroupByGroupId	根据消费组ID查询消费组详情。
QueryConsumerGroupList	查询用户所有消费组列表，或按消费组名称进行模糊查询。
QueryConsumerGroupStatus	使用AMQP服务端订阅时，查询某个消费组的状态，包括在线客户端信息、消息消费速率、消息堆积数、最近消息消费时间。
ResetConsumerGroupPosition	使用AMQP服务端订阅时，清空某个消费组的堆积消息。
DeleteConsumerGroup	删除消费组。