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/client/MqttClientCreate.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/client/MqttClientCreate.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/client/MqttClientCreate.java
index 93cd4fd..68ed918 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/client/MqttClientCreate.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/client/MqttClientCreate.java
@@ -34,18 +34,19 @@
*/
public static final Map<String, MqttClient> MQTT_CLIENT_MAP = new ConcurrentHashMap<>();
+
/**
* 鍒涘缓MQTT瀹㈡埛绔�
*/
@PostConstruct
public void createMqttClient() {
- System.out.println("createMqttClient");
List<MqttClientVO> mqttClientList = mqttConfig.getClientList();
-
for (MqttClientVO mqttClient : mqttClientList) {
//鍒涘缓瀹㈡埛绔紝瀹㈡埛绔疘D锛歞emo锛屽洖璋冪被璺熷鎴风ID涓�鑷�
- System.out.println(mqttClient.getClientId());
mqttClientManager.createMqttClient(mqttClient.getClientId(), mqttClient.getSubscribeTopic(), mqttClient.getUserName(), mqttClient.getPassword());
+ System.out.println(mqttClient.getClientId()+"鍒涘缓瀹屾垚");
+
}
}
+
}
--
Gitblit v1.9.3