diff --git a/src/utils/mqtt/index.js b/src/utils/mqtt/index.js index fbd1da7..59580fe 100644 --- a/src/utils/mqtt/index.js +++ b/src/utils/mqtt/index.js @@ -54,13 +54,7 @@ function doSubscribe (topic, callBack) { } store.state.app.mqttState = true // 标记mqtt链接成功 在线 // 订阅一个主题 - this.client.subscribe(topic, { qos: 2 }, err => { - if (!err) { - store.dispatch('fetchLog', { content: topic + '主题订阅成功' }) - } else { - store.dispatch('fetchLog', { content: topic + '主题订阅失败' }) - } - }) + this.client.subscribe(topic, { qos: 2 }) }) // 获取订阅主题的消息 this.client.on('message', (topic, message) => { diff --git a/src/views/layout/index.vue b/src/views/layout/index.vue index 53d4283..42dc851 100644 --- a/src/views/layout/index.vue +++ b/src/views/layout/index.vue @@ -76,6 +76,7 @@ export default { */ airList (res) { /* mqtt */ + mqtt.mqttDestroy()// 先断开mqtt mqtt.mqttConf()// 连接mqtt // 订阅飞机信息 mqtt.doSubscribe('planeState/+', (mqttRes) => {