|
@@ -52,18 +52,13 @@ export function createMqttClient() {
|
|
|
client.on("message", (topic, message) => {
|
|
|
console.log("topic", topic, message);
|
|
|
console.log("接收到消息:", JSON.parse(message.toString()));
|
|
|
- const userId = uni.getStorageSync("userId");
|
|
|
const noticeMatch = /^\/mps\/wx_(.+)\/notice$/;
|
|
|
const match = topic.match(noticeMatch);
|
|
|
if (!match) return;
|
|
|
});
|
|
|
client.on("error", (err) => {
|
|
|
mqttCmdConnected = false;
|
|
|
- console.error("MQTT连接错误:", err);
|
|
|
- // 连接失败时重新尝试连接
|
|
|
- setTimeout(() => {
|
|
|
- createMqttClient(); // 重新连接
|
|
|
- }, 1000);
|
|
|
+ console.error("MQTTCMD连接错误:", err);
|
|
|
});
|
|
|
|
|
|
client.on("disconnect", () => {
|
|
@@ -83,9 +78,10 @@ export function createMqttData() {
|
|
|
if (mqttDataConnected) return mqttClientData;
|
|
|
|
|
|
const params = {
|
|
|
- keepalive: 15,
|
|
|
+ // keepalive: 15,
|
|
|
// clean: false,
|
|
|
// connectTimeout: 1500,
|
|
|
+ // reconnectPeriod: 2000
|
|
|
clientId: "xcx_mqtt_data1_" + uni.getStorageSync("userId") + "_" + Date.now(),
|
|
|
username: "lnradar",
|
|
|
password: "lnradar",
|
|
@@ -98,7 +94,6 @@ export function createMqttData() {
|
|
|
protocols: ["mqtt"],
|
|
|
});
|
|
|
},
|
|
|
- reconnectPeriod: 2000
|
|
|
};
|
|
|
|
|
|
mqttClientData = mqtt.connect("wxs://data.radar-power.cn/mqtt/", params);
|
|
@@ -115,7 +110,7 @@ export function createMqttData() {
|
|
|
|
|
|
});
|
|
|
|
|
|
- mqttClientData.on("error", (err) => { mqttDataConnected = false; console.error(err); });
|
|
|
+ mqttClientData.on("error", (err) => { mqttDataConnected = false; console.error("MQTTDATA连接错误:", err); });
|
|
|
mqttClientData.on("disconnect", () => { mqttDataConnected = false; console.log("DATA MQTT 断开"); });
|
|
|
mqttClientData.close = function (force = true) {
|
|
|
mqttClientData.end(force, () => {
|