|
|
@@ -10,7 +10,6 @@ define('PASSWORD', 'R!478gH*%23nPn');
|
|
|
define('DATABASE', 2);
|
|
|
|
|
|
|
|
|
-
|
|
|
function app_redis()
|
|
|
{
|
|
|
static $redis = null;
|
|
|
@@ -146,9 +145,6 @@ function loop()
|
|
|
->setKeepAliveInterval(60)
|
|
|
;
|
|
|
|
|
|
- $mqtt = new MqttClient($server, $port, $clientId);
|
|
|
-
|
|
|
- $mqtt->connect($connectionSettings, $clean_session);
|
|
|
rlog('INFO', "connect OK");
|
|
|
|
|
|
while (1) {
|
|
|
@@ -159,12 +155,17 @@ function loop()
|
|
|
sleep(1);
|
|
|
continue;
|
|
|
}
|
|
|
+ $mqtt = new MqttClient($server, $port, $clientId);
|
|
|
+
|
|
|
+ $mqtt->connect($connectionSettings, $clean_session);
|
|
|
$cnt = json_decode($configCnt, true);
|
|
|
$mqtt->publish('RlianStation/G31W/'.$cnt["mac"].'/SetConfig', $configCnt, MqttClient::QOS_AT_MOST_ONCE);
|
|
|
+ $mqtt->loop(true, true);
|
|
|
+ $mqtt->disconnect();
|
|
|
+ var_dump("out!!");
|
|
|
rlog('PUB_CONFIG_CNT', $configCnt);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
}
|
|
|
|
|
|
|
