文档

管理AMQP消费组

更新时间:
重要

本文中含有需要您注意的重要提示信息,忽略该信息可能对您的业务造成影响,请务必仔细阅读。

消费组是消息消费端的身份标识,多个消费者组成消息消费组接入物联网平台。设置AMQP服务端订阅后,物联网平台会将收到的设备消息转发到相应消费组,每条被流转到消费组的消息会被其中一个消费者接收。本文介绍如何在物联网平台创建、查看和删除消费组。

工作原理

image

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客户端上,以接收消息,请参见:

相关API

API

描述

CreateConsumerGroup

创建一个消费组,用于创建AMQP服务端订阅。

UpdateConsumerGroup

修改消费组名称。

QueryConsumerGroupByGroupId

根据消费组ID查询消费组详情。

QueryConsumerGroupList

查询用户所有消费组列表,或按消费组名称进行模糊查询。

QueryConsumerGroupStatus

使用AMQP服务端订阅时,查询某个消费组的状态,包括在线客户端信息、消息消费速率、消息堆积数、最近消息消费时间。

ResetConsumerGroupPosition

使用AMQP服务端订阅时,清空某个消费组的堆积消息。

DeleteConsumerGroup

删除消费组。