MQTT Endpoint
Mqtt Endpoint 用来创建和启动MQTT接收服务,它可以订阅不同主题数据,然后路由到不同规则链进行处理。
# Type
mqtt
# 启动配置
字段 | 类型 | 是否必填 | 说明 | 默认值 |
---|---|---|---|---|
Server | string | 是 | mqtt broker地址 | - |
Username | string | 否 | 用户名 | 0 |
Password | string | 否 | 密码 | - |
QOS | int | 否 | QOS | 0 |
CleanSession | bool | 否 | CleanSession | false |
ClientID | string | 否 | 客户端ID | 默认随机数 |
CAFile | string | 否 | CA文件路径 | - |
CertFile | string | 否 | Cert文件路径 | - |
CertKeyFile | string | 否 | CertKey文件路径 | - |
# 响应
exchange.Out.SetBody
响应之前,需要通过exchange.Out.Headers()
指定topic
参数,组件就会往指定的主题响应数据:
exchange.Out.Headers().Add("topic", "device.msg.response")
exchange.Out.SetBody([]byte("ok"))
1
2
2
响应参数配置:
字段 | 类型 | 是否必填 | 说明 | 默认值 |
---|---|---|---|---|
topic | string | 是 | 主题 | - |
qos | int | 否 | QOS | 0 |
# 示例
以下是使用endpoint的示例代码:
在 GitHub 上编辑此页 (opens new window)
上次更新: 2024/06/16, 16:49:02