| | |
| | | String result1 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff", |
| | | "FEA501000BFE010003FFFF0AA542FD69D4E6194E"); |
| | | log.info("开灯返回结果:"+result1); |
| | | sleep(3000); |
| | | sleep(5000); |
| | | // 关 |
| | | String result2 = MqttClientUtil.sendMqttMsg("363832544e5008ff3a32ffff", |
| | | "FEA501000BFE0100030001007130ECA9150640E6"); |
| | | log.info("关灯返回结果:"+result2); |
| | | sleep(3000); |
| | | 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("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); |
| | | System.out.println("链接状态:---"+i+"---:"); |
| | | System.out.println(localMqttConnectStatusMap.get("363832544e5008ff3a32ffff")); |
| | | sleep(3000); |
| | | |
| | | } |
| | | |