Μετάβαση στο περιεχόμενο

MQTT

Το MQTT είναι διαθέσιμο επιλέγοντας το πρωτόκολλο mqtt σε ένα αίτημα WebSocket.

Μια καρτέλα MQTT: το θέμα, το QoS, η επιλογή Διατήρηση, η εγγραφή κατά τη σύνδεση, το αναγνωριστικό πελάτη, το keepalive, η διαθήκη (LWT) και το δημοσιευμένο ωφέλιμο φορτίο

ΠεδίοΡόλος
URLΗ διεύθυνση του μεσίτη (mqtt://, mqtts://, ή WebSocket)
ΘέμαΤο θέμα, που φέρεται από το πεδίο Συμβάν
ΜήνυμαΤο δημοσιευμένο ωφέλιμο φορτίο
QoS0, 1 ή 2 — χρησιμοποιείται στη δημοσίευση και στην εγγραφή
Διατήρηση (retain)Σημειώνει το μήνυμα ως διατηρούμενο από τον μεσίτη
Αναγνωριστικό πελάτηΕπιλύεται από το Handlebars· δημιουργείται αυτόματα αν μείνει κενό
Χρήστης / Κωδικός πρόσβασηςΔιαπιστευτήρια του μεσίτη· ο κωδικός δέχεται τιμή τύπου Μυστικό
KeepaliveΣε δευτερόλεπτα
Εγγραφή στο θέμαΕνεργό εξ ορισμού: κατά τη σύνδεση, το Restorm εγγράφεται στο θέμα του αιτήματος

Το θέμα δέχεται {{variables}} — το capteurs/{{site}}/{{capteurId}} είναι απολύτως έγκυρο θέμα.

Τέσσερα πεδία δηλώνουν το μήνυμα που θα δημοσιεύσει ο μεσίτης αν ο πελάτης σας εξαφανιστεί απότομα: θέμα, ωφέλιμο φορτίο, QoS και διατήρηση της διαθήκης.

Είναι ακριβώς ό,τι χρειάζεται για να δοκιμάσετε τη συμπεριφορά του συστήματός σας απέναντι σε μια «βρόμικη» αποσύνδεση: ρυθμίστε μια διαθήκη, κόψτε τη σύνδεση και ελέγξτε ότι ο συνδρομητής αντιδρά.

Ο πελάτης MQTT επανασυνδέεται αυτόματα, με ανώτατο όριο τις δέκα προσπάθειες.

Σύνδεση MQTT (που εγγράφεται στο θέμα του αιτήματος και εκπέμπει ένα συμβάν ανά μήνυμα που λαμβάνεται), Δημοσίευση MQTT (δημοσιεύει, με το QoS και τη διατήρηση του αιτήματος) και Κλείσιμο σύνδεσης MQTT. Δείτε Συνδέσεις και ροές.

Το Restorm ξέρει να φιλοξενεί έναν τοπικό μεσίτη MQTT: έναν μεσίτη ανά θύρα, προσβάσιμο σε ακατέργαστο TCP και μέσω μιας πύλης MQTT-πάνω-από-WebSocket. Δείτε Προσομοίωση WebSocket, Socket.IO και MQTT.

Ένα έγγραφο AsyncAPI του οποίου τα κανάλια χρησιμοποιούν το πρωτόκολλο mqtt παράγει απευθείας αιτήματα MQTT (ένα ανά κανάλι, σε δημοσίευση και σε εγγραφή), με δείγματα ωφέλιμων φορτίων κατασκευασμένα από το σχήμα των μηνυμάτων. Δείτε Εισαγωγή AsyncAPI.