|
@@ -128,7 +128,7 @@ const initMqttManager = async () => {
|
|
|
host: import.meta.env.VITE_MQTT_HOST_ALARM,
|
|
|
username: import.meta.env.VITE_MQTT_USERNAME,
|
|
|
password: import.meta.env.VITE_MQTT_PASSWORD,
|
|
|
- clientId: `mqtt_client_${Math.random().toString(16).slice(2, 8)}`,
|
|
|
+ clientId: `web_mqtt_cmd1`,
|
|
|
}
|
|
|
mqttClient = mqtt.connect(mqttConfig.host, {
|
|
|
clientId: mqttConfig.clientId,
|
|
@@ -159,14 +159,14 @@ const initMqttManager = async () => {
|
|
|
else console.log('✅ 已发送参数:', messageData)
|
|
|
})
|
|
|
// 订阅所有主题
|
|
|
- mqttClient?.subscribe(`/mps/client/connect/`, (err) => {
|
|
|
+ mqttClient?.subscribe(`/mps/client/connect/`, { qos: 2 }, (err) => {
|
|
|
if (err) {
|
|
|
console.error('MQTT订阅失败', err)
|
|
|
} else {
|
|
|
console.log(`🔥已订阅主题 /mps/client/connect`)
|
|
|
}
|
|
|
})
|
|
|
- mqttClient?.subscribe(`/mps/wb_${userStore.userInfo?.userId}/notice`, (err) => {
|
|
|
+ mqttClient?.subscribe(`/mps/wb_${userStore.userInfo?.userId}/notice`, { qos: 2 }, (err) => {
|
|
|
if (err) {
|
|
|
console.error('MQTT订阅失败', err)
|
|
|
} else {
|