MQTT

MQTT este disponibil alegând protocolul mqtt pe o cerere WebSocket.

Configurare

Câmp	Rol
URL	Adresa brokerului (mqtt://, mqtts:// sau WebSocket)
Topic	Topicul, purtat de câmpul Eveniment
Mesaj	Sarcina utilă publicată
QoS	0, 1 sau 2 — folosit la publicare și la abonare
Retain (păstrare)	Marchează mesajul ca reținut de broker
Identificator de client	Rezolvat prin Handlebars; generat automat dacă este lăsat necompletat
Utilizator / Parolă	Identificatorii brokerului; parola acceptă o valoare de tip Secret
Keepalive	În secunde
Abonare la topic	Activat implicit: la conectare, Restorm se abonează la topicul cererii

Topicul acceptă {{variables}} — capteurs/{{site}}/{{capteurId}} este un topic perfect valabil.

Testament (Last Will and Testament)

Patru câmpuri declară mesajul pe care brokerul îl va publica dacă clientul dumneavoastră dispare brusc: topicul, sarcina utilă, QoS-ul și retain-ul testamentului.

Este exact ce trebuie pentru a testa comportamentul sistemului dumneavoastră în fața unei deconectări murdare: configurați un testament, tăiați conexiunea și verificați că abonatul reacționează.

Reconectare

Clientul MQTT se reconectează automat, cu un plafon de zece încercări.

Într-un scenariu

Conexiune MQTT (care se abonează la topicul cererii și emite un eveniment pentru fiecare mesaj primit), Publicare MQTT (publică, cu QoS-ul și retain-ul cererii) și Închidere conexiune MQTT. Vedeți Conexiuni și fluxuri.

Modul server

Restorm poate găzdui un broker MQTT local: un broker pentru fiecare port, accesibil în TCP brut și prin intermediul unei pasarele MQTT-peste-WebSocket. Vedeți Simularea WebSocket, Socket.IO și MQTT.

Importarea din AsyncAPI

Un document AsyncAPI ale cărui canale folosesc protocolul mqtt produce direct cereri MQTT (una pentru fiecare canal, în publicare și în abonare), cu sarcini utile de exemplu construite din schema mesajelor. Vedeți Importarea AsyncAPI.