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/controller/localMQTTTestController.java | 66 +++++++++++++++++++++-----------
1 files changed, 43 insertions(+), 23 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
index b417ffa..cc8661a 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
@@ -1,12 +1,13 @@
package com.sandu.ximon.admin.localMQTT.controller;
import com.sandu.ximon.admin.localMQTT.util.MqttClientUtil;
+import com.sandu.ximon.admin.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
-import static com.sandu.ximon.admin.localMQTT.callback.StatusMqttCallBack.localMqttConnectStatusMap;
+import static com.sandu.ximon.admin.localMQTT.callback.StatusMqttCallBack.localMqttConnectStatus;
import static java.lang.Thread.sleep;
/**
@@ -24,7 +25,7 @@
@RequestMapping("/test")
public String localMQTT() throws InterruptedException {
- for (int i = 0; i < 100; i++) {
+ for (int i = 0; i < 1000; i++) {
/*
* 寮�鐏�100
@@ -40,29 +41,48 @@
* 5鍒嗛挓
* FEA501000CFE210004FFFF012C4A7824285825CB53
* */
-// 寮�10
- String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
- "FEA501000BFE010003FFFF0AA542FD69D4E6194E");
- log.info("寮�鐏繑鍥炵粨鏋�:"+result1);
- sleep(5000);
-// 鍏�
- String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
- "FEA501000BFE0100030001007130ECA9150640E6");
- log.info("鍏崇伅杩斿洖缁撴灉:"+result2);
- sleep(5000);
+//// 寮�10
+// String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+// "FEA501000BFE010003FFFF0AA542FD69D4E6194E");
+// log.info("寮�鐏繑鍥炵粨鏋�:"+result1);
+// sleep(5000);
+//// 鍏�
+// String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+// "FEA501000BFE0100030001007130ECA9150640E6");
+// log.info("鍏崇伅杩斿洖缁撴灉:"+result2);
+// sleep(5000);
//// 蹇冭烦鏌ヨ
- String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
- "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
- log.info("蹇冭烦鏌ヨ杩斿洖缁撴灉:"+result3);
- sleep(3000);
- String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
- "FEA501001AFE230012FE23000A00017F1019647F111E005428F600EC64EC194EA28A7C");
- log.info("瀹氭椂浠诲姟杩斿洖缁撴灉:"+result4);
- sleep(3000);
+// String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
+// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
+// log.info("蹇冭烦鏌ヨ杩斿洖缁撴灉:"+result3);
+// sleep(1000);
+// String result = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
+// "FEA501000CFE210004FFFF001E9BB444E9C75BDB49");
+// log.info("蹇冭烦璁剧疆杩斿洖缁撴灉:"+result);
+// sleep(1000);
+//// 璁剧疆蹇冭烦30绉�
+// String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
+// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
+// log.info("蹇冭烦鏌ヨ杩斿洖缁撴灉:"+result4);
+// sleep(1000);
+// String result5 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
+// "FEA501000CFE210004FFFF001E9BB444E9C75BDB49");
+// log.info("蹇冭烦鏌ヨ杩斿洖缁撴灉:"+result5);
+// sleep(1000);
+// String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+// "FEA501001AFE230012FE23000A00017F1019647F111E005428F600EC64EC194EA28A7C");
+// log.info("瀹氭椂浠诲姟杩斿洖缁撴灉:"+result4);
+// sleep(3000);
- System.out.println("閾炬帴鐘舵�侊細---"+i+"---:");
- System.out.println(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff"));
- sleep(3000);
+ boolean set = RedisUtils.getBean().set(localMqttConnectStatus+"363832544e5008ff4734ffff",0);
+ System.out.println(set);
+ System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
+ System.out.println("1".equals(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff")));
+ System.out.println("------------");
+
+// System.out.println("閾炬帴鐘舵�侊細---"+i+"---:");
+// System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
+ sleep(1000);
}
--
Gitblit v1.9.3