XMPoleManager.git

			@@ -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(3000);
			// 关
			String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff",
			"FEA501000BFE0100030001007130ECA9150640E6");
			log.info("关灯返回结果:"+result2);
			sleep(3000);
			//// 开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",
			// String result3 = MqttClientUtil.sendMqttMsg("363832544e5008ff4734ffff",
			// "FEA501000AFE110002FFFF26008FBE3DAC7C0D");
			// log.info("心跳查询返回结果:"+result3);
			// sleep(3000);
			// 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);

			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(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff"));
			// sleep(10000);
			// System.out.println(RedisUtils.getBean().get(localMqttConnectStatus+"363832544e5008ff4734ffff"));
			sleep(1000);

			}