管理AMQP消费组

工作原理

AMQP服务端订阅会将同一产品所有设备的指定类型消息，转发到一个或多个消费组中，每个消费组中随机一个消费者收到消息。不同消费组通过消费组ID区分，每个AMQP客户端只能配置一个消费组ID，每个消费组最多包括64个AMQP客户端。您需要先创建消费组，然后将消费组ID配置到AMQP客户端，最后配置AMQP服务端订阅。

• 订阅关系1：将产品1的消息转发到消费组1和消费组2。

• 订阅关系2：将产品2的消息转发到消费组2。

AMQP服务端订阅只能流转同一产品所有设备的指定类型消息，如果需要更灵活的流转设备消息。例如转发部分设备消息到AMQP客户端进行消费，可以使用物联网平台提供的云产品流转功能，先指定设备Topic消息转发至AMQP服务端订阅的消费组，进而流转到消费对应消费组的AMQP客户端，操作步骤请参见云产品流转。

创建消费组

1. 登录物联网平台控制台。

2. 在实例概览页签的全部环境下，找到对应的实例，单击实例卡片。

3. 在左侧导航栏，选择消息转发 > 服务端订阅，单击消费组列表页签。

4. 单击创建消费组。

5. 在创建消费组对话框中，输入组名，单击确认。

   消费组名称支持中文、英文字母、日文、数字和下划线（_），长度范围为4~30个字符。一个中文或日文占2个字符。

查看和监控消费组

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

1. 在消费组列表中，找到要查看的消费组，并单击对应的查看。

2. 在消费组状态页签，查看订阅消息的实时消息消费速率、堆积消息消费速率、消息堆积量、最近消费时间和在线客户端列表。

   当消息堆积量大于等于（≥）1时，消息堆积量右侧会显示清空按钮，您可清除堆积消息。

   说明

   消息组创建后：

   • 若未上线过，此时消费组处于离线状态，向消费组发送消息时，不会有消息堆积。

   • 若已上线，然后离线，此时消费组处于离线状态，向消费组发送消息时，会有消息堆积。

   

3. 在消费组状态页签，单击报警配置，然后在创建报警规则页面，配置云监控阈值报警规则，监控消费组消息堆积数、消费组消息消费速率，并接收报警消息。

   您需选择产品为物联网平台-服务端订阅，其他参数根据您的需求设置。具体操作，请参见创建阈值报警规则。

4. 在消费组详情页面，单击消费日志页签，可查看具体的消费记录。

删除消费组

用户创建的消费组可以删除，物联网平台的默认消费组不可删除。

1. 解除订阅。如果消费组已关联订阅关系，则需先解除订阅；如果消费组无订阅关系，请忽略此步骤。

   1. 在消费组列表中，单击消费组对应的查看。

   2. 在消费组详情页面的订阅产品页签下，单击产品名对应的解除订阅，再单击确认。

      说明

      如果该产品的服务端订阅只有一个消费组，则不能在消费组详情页面解除订阅。您可返回服务端订阅页面的订阅列表页签，编辑或删除订阅。

2. 在服务端订阅页面的消费组列表页签下，单击消费组对应的删除，然后单击确认。

相关文档

将消费组ID配置到AMQP客户端上，以接收消息，请参见：

• AMQP客户端接入说明

• Java SDK接入示例

• Node.js SDK接入示例

• .NET SDK接入示例

• Python 2.7 SDK接入示例

• Python3 SDK接入示例

• PHP SDK接入示例

• Go SDK接入示例

相关API