服务端流转

更新时间:

云消息队列 MQTT 版支持与云消息队列 RocketMQ 版的数据流转功能,本文为您介绍数据流转中的属性字段的映射关系。

功能说明

云消息队列 MQTT 版可以通过数据互通规则实现与其他阿里云产品的交互,例如云消息队列 RocketMQ 版。规则的详细信息,请参见规则管理

使用限制

  • 云消息队列 MQTT 版的实例必须支持MQTT 5.0协议。

  • 云消息队列 RocketMQ 版的实例必须为4.x的实例。

属性字段映射

云消息队列 MQTT 版云端SDK和云消息队列 RocketMQ 版都可以消费和发送MQTT 5.0的消息,并且可以设置与读取用户属性,具体的属性字段映射关系如下表所示。

MQTT参数

RocketMQ属性Key

属性可选值

说明

QoS

qoslevel

0、1、2

云消息队列 RocketMQ 版发给云消息队列 MQTT 版消息时可以设置,如果不设置,默认为“1”;

云消息队列 MQTT 版发给云消息队列 RocketMQ 版的消息可以直接读取。

MQTT全量Topic

topic

具体的全量Topic字符串

不可设置,云消息队列 MQTT 版发给云消息队列 RocketMQ 版消息时,用于追踪该消息的发送源的全量Topic。

MQTT子级Topic

mqttSecondTopic

具体的子级Topic字符串

云消息队列 RocketMQ 版发给云消息队列 MQTT 版客户端消息时如果需要子级Topic来做过滤,则设置,如不设置,默认为空;

云消息队列 MQTT 版发给云消息队列 RocketMQ 版的消息可以直接读取。

客户端接收消息显示Topic

mqttRealTopic

业务上希望客户端收到消息时显示的子级字符串

云消息队列 RocketMQ 版发给云消息队列 MQTT 版客户端消息时如果希望客户端收到消息后显示成指定的子级Topic名称,则可以设置;一般用于P2P消息,若不设置,P2P消息默认使用自己固定的Topic;

云消息队列 MQTT 版发给云消息队列 RocketMQ 版的消息时无该属性。

clientId

clientId

具体的Client ID字符串

不可设置,云消息队列 MQTT 版发给云消息队列 RocketMQ 版消息时,用于追踪该消息的发送源的Client ID。

MQTT消息的用户属性

mqtt5UserProperty

长度不能超过8K, 例如 :

[{"key":"mQ","value":"test001"},{"key":"MQ","value":"test002"}]

发送消息时指定的用户属性信息。

MQTT消息的过期时间

mqtt5MsgExpireInterval

0-65535,单位s

发送消息时指定的过期时间。

MQTT消息的内容类型

mqtt5ContentType

UTF-8

发送消息时指定的编码类型。