修改

task_script/LIVESTOCK_MQTT_CLIENT.php

@@ -252,7 +252,7 @@ function loop()
         $data['data_type']='reportData';
         mqttToRedis(json_encode($data));
     }, 1);
-    $mqtt->subscribe('earings/+/coludResp', function ($topic, $message) use($mqtt) {
+    $mqtt->subscribe('earings/+/cloudResp', function ($topic, $message) use($mqtt) {
         rlog("coludResp", 'recv', $topic, $message);
         $topicArr=explode('/',$topic);
         $data=json_decode($message,true);
@@ -260,7 +260,7 @@ function loop()
         $data['data_type']='coludResp';
         mqttToRedis(json_encode($data));
     }, 1);
-    $mqtt->subscribe('earings/+/coludControl', function ($topic, $message) use($mqtt) {
+    $mqtt->subscribe('earings/+/cloudControl', function ($topic, $message) use($mqtt) {
         rlog("coludControl", 'recv', $topic, $message);
         $topicArr=explode('/',$topic);
         $data=json_decode($message,true);