提交 09ddfebf authored 作者: 詹银鑫's avatar 詹银鑫

mqtt 修改

上级 1afdbf74
...@@ -2,15 +2,17 @@ import mqtt from 'mqtt' ...@@ -2,15 +2,17 @@ import mqtt from 'mqtt'
// MQTT 配置 // MQTT 配置
const options = { const options = {
clean: true, // clean: true,
connectTimeout: 4000, keepalive: 30, // 心跳间隔(秒)
clientId: 'vue3-client-' + Math.random().toString(16).substr(2, 8), connectTimeout: 15000, // 连接超时(毫秒)
username: 'your_username', // 如果需要认证 clientId: 'web-client-' + Math.random().toString(16).substring(2, 8),
password: 'your_password' // username: '', // 如果需要认证
// password: '',
protocolVersion: 4,
} }
// MQTT 代理地址(示例使用公共测试服务器) // MQTT 代理地址(示例使用公共测试服务器)
const brokerUrl = 'ws://test.mosquitto.org:8080/mqtt' const brokerUrl = 'ws://192.168.1.177:1883/mqtt'
class MQTTClient { class MQTTClient {
constructor() { constructor() {
...@@ -18,12 +20,14 @@ class MQTTClient { ...@@ -18,12 +20,14 @@ class MQTTClient {
} }
connect() { connect() {
console.log('Connecting to MQTT...')
console.log("brokerUrl", brokerUrl)
this.client = mqtt.connect(brokerUrl, options) this.client = mqtt.connect(brokerUrl, options)
// 连接成功 // 连接成功
this.client.on('connect', () => { this.client.on('connect', () => {
console.log('MQTT Connected') console.log('MQTT Connected')
this.subscribe('your/topic') this.subscribe('/ctl/mqtt/test')
}) })
// 错误处理 // 错误处理
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论