AC
Я к сообществу про mqtt, кто работал, подводные камни, ощущения...
Size: a a a
2021 September 09
AC
Каждый девайс создаёт свою очередь на свои команды. От вет на команду можно в общую очередь с id команды
MB
Ага, понял, спасибо
AC
Ну а с mqtt все гораздо проще, ответ можно в очередь ответа конкретного девайса
MP
пробовал немного,
ощущения такие, что придумывали это все железячники,
вроде есть приличные брокеры на го
ощущения такие, что придумывали это все железячники,
вроде есть приличные брокеры на го
AC
Ну да, для железняк оно и нужно в основном. Даже если железки с линухом и явой. Они все равно как железки, устройства у меня.
MP
я к тому, что там все прибито по битам, и довольно жестко, как и остальная логика,
но вроде как люди с этим работают и вполне успешно
но вроде как люди с этим работают и вполне успешно
VL
Мм, сообщение из очереди удалятся после прочтения?
PP
По-моему там и очередей толком нет. Персистентных во всяком случае. Опубликованное немедленно роутится на подписчиков и выкидывается.
PP
Что-то пишут про флаг retained, для сохранения последнего сообщения в топике, но только последнего.
Это пойдёт для случая, когда старые данные всё равно не нужны, типа показаний с датчика, по которым система регулирует текущие условия. Но если важен весь поток – это скорее не про MQTT.
Это пойдёт для случая, когда старые данные всё равно не нужны, типа показаний с датчика, по которым система регулирует текущие условия. Но если важен весь поток – это скорее не про MQTT.
PP
У меня больше пользовательский опыт, половина умного дома на нём, но разрабатывать под него не случалось.
MB
Там пишут, что есть три типа доставки
PP
Это немного про другое – то указание того, как доставлять сообщения, когда на брокере уже есть связка pub-sub.
Но, кстати, я успешно проморгал, что там есть сессии (а-ля consumer group в Кафке, только потребитель один), для которых отслеживается что они успели принять (ибо клиент отправляет acknowledgement) и отправляется повторно в случае нештатного перезапуска. Пожалуй, это можно считать очередью, да 🤔
Но, кстати, я успешно проморгал, что там есть сессии (а-ля consumer group в Кафке, только потребитель один), для которых отслеживается что они успели принять (ибо клиент отправляет acknowledgement) и отправляется повторно в случае нештатного перезапуска. Пожалуй, это можно считать очередью, да 🤔
PP
Спека MQTT, кстати, написана весьма по-человечески и хорошо организована, мне прям нравится:
https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Session_State
https://docs.oasis-open.org/mqtt/mqtt/v5.0/os/mqtt-v5.0-os.html#_Session_State
AC
В mqtt подкупает, лично меня наличием LWT сообщения, это такое посмертное завещание, когда клиент отключился от брокера, брокер сам его создаёт.
IG
мне кажется, слать данные можно обычным (r)syslog. Полно серверов как бесплатных, так и платных сервисов. Тело можно слать в виде json.
IG
принимать обычным поллингом. А что там на сервере -- уже дело десятое. Логи rsyslog можно перекладывать в кафку, если нужно
V0
а напомните, в каких еще языках есть аналоги with-meta (без поддержки примитивов или вдруг даже над ними)?
в рубях можно запатчить BasicObject но это загрязнит instance_methods и inspect output. примерно та же история с прототипами js (оба немного не то)
в рубях можно запатчить BasicObject но это загрязнит instance_methods и inspect output. примерно та же история с прототипами js (оба немного не то)
A
В питоне можно в инстансы объектов набросать метаданных, но это всё же не совсем то