MQTT Endpoint

Mqtt Endpoint 用来创建和启动MQTT接收服务，它可以订阅不同主题数据，然后路由到不同规则链进行处理。

# Type

endpoint/mqtt

# 启动配置

该组件允许通关过server字段复用共享的连接客户端。参考组件连接复用。

字段	类型	是否必填	说明	默认值
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()或者exchange.Out.Msg.Metadata指定responseTopic参数，组件就会往指定的主题发送数据：

exchange.Out.GetMsg().Metadata.PutValue("responseTopic", "device.msg.response")
// or
exchange.Out.Headers().Add("responseTopic", "device.msg.response")

exchange.Out.SetBody([]byte("ok"))

1
2
3
4
5

响应参数配置：

字段	类型	是否必填	说明	默认值
responseTopic	string	是	响应主题	-
responseQos	int	否	响应QOS	0

# 示例

以下是使用endpoint的示例代码：

在 GitHub 上编辑此页

上次更新: 2025/09/08, 01:44:45

← Websocket Endpoint Schedule Endpoint→