3692
правки
(Отметить эту версию для перевода) |
|||
Строка 1: | Строка 1: | ||
<languages/> | <languages/> | ||
<translate> | <translate> | ||
<!--T:1--> | |||
'''MQTT''' - очередь сообщений, использующаяся в Wiren Board. Большая часть встроенных функций контроллера (АЦП, реле, транзисторный выход, watchdog) и внешних совместимых устройств транслируются туда в виде сообщений и реагируют на управляющие сообщения оттуда. [[Wiren Board 4:Веб-интерфейс | Веб-интерфейс]] работает также через систему сообщений MQTT - нажатие кнопки в интерфейсе вызывает отправку сообщения сообщения в MQTT-брокер, изменение показания датчика, поступившее в систему сообщений, тут же транслируется в веб-интерфейс. | '''MQTT''' - очередь сообщений, использующаяся в Wiren Board. Большая часть встроенных функций контроллера (АЦП, реле, транзисторный выход, watchdog) и внешних совместимых устройств транслируются туда в виде сообщений и реагируют на управляющие сообщения оттуда. [[Wiren Board 4:Веб-интерфейс | Веб-интерфейс]] работает также через систему сообщений MQTT - нажатие кнопки в интерфейсе вызывает отправку сообщения сообщения в MQTT-брокер, изменение показания датчика, поступившее в систему сообщений, тут же транслируется в веб-интерфейс. | ||
<!--T:2--> | |||
Базовая информация по MQTT - [http://en.wikipedia.org/wiki/MQTT статья] на википедии. Используемый демон - брокер сообщений [http://mosquitto.org/ Mosquitto]. | Базовая информация по MQTT - [http://en.wikipedia.org/wiki/MQTT статья] на википедии. Используемый демон - брокер сообщений [http://mosquitto.org/ Mosquitto]. | ||
== Краткая схема работы == | == Краткая схема работы == <!--T:3--> | ||
<!--T:4--> | |||
Архитектура ПО Wiren Board: | Архитектура ПО Wiren Board: | ||
<!--T:5--> | |||
[[Special:MyLanguage/File:MQTT.png | thumb | 600px]] | [[Special:MyLanguage/File:MQTT.png | thumb | 600px]] | ||
<!--T:6--> | |||
Специальные "драйверы" (отдельный для каждой функции контроллера и внешнего устройства) транслируют данные с устройства в очередь в виде сообщений специального формата. Сообщения из этой очереди получает веб-интерфейс и движок правил. Они же могут добавлять туда новые сообщения - например, "включить реле" после получения нажатия в интерфейсе или выполнения нужных условий в каком-нибудь правиле. | Специальные "драйверы" (отдельный для каждой функции контроллера и внешнего устройства) транслируют данные с устройства в очередь в виде сообщений специального формата. Сообщения из этой очереди получает веб-интерфейс и движок правил. Они же могут добавлять туда новые сообщения - например, "включить реле" после получения нажатия в интерфейсе или выполнения нужных условий в каком-нибудь правиле. | ||
== Принцип работы системы сообщений == | == Принцип работы системы сообщений == <!--T:7--> | ||
<!--T:8--> | |||
MQTT построена по следующему принципу: есть иерархическая система "топиков" (прямо как на обычных форумах), куда клиенты могут писать сообщения, и откуда могут читать. Чтобы было удобно следить за изменениями нужного топика (например, температуры), на него можно "подписаться". | MQTT построена по следующему принципу: есть иерархическая система "топиков" (прямо как на обычных форумах), куда клиенты могут писать сообщения, и откуда могут читать. Чтобы было удобно следить за изменениями нужного топика (например, температуры), на него можно "подписаться". | ||
=== Пример сообщения === | === Пример сообщения === <!--T:9--> | ||
<!--T:10--> | |||
Вот пример сообщения от драйвера датчика 1-Wire (драйвер регулярно опрашивает датчик и отправляет в виде сообщений значения с него): | Вот пример сообщения от драйвера датчика 1-Wire (драйвер регулярно опрашивает датчик и отправляет в виде сообщений значения с него): | ||
<pre> | <pre> | ||
Строка 34: | Строка 41: | ||
=== Пример подписки === | === Пример подписки === <!--T:11--> | ||
<!--T:12--> | |||
Клиенты, которые хотят следить за значением температуры, "подписываются" на этот топик, и им приходят все новые сообщения - меняющиеся значения температуры. Один из таких клиентов - веб-интерфейс. | Клиенты, которые хотят следить за значением температуры, "подписываются" на этот топик, и им приходят все новые сообщения - меняющиеся значения температуры. Один из таких клиентов - веб-интерфейс. | ||
<!--T:13--> | |||
Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''': | Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''': | ||
<pre> | <pre> | ||
Строка 47: | Строка 56: | ||
(описание утилиты смотрите [http://mosquitto.org/man/mosquitto_sub-1.html]). | (описание утилиты смотрите [http://mosquitto.org/man/mosquitto_sub-1.html]). | ||
<!--T:14--> | |||
Подписаться можно не только на один топик, но и на группу по wildcard: | Подписаться можно не только на один топик, но и на группу по wildcard: | ||
<pre> | <pre> | ||
Строка 58: | Строка 68: | ||
, где ''#'' - означает любое количество топиков. Соответственно, вывелись не только значения с "контрола" устройства, но и топики с метаданными - название драйвера устройства и тип "контрола" - ''temperature''. | , где ''#'' - означает любое количество топиков. Соответственно, вывелись не только значения с "контрола" устройства, но и топики с метаданными - название драйвера устройства и тип "контрола" - ''temperature''. | ||
<!--T:15--> | |||
Полное описание системы топиков и подписок: [http://mosquitto.org/man/mqtt-7.html]. | Полное описание системы топиков и подписок: [http://mosquitto.org/man/mqtt-7.html]. | ||
=== Пример сообщения от веб-интерфейса === | === Пример сообщения от веб-интерфейса === <!--T:16--> | ||
<!--T:17--> | |||
Подпишемся на сообщения о состоянии встроенного реле Wiren Board: | Подпишемся на сообщения о состоянии встроенного реле Wiren Board: | ||
<pre> | <pre> | ||
Строка 72: | Строка 84: | ||
Тут стоит отметить, что MQTT сохраняет часть сообщений (а именно с флагом retained) вечно, поэтому после подписки вы получите даже те сообщения, которые были отправлен раньше, чем вы подписались. | Тут стоит отметить, что MQTT сохраняет часть сообщений (а именно с флагом retained) вечно, поэтому после подписки вы получите даже те сообщения, которые были отправлен раньше, чем вы подписались. | ||
<!--T:18--> | |||
Реле управляется драйвером ''wb-gpio'' (этот драйвер также управляет транзисторными выходами и всем, что в электрическом смысле управляется GPIO). У него есть соответствующий топик-"контрол" ''Relay_1''. У него самого есть значение - ''0'' (реле выключено), и есть два подтопика. Один из них - служебный: в ''/meta/type'' записан тип "контрола". Здесь он ''switch'' - выключатель. Второй подтопик ''/on'' - интереснее: в него клиенты пишут то состояние, в которое они хотят установить реле. Заметим, что оно может не совпадать с тем состоянием, в котором реле находится, так как драйвер реле ведёт себя следующим образом: при получении сообщения в топик ''/devices/wb-gpio/controls/Relay_1/on'' он физически устанавливает его на реле, а лишь затем записывает новое значение реле в топик ''/devices/wb-gpio/controls/Relay_1''. | Реле управляется драйвером ''wb-gpio'' (этот драйвер также управляет транзисторными выходами и всем, что в электрическом смысле управляется GPIO). У него есть соответствующий топик-"контрол" ''Relay_1''. У него самого есть значение - ''0'' (реле выключено), и есть два подтопика. Один из них - служебный: в ''/meta/type'' записан тип "контрола". Здесь он ''switch'' - выключатель. Второй подтопик ''/on'' - интереснее: в него клиенты пишут то состояние, в которое они хотят установить реле. Заметим, что оно может не совпадать с тем состоянием, в котором реле находится, так как драйвер реле ведёт себя следующим образом: при получении сообщения в топик ''/devices/wb-gpio/controls/Relay_1/on'' он физически устанавливает его на реле, а лишь затем записывает новое значение реле в топик ''/devices/wb-gpio/controls/Relay_1''. | ||
<!--T:19--> | |||
Например, если мы сейчас нажмем на реле в веб-интерфейсе (переключим его состояние), то получим новые сообщения: | Например, если мы сейчас нажмем на реле в веб-интерфейсе (переключим его состояние), то получим новые сообщения: | ||
<pre> | <pre> | ||
Строка 82: | Строка 96: | ||
=== Управление устройствами из командной строки === | === Управление устройствами из командной строки === <!--T:20--> | ||
<!--T:21--> | |||
Как следует из написанного выше, для управления устройством (изменения значения канала), необходимо отправить сообщение в топик "/devices/<device-id>/controls/<control-id>/on" (обратите внимание на /on в конце). | Как следует из написанного выше, для управления устройством (изменения значения канала), необходимо отправить сообщение в топик "/devices/<device-id>/controls/<control-id>/on" (обратите внимание на /on в конце). | ||
Это легко сделать с помощью консольной команды mosquitto_pub . Пример: | Это легко сделать с помощью консольной команды mosquitto_pub . Пример: | ||
<!--T:22--> | |||
<pre> | <pre> | ||
mosquitto_pub -t "/devices/wb-gpio/controls/Relay_1/on" -m "1" | mosquitto_pub -t "/devices/wb-gpio/controls/Relay_1/on" -m "1" | ||
</pre> | </pre> | ||
<!--T:23--> | |||
команда включает реле 1 (канал "Relay_1" устройства "wb-gpio"). | команда включает реле 1 (канал "Relay_1" устройства "wb-gpio"). | ||
Строка 98: | Строка 115: | ||
=== Отображение устройств в системе сообщений === | === Отображение устройств в системе сообщений === <!--T:24--> | ||
<!--T:25--> | |||
Логика топиков, соответствующих разным устройствам и их параметрам, основывается на так называемых Conventions. Список актуальных типов здесь: [https://github.com/contactless/homeui/blob/contactless/conventions.md] | Логика топиков, соответствующих разным устройствам и их параметрам, основывается на так называемых Conventions. Список актуальных типов здесь: [https://github.com/contactless/homeui/blob/contactless/conventions.md] | ||
== Очистка сообщений MQTT == | == Очистка сообщений MQTT == <!--T:26--> | ||
<!--T:27--> | |||
Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | ||
Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе Devices веб-интерфейса. | Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе Devices веб-интерфейса. | ||
<!--T:28--> | |||
Для удаления топиков можно воспользоваться командой mqtt-delete-retained. | Для удаления топиков можно воспользоваться командой mqtt-delete-retained. | ||
<!--T:29--> | |||
Использование: | Использование: | ||
<!--T:30--> | |||
<pre> | <pre> | ||
mqtt-delete-retained <маска mqtt> | mqtt-delete-retained <маска mqtt> | ||
</pre> | </pre> | ||
<!--T:31--> | |||
например: | например: | ||
<!--T:32--> | |||
<pre> | <pre> | ||
mqtt-delete-retained '/devices/noolite_tx_1234/#' | mqtt-delete-retained '/devices/noolite_tx_1234/#' | ||
</pre> | </pre> | ||
<!--T:33--> | |||
- удалит все топики, начинающиеся на '/devices/noolite_tx_1234/' | - удалит все топики, начинающиеся на '/devices/noolite_tx_1234/' | ||
Строка 127: | Строка 152: | ||
== Использование данных внешними программами == | == Использование данных внешними программами == <!--T:34--> | ||
<!--T:35--> | |||
Для многих языков программирования есть библиотеки MQTT. Примеры программ: | Для многих языков программирования есть библиотеки MQTT. Примеры программ: | ||
* Python - [https://github.com/contactless/mqtt-tools] | * Python - [https://github.com/contactless/mqtt-tools] | ||
Строка 134: | Строка 160: | ||
== Система правил == | == Система правил == <!--T:36--> | ||
<!--T:37--> | |||
Вы можете написать свои правила на языке Javascript. Подробнее смотрите [https://github.com/contactless/wb-rules] | Вы можете написать свои правила на языке Javascript. Подробнее смотрите [https://github.com/contactless/wb-rules] | ||
</translate> | </translate> |