消费消息

操作场景

从消息队列中读取消息。

前提条件

已创建队列并创建消费组，且队列中存在消息。消息在队列中的保留时间为72小时，72小时后会被删除。

操作步骤

1. 登录管理控制台。

2. 单击页面上方的，选择“应用服务 > 分布式消息服务”，进入分布式消息服务信息页面。

3. 单击左侧菜单栏的“队列管理”，进入“队列管理”页面。

4. 打开“消费消息”页面，有如下两种方式：

   
   

• 在队列名称后面单击“消费消息”，进入“消费消息”的页面。

• 在队列详情中打开：

1. 单击指定队列的名称，显示队列详情。

2. 选择“消费组”页签，显示消费组列表。

3. 在消费组的名称后面单击“消费消息”，进入“消费消息”页面。

5. 选择消费组名称、每次最多消费消息、消费间隔和消息类型，如需添加消息标签进行过滤，则输入“消息标签”，单击“开始消费”，开始消费消息。

   
   

   表1 消费消息参数说明

   参数	说明
   消费组名称	消费组的名称。 从指定队列名称后面单击“消费消息”时，默认消费组为第一条。 从指定消费组名称后面单击“消费消息”时，默认消费组为指定的消费组。
   每次最多消费消息	每次读取消息的最大条数。 取值范围：5条或10条。 默认值：5条。
   消费间隔	离下次读取消息的时间间隔。 取值范围：3秒、5秒、10秒或30秒。 默认值：3秒。
   消息类型	消息的类型。 取值范围： 默认值：普通消息 说明：创建队列时关闭死信，则消费类型只有普通消息。
   消息标签	添加标签后可以按照Tag进行过滤，只消费匹配上标签的消息。 最多可添加3个标签。 勾选“匹配全部标签”时，必须所有标签匹配上，才能消费消息。否则，只要有一条标签匹配上，就可以消费消息。 Kafka队列没有消息标签。

   单击“开始消费”，消息将会持续消费5分钟，即使队列中没有消息，5分钟后，消费消息会自动停止。如果需要停止消费消息，您可以单击“停止”，消息消费将会在本次消费完成后停止。

   如果您在消费过程更换消费消息参数（消费组名称、每次最多消费消息、消费间隔、消息类型）或关闭消息消费的对话框，消息消费将会在本次消费完成后停止。

   已经消费的消息会在列表中展示，单击某一条消息后的“更多详情”可以查看消息的正文、大小、消息ID、属性个数、属性名称和属性值。在查看属性详情期间，消息消费不会停止。

    说明：

• 每条消息只能被同一个消费组消费一次，消费成功后，该消费组无法再次消费该条消息，但是其它消费组仍然可以消费。关闭消息消费对话框或更换消费组后无法查看到已消费消息。

• 一个队列中的消息存储在多个不同的分区，多分区设计提升了消费并发度，可同时处理同一个消费组的多个消费请求。为了性能考虑，每个消费请求只能消费一个分区中的消息，避免跨多个分区缓存管理和访问带来性能损失，当消息数量较少时，单个分区的消息数量可能小于指定的消费消息数量，这样单次消费请求返回的消息数会少于指定的消费消息数量，但是多次消费请求会自动负载均衡到不同的分区，所有分区的消息最终都将被消费。

• 每个消费组只支持一种Tag规则，如果第二次消费更换了Tag规则，则消费失败，但是已消费失败的消息，该消费组无法再重新消费，除非重置消费位置。

• 普通消息

  选择消费普通消息时，只能消费该队列中的普通消息。

• 死信消息

  选择消费死信消息时，只能消费该消费组产生的死信消息。