From 694d691291f6ee89061fdbb9fd451ecb5519b69b Mon Sep 17 00:00:00 2001
From: Van333 <van666666@foxmail.com>
Date: 星期一, 05 十二月 2022 15:35:26 +0800
Subject: [PATCH] 在线状态由map改成redis，定时保持emqx链接
---
ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java
index f3cf820..3653e53 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/StatusMqttCallBack.java
@@ -10,6 +10,7 @@
import com.sandu.ximon.admin.manager.iot.amqp.processor.c3ChargingProcessor;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum;
+import com.sandu.ximon.admin.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.springframework.stereotype.Component;
@@ -34,7 +35,8 @@
private static final String localMqttConnectStatusDisconnected = "disconnected";
- public static final Map<String, Integer> localMqttConnectStatusMap = new ConcurrentHashMap<>();
+ public static final String localMqttConnectStatus = "localMqttConnectStatus.";
+
protected final static ExecutorService EXECUTOR_SERVICE = new ThreadPoolExecutor(
@@ -56,7 +58,7 @@
protected void handleReceiveMessage(String topic, String message) {
EXECUTOR_SERVICE.submit(() -> processMessage(topic,message));
- log.info("鎺ユ敹鍒版秷鎭�---StatusMqttCallBack:topic={},message={}", topic, message);
+// log.info("鎺ユ敹鍒版秷鎭�---StatusMqttCallBack:topic={},message={}", topic, message);
}
@@ -69,17 +71,15 @@
String mac = topic.split("/")[4];
String status = topic.split("/")[5];
- System.out.println("----------------------");
- System.out.println(mac);
- System.out.println(status);
if (status.equals(localMqttConnectStatusConnected)){
// 璁惧鏁版嵁涓婃姤
- localMqttConnectStatusMap.put(mac,1);
+ boolean set = RedisUtils.getBean().set(localMqttConnectStatus + mac, 1);
+ log.error("璁惧涓婄嚎------锛宮ac:{},涓婄嚎,{}",mac,set);
}
else if (status.equals(localMqttConnectStatusDisconnected)){
- localMqttConnectStatusMap.put(mac,0);
+ boolean set = RedisUtils.getBean().set(localMqttConnectStatus+mac,0);
+ log.error("璁惧涓嬬嚎------锛宮ac:{},涓嬬嚎.{}",mac,set);
}
-
} catch (Exception e) {
e.printStackTrace();
--
Gitblit v1.9.3