|
@@ -45,12 +45,12 @@ export function useMqtt() {
|
|
|
|
|
|
|
|
client.value.on('connect', () => {
|
|
client.value.on('connect', () => {
|
|
|
isConnected.value = true
|
|
isConnected.value = true
|
|
|
- ElMessage.success('MQTT 连接成功')
|
|
|
|
|
|
|
+ // ElMessage.success('MQTT 连接成功')
|
|
|
})
|
|
})
|
|
|
|
|
|
|
|
client.value.on('error', (err) => {
|
|
client.value.on('error', (err) => {
|
|
|
console.error('MQTT Error:', err)
|
|
console.error('MQTT Error:', err)
|
|
|
- ElMessage.error(`MQTT 错误: ${err.message}`)
|
|
|
|
|
|
|
+ ElMessage.error('服务器连接异常,请检查网络或稍后重试')
|
|
|
isConnected.value = false
|
|
isConnected.value = false
|
|
|
})
|
|
})
|
|
|
|
|
|
|
@@ -74,7 +74,8 @@ export function useMqtt() {
|
|
|
}
|
|
}
|
|
|
})
|
|
})
|
|
|
} catch (err) {
|
|
} catch (err) {
|
|
|
- ElMessage.error(`MQTT 初始化异常: ${(err as Error).message}`)
|
|
|
|
|
|
|
+ console.error('MQTT 初始化异常:', err)
|
|
|
|
|
+ ElMessage.error('系统连接组件加载失败,请尝试刷新页面')
|
|
|
isConnected.value = false
|
|
isConnected.value = false
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -83,8 +84,10 @@ export function useMqtt() {
|
|
|
const subscribe = (topic: string) => {
|
|
const subscribe = (topic: string) => {
|
|
|
if (client.value && client.value.connected) {
|
|
if (client.value && client.value.connected) {
|
|
|
client.value.subscribe(topic, { qos: 0 }, (err) => {
|
|
client.value.subscribe(topic, { qos: 0 }, (err) => {
|
|
|
- if (err) ElMessage.error(`订阅失败: ${err.message}`)
|
|
|
|
|
- else console.log(`已订阅: ${topic}`)
|
|
|
|
|
|
|
+ if (err) {
|
|
|
|
|
+ console.error(`订阅失败: ${err.message}`)
|
|
|
|
|
+ ElMessage.error('实时数据同步失败,请稍后重试')
|
|
|
|
|
+ } else console.log(`已订阅: ${topic}`)
|
|
|
})
|
|
})
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|