js 使用Paho.mqtt连接mqtt 请给出示例
时间: 2023-11-19 09:05:37 浏览: 93
好的,以下是使用Paho.mqtt连接mqtt的js示例:
```javascript
// 创建一个 MQTT 客户端实例
var client = new Paho.MQTT.Client("mqtt服务器地址", "客户端ID");
// 设置连接选项
var options = {
userName: "用户名",
password: "密码",
onSuccess: onConnect,
onFailure: onFailure
};
// 连接到MQTT服务器
client.connect(options);
// 连接成功回调函数
function onConnect() {
console.log("连接成功!");
// 订阅主题
client.subscribe("要订阅的主题");
}
// 连接失败回调函数
function onFailure() {
console.log("连接失败!");
}
// 消息到达回调函数
client.onMessageArrived = function (message) {
console.log("收到消息:" + message.payloadString);
};
// 发布消息
function publishMessage() {
var message = new Paho.MQTT.Message("要发布的消息");
message.destinationName = "要发布的主题";
client.send(message);
}
```
以上代码实现了连接到MQTT服务器并订阅主题,同时也可以发布消息。需要注意的是,需要引入Paho.mqtt.js库。
阅读全文