【云知易】DMS分布式消息服务 入门 03 创建消费组
生产消息
操作场景
向队列中发送消息。每条消息的大小不超过512KB(包括消息体和消息属性,消息体包括界面输入的内容和固定JSON格式部分的内容)。
前提条件
已创建队列。
操作步骤
登录管理控制台。
单击页面上方的,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。
单击左侧菜单栏的“队列管理”,进入“队列管理”页面。
打开生产消息的页面,有如下两种方式:
单击队列名称后的“生产消息”,进入“生产消息”的页面。
在队列详情中生产消息:
单击指定队列的名称,显示队列详情。
单击右上角的“生产消息”,进入“生产消息”页面。
填写消息正文。如需添加消息标签,则输入“消息标签”。如果需要添加消息属性,输入消息属性的名称和属性值,单击“添加”,可以添加消息属性。
表1 创建消息参数说明 参数
说明
消息正文
发送消息的正文。
在Console界面发送消息时,在”消息正文“框中输入的内容都会被转义为字符串,例如:"hello dms" 会转义成 \"hello dms\"。
消息标签(可选)
消息标签,即Tag,是通过对消息增加tag来区分队列中的消息分类,DMS允许消费者按照Tag对消息进行过滤,确保消费者最终只消费到他关心的消息类型。
消息标签只能包含a~z,A~Z,0-9,-,_,长度是[1,64]。
最多可添加3个标签。
Kafka队列没有消息标签。
消息属性(可选)
每条消息均可以定义消息属性,由属性名及属性值组成,以K-V的形式体现,并随消息一起被发送和消费,属于消息的一部分。
属性名不能为空,且一条消息中的属性名不能重复。
DMS会删除输入名称前后的空格,比如将处理成“abc”,所以对DMS来说,和“abc”是同一个属性名称。
消息属性的数量没限制,但您需要确保消息的大小不超过512KB,因为消息属性也是消息的一部分。
Kafka队列没有消息属性。
已经添加的属性会在列表中展示,单击“删除”可以删除已经添加的属性。
单击“确定”。
在队列所在行,您可以看到消息数量增加了一条。
如果您已经创建消费组,您可以在消费组所在行看到可消费消息数增加了一条。
- 点赞
- 收藏
- 关注作者
评论(0)