MQTT: различия между версиями
Brainroot (обсуждение | вклад) |
м (→Настройка своего брокера MQTT: Поправил) |
||
(не показано 58 промежуточных версий 7 участников) | |||
Строка 1: | Строка 1: | ||
'''MQTT''' — протокол обмена данными, использующийся в [[Программное обеспечение Wiren Board|программном обеспечении Wiren Board]]. [http://en.wikipedia.org/wiki/MQTT Базовая информация по MQTT на Википедии]. | '''MQTT''' — протокол обмена данными, использующийся в [[Программное обеспечение Wiren Board|программном обеспечении Wiren Board]]. [http://en.wikipedia.org/wiki/MQTT Базовая информация по MQTT на Википедии]. | ||
Строка 6: | Строка 4: | ||
Действия пользователя в веб-интерфейсе также публикуются по MQTT, где их получает драйвер и передает команду пользователя устройству. | Действия пользователя в веб-интерфейсе также публикуются по MQTT, где их получает драйвер и передает команду пользователя устройству. | ||
== Примеры работы через MQTT == | |||
== Примеры работы через MQTT == | |||
===Получение значения от датчика температуры и вывод его в веб-интерфейс=== | ===Получение значения от датчика температуры и вывод его в веб-интерфейс=== | ||
[[File:Web-devices-1-wire.png|400px|thumb|Показания датчика и его уникальный идентификатор на странице ''Devices'' веб-интерфейса]] | [[File:Web-devices-1-wire.png|400px|thumb|Показания датчика и его уникальный идентификатор на странице ''Devices'' веб-интерфейса]] | ||
К [[Wiren Board]] подключён датчик температуры по шине [[1-Wire]]. Проследим, как данные с него через MQTT попадают в веб-интерфейс: | К [[Wiren Board]] подключён датчик температуры по шине [[1-Wire]]. Проследим, как данные с него через MQTT попадают в веб-интерфейс: | ||
#Драйвер [https://github.com/ | #Драйвер, отвечающий за данную аппаратную функцию ([https://github.com/contactless/wb-homa-drivers/tree/master/wb-homa-w1 wb-homa-w1]) опрашивает подключённые к контролеру датчики 1-Wire. | ||
#При получении значения драйвер публикует MQTT сообщение вида: <pre>/devices/wb-w1/controls/28-0115a48fcfff 23.25</pre>Оно значит, что | #При получении значения драйвер публикует по MQTT сообщение вида: <pre>/devices/wb-w1/controls/28-0115a48fcfff 23.25</pre>Оно значит, что на устройстве 1-Wire с идентификатором ''28-0115a48fcfff'' получено значение 23.25 °C. | ||
#Веб-интерфейс, который подписан на все сообщения из MQTT, получает это сообщение и выводит значение датчика на страницу. | #Веб-интерфейс, который подписан на все сообщения из MQTT, получает это сообщение и выводит значение датчика на страницу. | ||
===Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле=== | ===Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле=== | ||
[[File:Web-devices-serial.png|400px|thumb|Веб-интерфейс после нажатия кнопки включения Реле 1 на подключённом по RS-485 релейном модуле [[WB-MRM2]]]] | [[File:Web-devices-serial.png|400px|thumb|Веб-интерфейс после нажатия кнопки включения Реле 1 на подключённом по RS-485 релейном модуле [[WB-MRM2]]]] | ||
К контроллеру по шине [[RS-485]] подключён релейный модуль [[WB-MRM2]]. Пользователь в веб-интерфейсе нажимает кнопку включения реле. Проследим, как команда из веб-интерфейса попадает на внешний модуль: | К контроллеру по шине [[RS-485]] подключён релейный модуль [[WB-MRM2]]. Пользователь в веб-интерфейсе нажимает кнопку включения реле. Проследим, как команда из веб-интерфейса попадает на внешний модуль: | ||
#После нажатия кнопки веб-интерфейс публикует по MQTT сообщение вида: <pre>/devices/wb-mrm2_130/controls/Relay 1/on 1</pre>Оно значит, что устройство WB-MRM2 с адресом ''130'' должно перевести ''Реле 1'' в состояние логической единицы | #После нажатия кнопки веб-интерфейс публикует по MQTT сообщение вида: <pre>/devices/wb-mrm2_130/controls/Relay 1/on 1</pre>Оно значит, что устройство WB-MRM2 с адресом ''130'' должно перевести ''Реле 1'' в состояние логической единицы - «включено». | ||
#[[Драйвер wb-mqtt-serial]], отвечающий за данную аппаратную функцию, получает это сообщение (он ''подписан'' на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле. | #[[Драйвер wb-mqtt-serial]], отвечающий за данную аппаратную функцию, получает это сообщение (он ''подписан'' на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле. | ||
#Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление «Реле 1 включено». | #Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление «Реле 1 включено». | ||
#Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует по MQTT сообщение:<pre>/devices/wb-mrm2_130/controls/Relay 1 1</pre>Оно значит, что первое реле на устройстве WB-MRM2 с адресом ''130'' находится (уже переведено) в состоянии логической единицы — «включено». | #Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует по MQTT сообщение:<pre>/devices/wb-mrm2_130/controls/Relay 1 1</pre>Оно значит, что первое реле на устройстве WB-MRM2 с адресом ''130'' находится (уже переведено) в состоянии логической единицы — «включено». | ||
== Принцип работы MQTT == | == Принцип работы MQTT == | ||
[[File: | [[File:MQTT.png | thumb | 600px | Через MQTT работают драйверы внутренних функций, внешних устройств, веб-интерфейс, система правил]] | ||
Система сообщений MQTT построена по следующему принципу: | Система сообщений MQTT построена по следующему принципу: | ||
*есть иерархическая система «топиков» (как на обычных форумах в интернете). | *есть иерархическая система «топиков» (как на обычных форумах в интернете). | ||
Строка 40: | Строка 30: | ||
=== Отображение устройств в структуре сообщений === | === Отображение устройств в структуре сообщений === | ||
Логика организации топиков, соответствующих разным устройствам и их параметрам, в Wiren Board следует определённым правилам — так называемым соглашениям ([https://github.com/ | Логика организации топиков, соответствующих разным устройствам и их параметрам, в Wiren Board следует определённым правилам — так называемым соглашениям ([https://github.com/contactless/homeui/blob/master/conventions.md Wiren Board MQTT Conventions]). | ||
Полный список MQTT-топиков можно увидеть на странице ''Settings'' веб-интерфейса в разделе ''MQTT Channels'' (появилось в последних версиях [[Обновление прошивки|прошивки]]). | Полный список MQTT-топиков можно увидеть на странице ''Settings'' веб-интерфейса в разделе ''MQTT Channels'' (появилось в последних версиях [[Обновление прошивки|прошивки]]). | ||
Строка 51: | Строка 41: | ||
*(если есть) собственные программы пользователя. | *(если есть) собственные программы пользователя. | ||
=== Структура сообщения о состоянии устройства === | === Структура сообщения о состоянии устройства === | ||
Вот | Вот пример сообщения от драйвера температурного датчика 1-Wire из примера выше: | ||
<pre> | <pre> | ||
/devices/wb-w1/controls/28-0115a48fcfff 23.25 | /devices/wb-w1/controls/28-0115a48fcfff 23.25 | ||
Строка 59: | Строка 49: | ||
Название топика состоит из вложенных друг в друга «подтопиков»: | Название топика состоит из вложенных друг в друга «подтопиков»: | ||
* | * ''/devices'' — коренной топик для всех «устройств» — как встроенных функций Wiren Board (цифровые, АЦП, ...), так и подключённых внешних (например, модулей реле). | ||
* | * ''/wb-w1'' — подтопик, который наполняется драйвером 1-Wire. | ||
* | * ''/controls'' — подтопик, который есть у всех устройств — именно в него записываются все их параметры, которые меняются («включено-выключено», значение датчика, ...). | ||
* | * ''/28-0115a48fcfff'' — непосредственно сам «канал» («контрол») — топик, куда записывается значение с датчика. Его название совпадает с адресом 1-Wire датчика на шине. | ||
Содержание сообщения: | Содержание сообщения: | ||
* | * ''23.25'' — значение температуры | ||
Если вы хотите самостоятельно написать драйвер устройства, и хотите, что оно отображалось на вкладке | Если вы хотите самостоятельно написать драйвер устройства, и хотите, что оно отображалось на вкладке Devices и его можно было использовать в правилах, вам необходимо придерживаться такой же структуры топиков. | ||
=== Структура сообщения об ошибке опроса устройства === | === Структура сообщения об ошибке опроса устройства === | ||
Каждый «канал» («контрол») имеет «подтопик» <code>/meta/error</code>, в котором содержится информация о наличии ошибок взаимодействия с устройством. Ошибки получения данных (чтения) обозначаются символом '''r''', ошибки записи — '''w'''. | Каждый «канал» («контрол») имеет «подтопик» <code>/meta/error</code>, в котором содержится информация о наличии ошибок взаимодействия с устройством. Ошибки получения данных (чтения) обозначаются символом '''r''', ошибки записи — '''w'''. | ||
Строка 86: | Строка 76: | ||
Клиенты, которые хотят следить за значением температуры, «подписываются» на этот топик, и им приходят все новые сообщения — меняющиеся значения температуры. Один из таких клиентов — веб-интерфейс. | Клиенты, которые хотят следить за значением температуры, «подписываются» на этот топик, и им приходят все новые сообщения — меняющиеся значения температуры. Один из таких клиентов — веб-интерфейс. | ||
Подписаться на сообщения можно и из консоли Linux при помощи утилиты | Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''' (полное описание работы с MQTT из командной строки смотрите ниже): | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff | root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже - вывод утилиты, полученные сообщения | /devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже - вывод утилиты, полученные сообщения | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.75 | /devices/wb-w1/controls/28-0115a48fcfff 22.75 | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.75 | /devices/wb-w1/controls/28-0115a48fcfff 22.75 | ||
</syntaxhighlight> | </syntaxhighlight> | ||
=== Структура сообщения — команды на изменение состояния === | === Структура сообщения — команды на изменение состояния === | ||
Строка 100: | Строка 88: | ||
Подпишемся на сообщения о состоянии первого реле подключённого по RS-485 релейного модуля WB-MRM2: | Подпишемся на сообщения о состоянии первого реле подключённого по RS-485 релейного модуля WB-MRM2: | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mosquitto_sub -t "/devices/wb-mrm2_130/controls/Relay 1/#" -v | root@wirenboard:~# mosquitto_sub -t "/devices/wb-mrm2_130/controls/Relay 1/#" -v | ||
/devices/wb-mrm2_130/controls/Relay 1/meta/type switch | /devices/wb-mrm2_130/controls/Relay 1/meta/type switch | ||
/devices/wb-mrm2_130/controls/Relay 1/meta/order 1 | /devices/wb-mrm2_130/controls/Relay 1/meta/order 1 | ||
Строка 116: | Строка 104: | ||
- веб-интерфейс сначала «даёт указание» включить реле, потом драйвер его включает и записывает актуальное состояние в «канал» («контрол»). | - веб-интерфейс сначала «даёт указание» включить реле, потом драйвер его включает и записывает актуальное состояние в «канал» («контрол»). | ||
== | ==Работа с сообщениями MQTT== | ||
Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений [http://mosquitto.org/ Mosquitto]. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto. | Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений [http://mosquitto.org/ Mosquitto]. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto. | ||
===Работа из командной строки=== | ===Работа из командной строки=== | ||
Строка 125: | Строка 113: | ||
Это делается с помощью консольной команды '''mosquitto_pub'''. Пример: | Это делается с помощью консольной команды '''mosquitto_pub'''. Пример: | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mosquitto_pub -t "/devices/wb-mrm2_130/controls/Relay 1/on" -m "1" | root@wirenboard:~# mosquitto_pub -t "/devices/wb-mrm2_130/controls/Relay 1/on" -m "1" | ||
</syntaxhighlight> | </syntaxhighlight> | ||
команда отправляет сообщение «1» (логическую единицу, «включить») в топик, соответствующий подключённому по RS-485 релейном модуле WM-MRM2 с адресом 130. | команда отправляет сообщение «1» (логическую единицу, «включить») в топик, соответствующий подключённому по RS-485 релейном модуле WM-MRM2 с адресом 130. | ||
Строка 135: | Строка 123: | ||
Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''' (полное описание утилиты смотрите на [http://mosquitto.org/man/mosquitto_sub-1.html http://mosquitto.org/man/mosquitto_sub-1.html]): | Подписаться на сообщения можно и из консоли Linux при помощи утилиты '''mosquitto_sub''' (полное описание утилиты смотрите на [http://mosquitto.org/man/mosquitto_sub-1.html http://mosquitto.org/man/mosquitto_sub-1.html]): | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff | root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже — вывод утилиты, полученные сообщения | /devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже — вывод утилиты, полученные сообщения | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.75 | /devices/wb-w1/controls/28-0115a48fcfff 22.75 | ||
Строка 144: | Строка 132: | ||
Подписаться можно не только на один топик, но и на группу топиков по метасиволу. В MQTT применяется два метасимвола: '''#''' и '''+'''. Метасимвол ''#'' означает любое количество уровней вложенных топиков. Выполним команду | Подписаться можно не только на один топик, но и на группу топиков по метасиволу. В MQTT применяется два метасимвола: '''#''' и '''+'''. Метасимвол ''#'' означает любое количество уровней вложенных топиков. Выполним команду | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mosquitto_sub -t '/devices/wb-w1/#' -v | root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/#' -v | ||
/devices/wb-w1/meta/name 1-wire Thermometers | /devices/wb-w1/meta/name 1-wire Thermometers | ||
/devices/wb-w1/controls/28-0115a48fcfff 22.812 | /devices/wb-w1/controls/28-0115a48fcfff 22.812 | ||
Строка 151: | Строка 139: | ||
</syntaxhighlight> | </syntaxhighlight> | ||
В результате мы получили не только значения с «контрола» устройства, но и топики с метаданными — название драйвера устройства и тип «контрола» - ''temperature''. | В результате мы получили не только значения с «контрола» устройства, но и топики с метаданными — название драйвера устройства и тип «контрола» - ''temperature''. | ||
Существует так же метасимвол | Существует так же метасимвол ''+'', который обозначает один уровень, а не произвольное количество,как ''#'': | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
mosquitto_sub -v -t "/config/widgets/+/name" | mosquitto_sub -v -t "/config/widgets/+/name" | ||
Строка 157: | Строка 145: | ||
В этом случае мы получим имена всех виджетов. | В этом случае мы получим имена всех виджетов. | ||
=== Очистка очереди сообщений === | Полное описание системы топиков и подписок [http://mosquitto.org/man/mqtt-7.html http://mosquitto.org/man/mqtt-7.html]. | ||
==== Очистка очереди сообщений ==== | |||
Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. | ||
Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе ''Devices'' веб-интерфейса. | Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе ''Devices'' веб-интерфейса. | ||
Для удаления топиков можно воспользоваться командой | Для удаления топиков можно воспользоваться командой ''mqtt-delete-retained''. Пример использования: | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
~# mqtt-delete-retained '/devices/noolite_tx_1234/#' | root@wirenboard:~# mqtt-delete-retained '/devices/noolite_tx_1234/#' | ||
</syntaxhighlight> | </syntaxhighlight> | ||
удалит все топики, начинающиеся на '/devices/noolite_tx_1234/' | |||
Для удаления топиков «по маске», можно циклично вызывать | Для удаления топиков «по маске», можно циклично вызывать runShellCommand из правил. Таким образом, задача сводится к задаче работы со строками в js. | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
var deviceName = ['name1',.., 'nameN']; | var deviceName = ['name1',.., 'nameN']; | ||
Строка 183: | Строка 171: | ||
=== Работа с MQTT из внешних программ === | === Работа с MQTT из внешних программ === | ||
Если вы разрабатываете собственное ПО для Wiren Board, взаимодействовать с его аппаратными ресурсами лучше всего через протокол MQTT — ваша программа передаёт сообщение по MQTT, драйвер управляет устройством и вашей программе не нужно напрямую взаимодействовать с устройством на низком уровне. | Если вы разрабатываете собственное ПО для Wiren Board, взаимодействовать с его аппаратными ресурсами лучше всего через протокол MQTT — ваша программа передаёт сообщение по MQTT, драйвер управляет устройством, и вашей программе не нужно напрямую взаимодействовать с устройством на низком уровне. | ||
Для того, чтобы отправлять сообщения MQTT, для многих языков программирования есть библиотеки. Примеры: | |||
* Python - [https://github.com/contactless/mqtt-tools] | |||
* C - [http://mosquitto.org/man/libmosquitto-3.html] | |||
=== Просмотр MQTT-каналов в web-интерфейсе === | === Просмотр MQTT-каналов в web-интерфейсе === | ||
MQTT-названия устройств, их элементов управления и последние значения можно найти в разделе | MQTT-названия устройств, их элементов управления и последние значения можно найти в разделе Settings web-интерфейса: | ||
[[Файл:Wb_settings.png|900px|thumb|center|Информация об MQTT-названиях устройств]] | [[Файл:Wb_settings.png|900px|thumb|center|Информация об MQTT-названиях устройств]] | ||
=== Настройка MQTT моста (bridge) === | === Настройка MQTT моста (bridge) === | ||
[[File:CloudMQTT.png | thumb | 400px | Настройки брокера Cloud MQTT]] | |||
MQTT мост (bridge) — это функция MQTT-брокера, позволяющая пересылать все или часть сообщений на другой MQTT-брокер, и получать сообщения с другого брокера обратно. | MQTT мост (bridge) — это функция MQTT-брокера, позволяющая пересылать все или часть сообщений на другой MQTT-брокер, и получать сообщения с другого брокера обратно. На контроллере эта функция настраивается в конфигурационных файлах ''mosquitto''. Самый простой вариант конфигурации приведён ниже. | ||
На контроллере эта функция настраивается в конфигурационных файлах ''mosquitto''. Самый простой вариант конфигурации приведён ниже. | |||
'''Задача:''' настроить пересылку всех сообщений MQTT на популярный дешёвый облачный MQTT брокер http://cloudmqtt.com/ и обратно. | '''Задача:''' настроить пересылку всех сообщений MQTT на популярный дешёвый облачный MQTT брокер http://cloudmqtt.com/ и обратно. | ||
Строка 258: | Строка 191: | ||
# Зарегистрируйтесь на http://cloudmqtt.com/ | # Зарегистрируйтесь на http://cloudmqtt.com/ | ||
# Зайдите в свой аккаунт на http://cloudmqtt.com/ и посмотрите настройки: сервер, порт, логин, пароль. | # Зайдите в свой аккаунт на http://cloudmqtt.com/ и посмотрите настройки: сервер, порт, логин, пароль. | ||
# Зайдите на контроллер и добавьте в конец файла <code>/etc/mosquitto/ | # Зайдите на контроллер и добавьте в конец файла <code>/etc/mosquitto/mosquitto.conf</code> следующие строки: | ||
#: <syntaxhighlight lang="bash"> | #: <syntaxhighlight lang="bash"> | ||
connection cloudmqtt | connection cloudmqtt | ||
Строка 271: | Строка 204: | ||
#: (последняя строка говорит, что нужно пересылать все сообщения (метасимвол '''#''', смотрите описание выше) в обе ('''both''') стороны (с брокера контроллера на облачный брокер и обратно) | #: (последняя строка говорит, что нужно пересылать все сообщения (метасимвол '''#''', смотрите описание выше) в обе ('''both''') стороны (с брокера контроллера на облачный брокер и обратно) | ||
#: Более подробное описание всех опций смотрите на https://mosquitto.org/man/mosquitto-conf-5.html. | #: Более подробное описание всех опций смотрите на https://mosquitto.org/man/mosquitto-conf-5.html. | ||
# Перезапустите | # Перезапустите mosquitto, выполнив в консоли | ||
#: <syntaxhighlight lang="bash"> | #: <syntaxhighlight lang="bash"> | ||
service mosquitto restart | |||
</syntaxhighlight> | </syntaxhighlight> | ||
'''Другие облачные брокеры''' | |||
''' | |||
Список облачных брокеров, в том числе бесплатных: [https://github.com/mqtt/mqtt.github.io/wiki/public_brokers https://github.com/mqtt/mqtt.github.io/wiki/public_brokers] | |||
'''Задача:''' настроить пересылку топика MQTT на другой контроллер. | '''Задача:''' настроить пересылку топика MQTT на другой контроллер. | ||
Есть два контроллера в одной сети: | Есть два контроллера в одной сети, адреса: | ||
;10.0.0.40 | |||
:На этот контроллер «забираем» топик. Обозначаем его как «40». | |||
;10.0.0.70 | |||
:С этого контроллера, он источник. Назовем его «70». | |||
На '' | На '''70''' есть <code>/client/temp1</code> | ||
Его нужно видеть на '''40''' в <code>/devices/temp1</code> | |||
Решается двумя способами, можно с '' | Решается двумя способами, можно с '''70''' публиковать на '''40''' или с '''40''' подписаться на топик '''70''' и забирать изменения. От выбора стратегии зависит на каком контроллере будем проводить настройки. | ||
Будем настраивать '''40'''. | |||
'''Решение:''' | |||
На контроллере «40» добавляем в конфиг: | |||
'''Решение:''' На контроллере | |||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
mcedit /etc/mosquitto/conf.d/bridge.conf | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Следующее | |||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
connection wb_40 | connection wb_40 | ||
Строка 338: | Строка 241: | ||
restart_timeout 20 | restart_timeout 20 | ||
topic /temp1/# in | topic /temp1/# in 2 /devices /client | ||
</syntaxhighlight> | </syntaxhighlight> | ||
Перезапускаем на нем же mosquitto: | |||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
systemctl restart mosquitto; systemctl status mosquitto | systemctl restart mosquitto; systemctl status mosquitto | ||
</syntaxhighlight> | </syntaxhighlight> | ||
'''ВАЖНО | '''ВАЖНО''' перед перезапуском желательно [[watchdog |остановить watchdog]]. В случае ошибки в конфигах брокер не запустится и watchdog вызовет перезапуск контроллера. | ||
Подробней о строчке: | |||
<syntaxhighlight lang="bash"> | |||
topic /temp1/# in 2 /devices /client | |||
</syntaxhighlight> | |||
где: | где: | ||
;/temp1/# это топик от «корня» | |||
:На брокере-источнике /client/'''temp1''' | |||
;in — только забираем, изменения на контроллере не передадутся на сервер | |||
;/devices — »корень« '''куда''' располагаем локально | |||
: На контроллере '''40''' это '''/devices''' и полный путь будет выгляджеть как '''/devices'''/temp1 | |||
;/client — «корень» откуда забираем на удаленном | |||
: На контроллере '''70''' это '''/client''' и полный путь будет выгляджеть как '''/client'''/temp1 | |||
'''Проверка:''' | '''Проверка:''' | ||
Дожидаемся статуса бриджа «1» в топике <code>/client/wb_40/bridge_status</code> на контроллере '' | Дожидаемся статуса бриджа «1» в топике <code>/client/wb_40/bridge_status</code> на контроллере '''70'''. | ||
На нем же публикуем: | На нем же публикуем: | ||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
Строка 364: | Строка 275: | ||
</syntaxhighlight> | </syntaxhighlight> | ||
подписавшись на контроллере '''40''' на целевой топик можно видеть: | |||
<syntaxhighlight lang="bash"> | <syntaxhighlight lang="bash"> | ||
mosquitto_sub -v -t /devices/temp1/# | mosquitto_sub -v -t /devices/temp1/# | ||
Строка 395: | Строка 306: | ||
</syntaxhighlight> | </syntaxhighlight> | ||
== | == Настройка своего брокера MQTT == | ||
=== Установка === | |||
Установите <code>mosquitto</code>: | |||
<syntaxhighlight lang="bash"> | |||
apt update && apt install mosquitto -y | |||
</syntaxhighlight> | |||
Отредактируйте файл конфигурации, отключив возможность анонимного входа: | |||
<syntaxhighlight lang="bash"> | |||
cat << EOF >>/etc/mosquitto/mosquitto.conf | |||
#Disable anonomous login: | #Disable anonomous login: | ||
allow_anonymous false | allow_anonymous false | ||
#Password file: | #Password file: | ||
password_file /etc/mosquitto/mosquitto.pwd | password_file /etc/mosquitto/mosquitto.pwd | ||
EOF | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Создайте пароль для пользователя, в примере использован пользователь <code>test</code> с паролем <code>test11test</code>: | |||
<syntaxhighlight lang="bash"> | |||
mosquitto_passwd -c /etc/mosquitto/mosquitto.pwd test | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Введите дважды пароль и запомните его, он вам пригодится ниже. | |||
Перезапустите <code>mosquitto</code> и проверьте его состояние: | |||
<syntaxhighlight lang="bash"> | |||
systemctl restart mosquitto && systemctl status mosquitto | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Подключитесь к брокеру для проверки, в примере адрес брокера <code>10.0.26.1</code>: | |||
<syntaxhighlight lang="bash"> | |||
mosquitto_sub -v -h 10.0.26.1 -u test -P test11test -t "/#" | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Запустите в другой консоли команду ниже и убедитесь, что топик меняется: | |||
<syntaxhighlight lang="bash"> | |||
for i in {1..25}; do mosquitto_pub -h 10.0.26.1 -u test -P test11test -t "/client/temp1/temp" -m "$i" -r; done | |||
</syntaxhighlight> | </syntaxhighlight> | ||
Брокер установлен, доступ к нему разрешен только с логином и паролем, с контроллера брокер доступен. |
Версия 20:32, 18 января 2021
MQTT — протокол обмена данными, использующийся в программном обеспечении Wiren Board. Базовая информация по MQTT на Википедии.
Драйверы, которые отвечают за аппаратную часть контроллера (цифровые и транзисторные входы, АЦП и т.п.) и функции внешних подключенных устройств публикуют их состояние по MQTT в виде сообщений. Веб-интерфейс читает эти сообщения и на их основе отображает состояние устройств.
Действия пользователя в веб-интерфейсе также публикуются по MQTT, где их получает драйвер и передает команду пользователя устройству.
Примеры работы через MQTT
Получение значения от датчика температуры и вывод его в веб-интерфейс
К Wiren Board подключён датчик температуры по шине 1-Wire. Проследим, как данные с него через MQTT попадают в веб-интерфейс:
- Драйвер, отвечающий за данную аппаратную функцию (wb-homa-w1) опрашивает подключённые к контролеру датчики 1-Wire.
- При получении значения драйвер публикует по MQTT сообщение вида:
/devices/wb-w1/controls/28-0115a48fcfff 23.25
Оно значит, что на устройстве 1-Wire с идентификатором 28-0115a48fcfff получено значение 23.25 °C. - Веб-интерфейс, который подписан на все сообщения из MQTT, получает это сообщение и выводит значение датчика на страницу.
Нажатие кнопки в веб-интерфейсе и переключение реле на внешнем модуле
![](/wiki/images/thumb/d/d2/Web-devices-serial.png/400px-Web-devices-serial.png)
К контроллеру по шине RS-485 подключён релейный модуль WB-MRM2. Пользователь в веб-интерфейсе нажимает кнопку включения реле. Проследим, как команда из веб-интерфейса попадает на внешний модуль:
- После нажатия кнопки веб-интерфейс публикует по MQTT сообщение вида:
/devices/wb-mrm2_130/controls/Relay 1/on 1
Оно значит, что устройство WB-MRM2 с адресом 130 должно перевести Реле 1 в состояние логической единицы - «включено». - Драйвер wb-mqtt-serial, отвечающий за данную аппаратную функцию, получает это сообщение (он подписан на все сообщения, относящиеся к подключённым по RS-485 устройствам) и посылает по шине RS-485 релейному модулю команду на включение первого реле.
- Релейный модуль WB-MRM2 получает команду от контроллера, переключает реле и посылает обратно уведомление «Реле 1 включено».
- Драйвер wb-mqtt-serial получает это уведомление по RS-485 и публикует по MQTT сообщение:
/devices/wb-mrm2_130/controls/Relay 1 1
Оно значит, что первое реле на устройстве WB-MRM2 с адресом 130 находится (уже переведено) в состоянии логической единицы — «включено».
Принцип работы MQTT
Система сообщений MQTT построена по следующему принципу:
- есть иерархическая система «топиков» (как на обычных форумах в интернете).
- в эти топики клиенты (в случае Wiren Board это драйверы устройств и веб-интерфейс) могут писать сообщения и читать оттуда.
- чтобы следить за изменениями нужного топика (например, температуры на датчике), клиент может на него «подписаться» — тогда он получит все сообщения в этом топике.
Читать полное описание системы топиков и подписок.
Отображение устройств в структуре сообщений
Логика организации топиков, соответствующих разным устройствам и их параметрам, в Wiren Board следует определённым правилам — так называемым соглашениям (Wiren Board MQTT Conventions).
Полный список MQTT-топиков можно увидеть на странице Settings веб-интерфейса в разделе MQTT Channels (появилось в последних версиях прошивки).
Клиенты MQTT
- драйверы внутренних аппаратных функций,
- драйверы внешних подключённых устройств,
- веб-интерфейс,
- движок правил,
- (если есть) собственные программы пользователя.
Структура сообщения о состоянии устройства
Вот пример сообщения от драйвера температурного датчика 1-Wire из примера выше:
/devices/wb-w1/controls/28-0115a48fcfff 23.25
Часть до пробела — название топика, после — само сообщение.
Название топика состоит из вложенных друг в друга «подтопиков»:
- /devices — коренной топик для всех «устройств» — как встроенных функций Wiren Board (цифровые, АЦП, ...), так и подключённых внешних (например, модулей реле).
- /wb-w1 — подтопик, который наполняется драйвером 1-Wire.
- /controls — подтопик, который есть у всех устройств — именно в него записываются все их параметры, которые меняются («включено-выключено», значение датчика, ...).
- /28-0115a48fcfff — непосредственно сам «канал» («контрол») — топик, куда записывается значение с датчика. Его название совпадает с адресом 1-Wire датчика на шине.
Содержание сообщения:
- 23.25 — значение температуры
Если вы хотите самостоятельно написать драйвер устройства, и хотите, что оно отображалось на вкладке Devices и его можно было использовать в правилах, вам необходимо придерживаться такой же структуры топиков.
Структура сообщения об ошибке опроса устройства
Каждый «канал» («контрол») имеет «подтопик» /meta/error
, в котором содержится информация о наличии ошибок взаимодействия с устройством. Ошибки получения данных (чтения) обозначаются символом r, ошибки записи — w.
Пример ошибки получения данных:
/devices/wb-w1/controls/28-0115a48fcfff/meta/error r
Это означает, что не удалось получить температуру термометра с адресом 28-0115a48fcfff.
Драйвер wb-mqtt-serial устанавливает признак r, если не удалось запросить значение параметра устройства, признак w — не удалось передать значение устройству.
Драйвер wb-mqtt-adc устанавливает признак r, если не удалось получить значение соотвествующего канала АЦП.
Пример подписки
Клиенты, которые хотят следить за значением температуры, «подписываются» на этот топик, и им приходят все новые сообщения — меняющиеся значения температуры. Один из таких клиентов — веб-интерфейс.
Подписаться на сообщения можно и из консоли Linux при помощи утилиты mosquitto_sub (полное описание работы с MQTT из командной строки смотрите ниже):
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff
/devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже - вывод утилиты, полученные сообщения
/devices/wb-w1/controls/28-0115a48fcfff 22.75
/devices/wb-w1/controls/28-0115a48fcfff 22.75
Структура сообщения — команды на изменение состояния
Подпишемся на сообщения о состоянии первого реле подключённого по RS-485 релейного модуля WB-MRM2:
root@wirenboard:~# mosquitto_sub -t "/devices/wb-mrm2_130/controls/Relay 1/#" -v
/devices/wb-mrm2_130/controls/Relay 1/meta/type switch
/devices/wb-mrm2_130/controls/Relay 1/meta/order 1
/devices/wb-mrm2_130/controls/Relay 1 0
Тут стоит отметить, что MQTT сохраняет часть сообщений (а именно те, которые при отправке были помечены флагом retained) вечно, поэтому после подписки вы получите даже те сообщения, которые были отправлены раньше, чем вы подписались.
Релейный модуль управляется драйвером Драйвер wb-mqtt-serial. У него есть соответствующий топик-«канал» («контрол») Relay 1. У него самого есть значение — 0 (реле выключено), и есть два подтопика. Один из них — служебный: в /meta/type
записан тип «контрола». Здесь он switch — выключатель. Второй подтопик /on — интереснее: в него клиенты пишут то состояние, в которое они хотят установить реле. Заметим, что оно может не совпадать некоторое время (затрачиваемое на процесс переключения) с тем состоянием, в котором реле находится. Драйвер при этом ведёт себя следующим образом: при получении сообщения в топик /devices/wb-mrm2_130/controls/Relay 1/on
он физически включает реле на релейном модуле, а лишь затем записывает новое состояние реле в топик /devices/wb-mrm2_130/controls/Relay
.
Например, если мы сейчас нажмём на кнопку реле в веб-интерфейсе (переключим его состояние), то получим новые сообщения:
/devices/wb-mrm2_130/controls/Relay 1/on 1 /devices/wb-mrm2_130/controls/Relay 1 1
- веб-интерфейс сначала «даёт указание» включить реле, потом драйвер его включает и записывает актуальное состояние в «канал» («контрол»).
Работа с сообщениями MQTT
Программа (демон), отвечающая за рассылку сообщений от одних клиентов другим, называется брокером сообщений. В Wiren Board используется брокер сообщений Mosquitto. Фактически, все драйверы и веб-интерфейс передают свои сообщения именно демону-брокеру Mosquitto.
Работа из командной строки
Управление устройствами из командной строки
Для управления устройством (изменения значения канала), необходимо отправить сообщение в топик /devices/<device-id>/controls/<control-id>/on
(обратите внимание на /on в конце).
Это делается с помощью консольной команды mosquitto_pub. Пример:
root@wirenboard:~# mosquitto_pub -t "/devices/wb-mrm2_130/controls/Relay 1/on" -m "1"
команда отправляет сообщение «1» (логическую единицу, «включить») в топик, соответствующий подключённому по RS-485 релейном модуле WM-MRM2 с адресом 130.
Слежение за состоянием устройства / подписка на топик
Клиенты, которые хотят следить за значением температуры, «подписываются» на этот топик, и им приходят все новые сообщения - меняющиеся значения температуры. Один из таких клиентов - веб-интерфейс.
Подписаться на сообщения можно и из консоли Linux при помощи утилиты mosquitto_sub (полное описание утилиты смотрите на http://mosquitto.org/man/mosquitto_sub-1.html):
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/controls/28-0115a48fcfff' -v //получить сообщения из топика устройства 1-Wire с идентификатором 28-0115a48fcfff
/devices/wb-w1/controls/28-0115a48fcfff 22.75 //в этой строке и ниже — вывод утилиты, полученные сообщения
/devices/wb-w1/controls/28-0115a48fcfff 22.75
/devices/wb-w1/controls/28-0115a48fcfff 22.75
Метасимволы
Подписаться можно не только на один топик, но и на группу топиков по метасиволу. В MQTT применяется два метасимвола: # и +. Метасимвол # означает любое количество уровней вложенных топиков. Выполним команду
root@wirenboard:~# mosquitto_sub -t '/devices/wb-w1/#' -v
/devices/wb-w1/meta/name 1-wire Thermometers
/devices/wb-w1/controls/28-0115a48fcfff 22.812
/devices/wb-w1/controls/28-0115a48fcfff/meta/type temperature
/devices/wb-w1/controls/28-0115a48fcfff 22.75
В результате мы получили не только значения с «контрола» устройства, но и топики с метаданными — название драйвера устройства и тип «контрола» - temperature. Существует так же метасимвол +, который обозначает один уровень, а не произвольное количество,как #:
mosquitto_sub -v -t "/config/widgets/+/name"
В этом случае мы получим имена всех виджетов.
Полное описание системы топиков и подписок http://mosquitto.org/man/mqtt-7.html.
Очистка очереди сообщений
Ненужные retained-сообщения могут остаться в системе MQTT после удаления неиспользуемых драйверов или отключения каких-либо устройств. Это приводит к тому, что несуществующие больше устройства могут отображаться в разделе Devices веб-интерфейса.
Для удаления топиков можно воспользоваться командой mqtt-delete-retained. Пример использования:
root@wirenboard:~# mqtt-delete-retained '/devices/noolite_tx_1234/#'
удалит все топики, начинающиеся на '/devices/noolite_tx_1234/'
Для удаления топиков «по маске», можно циклично вызывать runShellCommand из правил. Таким образом, задача сводится к задаче работы со строками в js.
var deviceName = ['name1',.., 'nameN'];
var controlName = 'Temperature';
for (var i = 0; i<deviceName.length; i++) {
runShellCommand ('mqtt-delete-retained /devices/'+ deviceName[i] + '/controls/controlName/#');
}
Работа с MQTT из внешних программ
Если вы разрабатываете собственное ПО для Wiren Board, взаимодействовать с его аппаратными ресурсами лучше всего через протокол MQTT — ваша программа передаёт сообщение по MQTT, драйвер управляет устройством, и вашей программе не нужно напрямую взаимодействовать с устройством на низком уровне.
Для того, чтобы отправлять сообщения MQTT, для многих языков программирования есть библиотеки. Примеры:
Просмотр MQTT-каналов в web-интерфейсе
MQTT-названия устройств, их элементов управления и последние значения можно найти в разделе Settings web-интерфейса:
Настройка MQTT моста (bridge)
MQTT мост (bridge) — это функция MQTT-брокера, позволяющая пересылать все или часть сообщений на другой MQTT-брокер, и получать сообщения с другого брокера обратно. На контроллере эта функция настраивается в конфигурационных файлах mosquitto. Самый простой вариант конфигурации приведён ниже.
Задача: настроить пересылку всех сообщений MQTT на популярный дешёвый облачный MQTT брокер http://cloudmqtt.com/ и обратно.
Решение:
- Зарегистрируйтесь на http://cloudmqtt.com/
- Зайдите в свой аккаунт на http://cloudmqtt.com/ и посмотрите настройки: сервер, порт, логин, пароль.
- Зайдите на контроллер и добавьте в конец файла
/etc/mosquitto/mosquitto.conf
следующие строки:connection cloudmqtt address m21.cloudmqtt.com:10858 remote_username fs_user_kp remote_password 5dn_pass_pm clientid pavel_test try_private false start_type automatic topic # both
- (последняя строка говорит, что нужно пересылать все сообщения (метасимвол #, смотрите описание выше) в обе (both) стороны (с брокера контроллера на облачный брокер и обратно)
- Более подробное описание всех опций смотрите на https://mosquitto.org/man/mosquitto-conf-5.html.
- Перезапустите mosquitto, выполнив в консоли
service mosquitto restart
Другие облачные брокеры
Список облачных брокеров, в том числе бесплатных: https://github.com/mqtt/mqtt.github.io/wiki/public_brokers
Задача: настроить пересылку топика MQTT на другой контроллер.
Есть два контроллера в одной сети, адреса:
- 10.0.0.40
- На этот контроллер «забираем» топик. Обозначаем его как «40».
- 10.0.0.70
- С этого контроллера, он источник. Назовем его «70».
На 70 есть /client/temp1
Его нужно видеть на 40 в /devices/temp1
Решается двумя способами, можно с 70 публиковать на 40 или с 40 подписаться на топик 70 и забирать изменения. От выбора стратегии зависит на каком контроллере будем проводить настройки. Будем настраивать 40.
Решение: На контроллере «40» добавляем в конфиг:
mcedit /etc/mosquitto/conf.d/bridge.conf
Следующее
connection wb_40
address 10.0.0.70
notifications true
notification_topic /client/wb_40/bridge_status
keepalive_interval 20
restart_timeout 20
topic /temp1/# in 2 /devices /client
Перезапускаем на нем же mosquitto:
systemctl restart mosquitto; systemctl status mosquitto
ВАЖНО перед перезапуском желательно остановить watchdog. В случае ошибки в конфигах брокер не запустится и watchdog вызовет перезапуск контроллера.
Подробней о строчке:
topic /temp1/# in 2 /devices /client
где:
- /temp1/# это топик от «корня»
- На брокере-источнике /client/temp1
- in — только забираем, изменения на контроллере не передадутся на сервер
- /devices — »корень« куда располагаем локально
- На контроллере 40 это /devices и полный путь будет выгляджеть как /devices/temp1
- /client — «корень» откуда забираем на удаленном
- На контроллере 70 это /client и полный путь будет выгляджеть как /client/temp1
Проверка:
Дожидаемся статуса бриджа «1» в топике /client/wb_40/bridge_status
на контроллере 70.
На нем же публикуем:
for i in {1..25}
do
mosquitto_pub -t "/client/temp1/temp" -m "$i" -r
done
подписавшись на контроллере 40 на целевой топик можно видеть:
mosquitto_sub -v -t /devices/temp1/#
/devices/temp1/temp
/devices/temp1/temp 1
/devices/temp1/temp 2
/devices/temp1/temp 3
/devices/temp1/temp 4
/devices/temp1/temp 5
/devices/temp1/temp 6
/devices/temp1/temp 7
/devices/temp1/temp 8
/devices/temp1/temp 9
/devices/temp1/temp 10
/devices/temp1/temp 11
/devices/temp1/temp 12
/devices/temp1/temp 13
/devices/temp1/temp 14
/devices/temp1/temp 15
/devices/temp1/temp 16
/devices/temp1/temp 17
/devices/temp1/temp 18
/devices/temp1/temp 19
/devices/temp1/temp 20
/devices/temp1/temp 21
/devices/temp1/temp 22
/devices/temp1/temp 23
/devices/temp1/temp 24
/devices/temp1/temp 25
Настройка своего брокера MQTT
Установка
Установите mosquitto
:
apt update && apt install mosquitto -y
Отредактируйте файл конфигурации, отключив возможность анонимного входа:
cat << EOF >>/etc/mosquitto/mosquitto.conf
#Disable anonomous login:
allow_anonymous false
#Password file:
password_file /etc/mosquitto/mosquitto.pwd
EOF
Создайте пароль для пользователя, в примере использован пользователь test
с паролем test11test
:
mosquitto_passwd -c /etc/mosquitto/mosquitto.pwd test
Введите дважды пароль и запомните его, он вам пригодится ниже.
Перезапустите mosquitto
и проверьте его состояние:
systemctl restart mosquitto && systemctl status mosquitto
Подключитесь к брокеру для проверки, в примере адрес брокера 10.0.26.1
:
mosquitto_sub -v -h 10.0.26.1 -u test -P test11test -t "/#"
Запустите в другой консоли команду ниже и убедитесь, что топик меняется:
for i in {1..25}; do mosquitto_pub -h 10.0.26.1 -u test -P test11test -t "/client/temp1/temp" -m "$i" -r; done
Брокер установлен, доступ к нему разрешен только с логином и паролем, с контроллера брокер доступен.