MQTT и WirenBoard

[excun]

Добрый день!
Мучаюсь уже какой день. Есть связка клиент MQTT на MDM и WirenBoard. C MDM на WB команды передаются сразу, без задержки, в обратную сторону с задержкой 5-8 минут.
То есть например нажимается кнопка выключателя или отрабатывает PIR датчик, на WB событие отрабатывает сразу через mosquitto_sub видно что соответствующее свойство поменяло свое значение, на MDM это значение обновляется через значительный промежуток времени.
В чем может быть дело? в каком направлении капать?

[sergejey]

Странное поведение... можно попробовать запустить отдельно cycle_mqtt и посмотреть, что там происходит. Там в принципе, ничего специфичного для wirenboard не делалось -- стандартная подписка на MQTT-брокера и как только он данные присылает, так они в системе и обновляются.

[excun]

При запуске cycle_mqtt.php происходит последовательный опрос серверной части wb
015-03-24 20:14:50 Topic:/devices/noolite_tx_0xe2e/controls/bind/meta/order 6
2015-03-24 20:14:51 Topic:/devices/noolite_tx_0xe2e/controls/switch 0
2015-03-24 20:14:52 Topic:/devices/noolite_tx_0xe2e/controls/switch/meta/type pushbutton
2015-03-24 20:14:53 Topic:/devices/noolite_tx_0xe2e/controls/switch/meta/order 4
2015-03-24 20:14:54 Topic:/devices/noolite_tx_0xe2e/controls/slowstop 0
2015-03-24 20:14:55 Topic:/devices/noolite_tx_0xe2e/controls/slowstop/meta/type pushbutton
2015-03-24 20:14:56 Topic:/devices/noolite_tx_0xe2e/controls/slowstop/meta/order 10
Команда на включение в логах не отразилась не как, хотя сама команда ушла и выполнилась(само событие зафиксировал на отметке 2015-03-24 20:17:56 через 3 минуты)
При это если выполнить mosquitto_sub -h X.X.X.X -v -t /devices/# на MDM то показ отрабатывает вполне корректно

[excun]

Сергей, провел эксперимент. Развернул чистую инсталляцию, подцепил сторонний брокер, прописал subscription path строго на одно значение(temp/random), как результат все меняется, все работает. Вторым этапом поменял subscription path на широкую маску, перезапустил процесс и послал на брокер контрольное значение, в результате mosquitto_pub, показал что значение поменялось, а MDM не отрабатывает(значение изменилось более чем через 10 минут).
Вопрос в следующем, есть ли возможность как то ограничить список с которым работает клиент mqtt на MDM? Такое ощущение что клиент в синхронном режиме обрабатывает входной поток и при больших объемах идут соответственно задержки
P.S. Настроить подписку для WB c учетом более узкой маски не представляется возможным, так как используется несколько разных устройств(как силовые блоки, так и датчики)

[sergejey]

Сергей, провел эксперимент. Развернул чистую инсталляцию, подцепил сторонний брокер, прописал subscription path строго на одно значение(temp/random), как результат все меняется, все работает. Вторым этапом поменял subscription path на широкую маску, перезапустил процесс и послал на брокер контрольное значение, в результате mosquitto_pub, показал что значение поменялось, а MDM не отрабатывает(значение изменилось более чем через 10 минут).
Вопрос в следующем, есть ли возможность как то ограничить список с которым работает клиент mqtt на MDM? Такое ощущение что клиент в синхронном режиме обрабатывает входной поток и при больших объемах идут соответственно задержки
P.S. Настроить подписку для WB c учетом более узкой маски не представляется возможным, так как используется несколько разных устройств(как силовые блоки, так и датчики)

Клиент реализован с помощью библиотеке phpMQTT (https://github.com/bluerhinos/phpMQTT), в которую я, если честно, не лазил.
Если взять исходник /scripts/cycle_mqtt.php , то там оно устроено вот так:



1. Коннект
2. Подписка
3. Обработка сообщения

Если в логе majordomo сообщение появляется гораздо позже, то тут два варианта:
1. Клиент не вызывает procmsg в момент сообщения, а почему-то вызывает его гораздо позже
2. Большая задержка с обработкой сообщения, т.к. сначало оно обрабатывается, а потом пишется в лог

Чтобы исключить номер 2 можно попробовать поменять местами эти две строчки и посмотреть снова лог

[excun]

Сергей, спасибо. На том уровне количества устройств nooLite сделать получилось

[sergejey]

Сергей, спасибо. На том уровне количества устройств nooLite сделать получилось

Так, а в чём в итоге дело было?

[excun]

В конструкции while ($mqtt_client->proc()) {...} у вас используется задержка в 1 секунду sleep(1), как следствие на больших массивах данных получаемых с брокера получаем задержку перед выполнением. Я модифицировал код следующем образом:
$previousMillis = 0;
while ($mqtt_client->proc()) {
$currentMillis = round(microtime(1) * 10000);
if ($currentMillis - $previousMillis > 10000) {
$previousMillis = $currentMillis;
setGlobal((str_replace('.php', '', basename(__FILE__))) . 'Run', time(), 1);

if (file_exists('./reboot') || $_GET['onetime']) {
$db->Disconnect();
exit;
}
}
}
На данный момент задержка считывания не превышает секунды

[SergVl]

Добрый день!
Как отключить автоматическую публикацию значений в настройках MQTT, а то у меня их набралось на 11 страниц (удаляю их, но они занова публикуются).