From b531004a3cbd33d7bb9f5b7dce06ddd4f5e7ec9a Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 18 十一月 2022 11:57:02 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/xm-20221107' into xm-20221107
---
ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java | 72 ++++++++++++++++++++++++++++++++++++
1 files changed, 72 insertions(+), 0 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
new file mode 100644
index 0000000..9fcf3dd
--- /dev/null
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/controller/localMQTTTestController.java
@@ -0,0 +1,72 @@
+package com.sandu.ximon.admin.localMQTT.controller;
+
+import com.sandu.ximon.admin.localMQTT.util.MqttClientUtil;
+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 java.lang.Thread.sleep;
+
+/**
+ * @author van
+ * @version 1.0
+ * msg锛�
+ * @date 2022/11/11 14:18
+ */
+@RestController
+@RequestMapping("/localMQTT")
+@Slf4j
+public class localMQTTTestController {
+
+
+ @RequestMapping("/test")
+ public String localMQTT() throws InterruptedException {
+
+ for (int i = 0; i < 100; i++) {
+
+ /*
+ * 寮�鐏�100
+ * FEA501000BFE010003FFFF0045971477B6D8C2CA
+ * 10
+ * FEA501000BFE010003FFFF0AA542FD69D4E6194E
+ * 鍏崇伅
+ * FEA501000BFE0100030001007130ECA9150640E6
+ * 鏌ヨ蹇冭烦鏃堕棿
+ * FEA501000AFE110002FFFF26008FBE3DAC7C0D
+ * 璁剧疆蹇冭烦30绉�
+ * FEA501000CFE210004FFFF001E9BB444E9C75BDB49
+ * 5鍒嗛挓
+ * FEA501000CFE210004FFFF012C4A7824285825CB53
+ * */
+// 寮�10
+ String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+ "FEA501000BFE010003FFFF0AA542FD69D4E6194E");
+ log.info("寮�鐏繑鍥炵粨鏋�:"+result1);
+ sleep(3000);
+// 鍏�
+ String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+ "FEA501000BFE0100030001007130ECA9150640E6");
+ log.info("鍏崇伅杩斿洖缁撴灉:"+result2);
+ sleep(3000);
+//// 蹇冭烦鏌ヨ
+// String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
+// log.info("蹇冭烦鏌ヨ杩斿洖缁撴灉:"+result3);
+// sleep(3000);
+// String result4 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
+// "FEA501001AFE230012FE23000A00017F1019647F111E005428F600EC64EC194EA28A7C");
+// log.info("瀹氭椂浠诲姟杩斿洖缁撴灉:"+result4);
+// sleep(3000);
+
+// System.out.println("閾炬帴鐘舵�侊細---"+i+"---:");
+// System.out.println(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff"));
+// sleep(10000);
+
+ }
+
+
+ return "OK";
+ }
+}
--
Gitblit v1.9.3