跳到主要内容
版本:2.0.19

RABBITMQ

场景说明

业务触发的指令下发,会经由RabbitMQ消息队列统一接收,再依赖定制服务完成统一下发至网关,通过主题的映射配置可以极大的简化指令下发链路

本示例演示:通过RabbitMQ精准推送指令消息。

前提条件

  • 拥有可使用的RabbitMQ实例

配置指令消费实例

1. 选择左侧导航栏的“指令消费”,单击左上角的“+”来新建指令消费配置。

rabbitmq_cmd_1.png

2. 配置界面参考下表参数说明,填写相关内容。以下参数取值仅为示例,填写完成后单击“提交”。

rabbitmq_cmd_2.png

编辑指令消费

参数名参数说明
指令消费类型默认,如:RABBITMQ
指令消费名称指令消费实例名,如:param_cmd
是否启用开启/关闭按钮

数据源配置

参数名参数说明
host指定rabbitmq集群地址ip,如:127.0.0.1
portrabbitmq通信连接端口,如:5672
usernamerabbitmq用户名,如:guest
passwordrabbitmqQ密码,如:guest
vhost指定虚拟主机,如:/
更多属性通过点击【添加属性字段】,设置更多自定义属性

主题映射

参数名参数说明
订阅源主题自rabbitmq消费主题名
MQTT主题发送mqtt的主题名(如果下发的指令是JSON格式,可以通过${变量名}动态映射互踢),参考下面参数集
Qos消息语义(至多一次,至少一次,精准一次)
Retain指定mqtt主题接收的数据是否保留

变量集

参数名参数说明参数结构
valuerabbitmq的报文体,如果是json格式,可以通过value.{key}获取变量Object
tsrabbitmq消息的时间戳Long
message_idrabbitmq消息的序列号idLong
topicrabbitmq主题String
exchangerabbitmq交换机String
routing_keyrabbitmq路由keyString
headers消息header,可以通过 headers.{key}获取headerMap