Примеры по сокетам для ПЛК110/160 M02 и ПЛК1хх

[Мастеренко Иван]

День добрый.
Что-то я запутался с MQTT, если один топик читаем, и один публикуем, как в примере, вроде все понятно.
А если необходимо несколько топиков читать и писать, работает как-то непредсказуемо.
Пробовал и несколько экземпляров MQTT_Client вызывать, и один экземпляр последовательно с разными топиками в одном цикле ПЛК, и один экземпляр последовательно в разных циклах ПЛК.
Подскажите, как правильно организовать обмен?
В идеале, в виде примера хотя бы два топика на чтение и два на запись.
Хочу прикрутить MQTT на ПЛК-110-60 М02.

Добрый день.
Обновил пример по MQTT и библиотеку MQTTOwenPlc_udp.lib: https://owen.ru/forum/showthread.php...l=1#post327664
Публикация выполняется последовательно в два топика (по временному интервалу) и добавлены 2 топика подписчика.

[LAM]

Добрый день.
Обновил пример по MQTT и библиотеку MQTTOwenPlc_udp.lib: https://owen.ru/forum/showthread.php...l=1#post327664
Публикация выполняется последовательно в два топика (по временному интервалу) и добавлены 2 топика подписчика.

День добрый.
Спасибо за пример.
Но по идее правильнее тогда
sPublic: ARRAY [0..1] OF STRING:='Test0', 'Test1';
Публиковать ведь нужно разные сообщения.

И дальше получается что данные с брокера, из топика на который подписаны, попадают по порядку сначала в asSubscriber[0], потом в asSubscriber[1] и так далее (если массивы расширить до большего числа элементов, то это более наглядно просматривается).
(*когда получаем сообщение от издателя xMess равна TRUE)
IF xMess THEN
iNumberSubTopic:=iNumberSubTopic+1;
xSub:=TRUE;
xMess:=FALSE;
END_IF
Но ведь при большом числе топиков, они не все обновляются по порядку, и соответственно в массив получения они будут попадать по порядку обновления а не по тем топикам где находятся.
получается что необходимо доработать библиотеку и внести на выход еще одну переменную, чтоб при получении понимать в какой топик пришло новое значение.
В общем, запутался еще больше.

[LAM]

День добрый.
Спасибо за пример.
Но по идее правильнее тогда
sPublic: ARRAY [0..1] OF STRING:='Test0', 'Test1';
Публиковать ведь нужно разные сообщения.

И дальше получается что данные с брокера, из топика на который подписаны, попадают по порядку сначала в asSubscriber[0], потом в asSubscriber[1] и так далее (если массивы расширить до большего числа элементов, то это более наглядно просматривается).
(*когда получаем сообщение от издателя xMess равна TRUE)
IF xMess THEN
iNumberSubTopic:=iNumberSubTopic+1;
xSub:=TRUE;
xMess:=FALSE;
END_IF
Но ведь при большом числе топиков, они не все обновляются по порядку, и соответственно в массив получения они будут попадать по порядку обновления а не по тем топикам где находятся. Попробуйте расширить количество топиков хотя бы до 10.
получается что необходимо доработать библиотеку и внести на выход еще одну переменную, чтоб при получении понимать в какой топик пришло новое значение.
В общем, запутался еще больше.

[LAM]

Добрый день.
Обновил пример по MQTT и библиотеку MQTTOwenPlc_udp.lib: https://owen.ru/forum/showthread.php...l=1#post327664
Публикация выполняется последовательно в два топика (по временному интервалу) и добавлены 2 топика подписчика.

Добрый день.
В том примере что вы сделали, пишет в топики отлично. а вот при чтении данные попадают куда им хочется, совсем не в те топики куда должны.
Попробуйте растяните пример на большее количество топиков, и вы увидите.