大屏数据

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/controller/EnvDeviceEquipmentController.java

@@ -70,6 +70,7 @@ public class EnvDeviceEquipmentController {
             jsonObject.put("dev_ctrl",i);
             log.info("消息配置完成开始发送："+jsonObject.toJSONString());
             publishMQTT.start("tcp://115.238.57.190:1883",chipId,"admin","admin","huimv_down_"+chipId,jsonObject.toJSONString());
+
             return new Result(10000,"修改成功",true);
         }catch (Exception e){
             System.out.println("22222222222"+e);

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/publish/PublishMQTT.java

@@ -51,7 +51,7 @@ public class PublishMQTT {
 
 //            pubMessage(client,"list",topic);
             MqttMessage mess = new MqttMessage();
-            mess.setQos(2);
+            mess.setQos(1);
             mess.setRetained(true);
             mess.setPayload(message.getBytes());
             try {

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/subscribe/PushCallback.java

@@ -133,9 +133,8 @@ public class PushCallback implements MqttCallback {
             PublishMQTT publishMQTT = new PublishMQTT();
             publishMQTT.start("tcp://115.238.57.190:1883", chip, "admin", "admin", "huimv_down_" + chip, jsonObject.toJSONString());
             log.info("---设备控制发送完成---");
-        }  else if (messages.equals("dev_ctrl_suc")) {
-            PublishMQTT publishMQTT = new PublishMQTT();
-            publishMQTT.start("tcp://115.238.57.190:1883", chip, "admin", "admin", "huimv_down_" + chip,"已应答");
+        }  else if ("dev_ctrl_suc".equals(messages)) {
+            System.out.println("收到控制响应");
         } else {
             JSONObject jsonObject = JSON.parseObject(messages);
             System.out.println("这里是1111：" + jsonObject);

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/uplod/UploadMqtt.java

@@ -25,7 +25,7 @@ public class UploadMqtt extends Thread {
 
     @SneakyThrows
     @Override
-    public void run() {
+    public synchronized void  run() {
         try {
             // host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
             client = new MqttClient(HOST, clientid, new MemoryPersistence());

huimv-env-platform/huimv-env-manage/src/main/java/com/huimv/env/manage/saas/mqtt/uplod/UploadMqttStart.java

@@ -15,7 +15,7 @@ public class UploadMqttStart {
     private IEnvDeviceRegisterService deviceRegisterService;
 
     @PostConstruct
-    public void test() {
+    public  void  test() {
         List<EnvDeviceRegister> list = deviceRegisterService.list();
         for (EnvDeviceRegister deviceRegister : list) {
             String chipId = deviceRegister.getChipId();