IoT (Internet of Things) в 1С или как подружить 1С с ESP32 при помощи MQTT-брокера

Что делать, если надо подключить удалённое устройство к серверу 1С, но ни устройство, ни сервер 1С нельзя "светить" наружу? А если таких устройств десятки или сотни по всей стране? Ответ: Использовать промежуточный сервис, который будет пересылать данные между сервером 1С и устройствами. Такие функции замечательно выполняет MQTT-брокер, но вот не задача, 1С не умеет с ним работать.

А теперь подробности.

Чтобы решить это недоразумение, я написал скрипт на Node.JS, который при запуске выполняет функцию моста между MQTT-брокером и 1С сервером.

Схема взаимодействия такая:

Вариант настройки 1с сервера

Для работы скрипта требуется установить Node.js. Писать инструкцию по установке я не буду, в интернете их полно, кроме самого Node.js понадобиться ещё и менеджер пакетов npm для установки дополнительных библиотек.

Создаём каталог, где будут лежать все файлы для скрипта, например: "c:mqtt_over_http"

Далее установим необходимые библиотеки, для это в командной строке (cmd.exe), находясь в созданном каталоге, выполним следующие команды:

npm install mqtt --save
npm install express --save
npm install request --save
npm install dotenv --save

 Видео с процессом установки библиотек

 

Теперь приступим к самому скрипту. Сохраняем его в файл, например: "c:mqtt_over_httpserver.js"

 Текст скрипта на Node.js

require('dotenv').config();

constconfig = {

mqtt : {

server :process.env.MQTT_SERVER,

options : {

clientId :process.env.MQTT_CLIENTID,

username :process.env.MQTT_USERNAME,

password :process.env.MQTT_PASSWORD,

keepalive :60,

reconnectPeriod :1000,

clean :true

        }

    },

http : {

serverport :parseInt(process.env.HTTP_SERVERPORT),

url :process.env.HTTP_REQUESTURL,

username :process.env.HTTP_USERNAME,

password :process.env.HTTP_PASSWORD

    }

}

constmqtt = require('mqtt');

constexpress = require('express')

constapp = express()

constbodyParser = require('body-parser');

app.use(bodyParser.json());

app.use(bodyParser.urlencoded({ extended:true }));

constclient = mqtt.connect(config.mqtt.server, config.mqtt.options);

//handle incoming messages

client.on('message',function(topic, msg, packet){

varreq = require('request');

req.post({

url:config.http.url,

headers: {

"Content-Type":"application/json"

        },

auth : {

username:config.http.username,

password:config.http.password

        },

body: {

"topic":topic,

"msg":msg.toString('utf8'),

"qos":packet.qos

        },

json:true

    });

});

client.on("connect",function(){ 

console.log("connected  "+ client.connected);

})

//handle errors

client.on("error",function(error){

console.log("Can't connect" + error);

process.exit(1)

})

//publish

functionpublish(topic,msg,options){

if (client.connected == true){

client.publish(topic,msg,options);

    }

}

app.post('/subscribe', (request, response) => {   

vartopic = request.body.topic;

varqos = request.body.qos;

if (typeoftopic == "undefined") {

response.status(400).send('topic not specified');

    } elseif (typeofqos == "undefined") {

response.status(400).send('qos not specified');

    } else {

client.subscribe(topic,{qos:qos});

response.status(200).send();

    }

})

app.post('/publish', (request, response) => {

vartopic = request.body.topic;

varmsg = request.body.msg;

varretain = request.body.retain;

varqos = request.body.qos;

if (typeoftopic == "undefined") {

response.status(400).send('topic not specified');

    } elseif (typeofmsg == "undefined") {

response.status(400).send('msg not specified');

    } elseif (typeofretain == "undefined") {

response.status(400).send('retain not specified');

    } elseif (typeofqos == "undefined") {

response.status(400).send('qos not specified');

    } else {

publish(topic, msg, {retain:retain,qos:qos});

response.status(200).send();

    }

})

app.listen(config.http.serverport)

Рядом с ним необходимо создать файл ".env" (прям с таким названием, как-будто только расширение) со следующим содержимым:

 Содержимое файла настроек .env

MQTT_SERVER=mqtt://srv2.mqtt.4api.ru:9991 // адрес mqtt-брокера, я в примере использовал бесплатный сервер
MQTT_CLIENTID=mqqt_over_http // тут указывается Client ID, который должен быть уникальным для каждого клиента
MQTT_USERNAME=myuser // логин для подключения
MQTT_PASSWORD=mypassword // пароль для подключения

HTTP_SERVERPORT=3000 // порт, который будет слушать скрипт для входящих от 1С запросов
HTTP_REQUESTURL=http://127.0.0.1:8080/iot/hs/mqtt/publish // адрес HTTP-сервиса сервера 1С, куда будут отправляться полченные по подписке сообщения. Выполняется POST запрос с JSON-телом {topic, msg, qos}
HTTP_USERNAME=mqtt_user // имя пользователя 1С
HTTP_PASSWORD=mqtt_password // пароль пользователя 1С

Таким должен получиться каталог со скриптом:

Готово, теперь можно запускать.

node c:mqtt_over_httpserver.js

 Запущенный скрипт

Скрипт работает и может принять запрос на подписку.

В качестве примера устройств, которые будет обмениваться информацией с 1С, были выбраны ESP32 с WiFi на борту.

На платы установлена RTOS (Mongoose-OS) в ней уже есть библиотеки для работы с MQTT-брокером и для примера я буду управлять вcтроенным синим светодиодом.

В архив к этой статье я прикреплю прошивку, которую можно прошить. Алгоритм прошивки следующий:

В программе mos.exe переходим в каталог с прошивкой (в примере C:/mos/app1)

1. Выбираем порт для подключения (в примере COM3)
2. Выбираем плату (в примере ESP32)
3. Запускаем сборку прошивки: mos build
4. Запускаем прошивку платы: mos flash
5. Настраиваем подключение к WiFi: mos wifi mywifi 012345467 (где mywifi - имя сети, а 01234567 - пароль)
6. Настраиваем подключение к MQTT-брокеру: mos config-set mqtt.enable=true mqtt.server=srv2.mqtt.4api.ru:9991 mqtt.user=myuser mqtt.pass=mypassword (Client ID - это серийный номер платы)
7. И указываем, что диод, которым мы будем управлять находится на ноге 2: mos config-set board.led1.pin=2
8. Всё

 Процесс прошивки

 

Сделаем конфигурацию, которая будет демонстрировать пример взаимодействия.

Для этого в конфигурации создадим и опубликуем HTTP-сервис c функцией принимающей сообщения и регистр сведений, который будет хранить последнее сообщение в топике:

И панель управления нашими платами:

Теперь всё готово.

Задержка между событиями возникает из-за того, что обмен происходит через сервер, а клиент получает ответы только по "таймеру", но события на сервере возникают моментально, так-что реагировать на них можно оперативно.

Материал из статьи не претендует на использование его в продуктивных средах "из коробки", но для возможного варианта архитектуры очень может пригодиться.

Источник: infostart.ru

Комментарии: