更新时间:2022-02-21 GMT+08:00

生产消息

操作场景

向队列中发送消息。

每条消息的大小不超过512KB(包括消息体和消息属性,消息体包括界面输入的内容和固定JSON格式部分的内容)。

使用Kafka SDK接口生产消息到高级队列时,单条消息最大限制为10MB。使用管理控制台生产消息到高级队列时,最大限制依然是512KB。

前提条件

已创建队列。

操作步骤

  1. 登录管理控制台。
  2. 在管理控制台左上角单击,选择区域。

    此处请选择与您的应用服务相同的区域。

  3. 单击页面上方的“服务列表”,选择“应用服务 > 分布式消息服务”,进入分布式消息服务信息页面。
  4. 单击左侧菜单栏的“队列管理”,进入“队列管理”页面。
  5. 打开生产消息的页面,有如下两种方式:

    • 单击队列名称后的“生产消息”,进入“生产消息”的页面。
    • 在队列详情中生产消息:
      1. 单击指定队列的名称,显示队列详情。
      2. 单击右上角的“生产消息”,进入“生产消息”页面。

  6. 填写如表1所示信息。

    如需添加消息标签,则输入“消息标签”。

    如果需要添加消息属性,则输入消息属性的名称和属性值,单击“添加”。
    表1 创建消息参数说明

    参数

    说明

    消息正文

    发送消息的正文。

    在Console界面发送消息时,在“消息正文”框中输入的内容都会被转义为字符串,例如:"it's not you, it's me" 会转义成 \"it's not you, it's me\"。

    延时消息

    是否开启延时消息。

    延时消息是指消息发送到DMS服务后,并不期望这条消息立即被消费,而是延迟一段时间后才能被消费。

    仅普通队列可以开启延时消息,高级队列不支持延时消息的功能。

    延时时长

    开启延时消息时,设置延时的时长。

    取值范围:1分钟、5分钟、30分钟、1小时或1天。

    默认值:5分钟。

    消息标签(可选)

    消息标签,即Tag,是通过对消息增加Tag来区分队列中的消息分类,DMS允许消费者按照Tag对消息进行过滤,确保消费者最终只消费到他关心的消息类型。

    消息标签只能包含a~z,A~Z,0-9,-,_,长度是[1,64]。

    最多可添加3个标签。

    仅普通队列有消息标签,高级队列不支持消息标签的功能。

    消息属性(可选)

    每条消息均可以定义消息属性,由属性名及属性值组成,以K-V的形式体现,并随消息一起被发送和消费,属于消息的一部分。

    属性名不能为空,且一条消息中的属性名不能重复。

    输入属性名和属性值时,DMS会删除输入名称前后的空格,中间有空格会保留。比如将“ ab c ”处理成“ab c”,所以对DMS来说,“ ab c ”和“ab c”是同一个属性名称或者属性值。

    说明:

    属性名和属性值,仅在Web Console输入时前后去掉空格,使用API接口访问DMS时,不会去掉前后空格。

    消息属性的数量没限制,但您需要确保消息的大小不超过512KB,因为消息属性也是消息的一部分。

    仅普通队列有消息属性,高级队列没有消息属性。

    已经添加的属性会在列表中展示,单击“删除”可以删除已经添加的属性。

  7. 单击“确定”。

    在队列所在行,您可以看到消息数量增加了一条。

    如果您已经创建消费组,您可以在消费组所在行看到可消费消息数增加了一条。