上云无忧 > 文档中心 > 天翼云分布式消息服务消费消息
分布式消息服务
天翼云分布式消息服务消费消息

文档简介:
操作场景 从消息队列中读取消息。 前提条件 已创建队列并创建消费组,且队列中存在消息。消息在队列中的保留时间为至少72小时,72小时后将会被删除。 操作步骤 步骤 1登录管理控制台。 步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

适用于杭州/南昌/青岛/福州/上海4/北京2/西安2/苏州/广州4/深圳节点


操作场景

从消息队列中读取消息。


前提条件

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


操作步骤

步骤 1登录管理控制台。

步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。

步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。

步骤 4打开“消费消息”页面,有如下两种方式:

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

在队列详情中打开:

a.单击指定队列的名称,显示队列详情。

b.选择“消费组”页签,显示消费组列表。

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

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

消费消息参数说明

参数

说明

消费组名称

消费组的名称。

从指定队列名称后面单击“消费消息”时,默认消费组为第一条。

从指定消费组名称后面单击“消费消息”时,默认消费组为指定的消费组。

每次最多消费消息

每次读取消息的最大条数。

取值范围:5条或10条。

默认值:5条。

消费间隔

离下次读取消息的时间间隔。

取值范围:3秒、5秒、10秒或30秒。

默认值:3秒。

消息类型

消息的类型。

取值范围:

l    普通消息

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

l    死信消息

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

默认值:普通消息

说明:2.1 创建队列时关闭死信,则消费类型只有普通消息。

消息标签

添加标签后可以按照Tag进行过滤,只消费匹配上标签的消息。

最多可添加3个标签。

勾选“匹配全部标签”时,必须所有标签匹配上,才能消费消息。否则,只要有一条标签匹配上,就可以消费消息。

Kafka队列没有消息标签。

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

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

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

说明:

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

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

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

已消费消息参数说明

参数

说明

消息概览

显示消息体的内容。

Kafka队列显示的内容为经过base64编码后的消息体。

消息ID

该消费组消费消息的handler。

消息体大小

该条消息的大小。

操作

单击“更多详情”可以显示完整的消息体、完整的消息ID、属性等。

Kafka队列没有“操作”列。

相似文档
  • 操作步骤 步骤 1登录管理控制台。 步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。 步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。 步骤 4单击指定队列的名称,显示队列详情。
  • 步骤 1登录管理控制台。 步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。 步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。 步骤 4勾选需要删除队列前的复选框。 步骤 5单击“删除队列”。 步骤 6单击“确定”,确认删除队列。
  • 步骤 1登录管理控制台。 步骤 2单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。 步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。 步骤 4单击指定队列的名称,显示队列详情。 步骤 5在需要删除的消费组所在行,单击消费组后的“更多”,选择“删除消费组”。 步骤 6单击“确定”,确认删除。
  • 步骤 1登录管理控制台。 步骤 2单击“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。 步骤 3单击左侧菜单栏的“队列管理”,进入“队列管理”页面。 步骤 4单击队列名称后的“更多”,选择“查看监控数据”,可以查看队列中的消息大小、消息总数、请求数量。 监控信息会在Cloud Eye中显示,并且数据更新周期为1分钟。
  • 如果想跳过某些未消费的消息,或者想重新消费队列中的已消费的消息,或者只想消费某个时间点之后的消息(这些消息不论之前是否消费过),那么可以通过“消费重置”功能实现选择性跳过或者重新消费。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部