MQTT jest protokołem wiadomości: publikujący wysyłają komunikaty, a subskrybenci odbierają właściwe tematy. Może łączyć kolektor przemysłowy z aplikacjami. Nie określa pomiaru czujnika, jednostki ani warunku alarmu; należą one do kontraktu danych aplikacji.
Broker i struktura tematów
Broker kieruje wiadomości do subskrybentów. Nadawca nie musi znać każdego odbiorcy, lecz dostęp, pojemność, uprawnienia i sprawność brokera wymagają obsługi. Domyślne prawo każdego urządzenia do publikowania wszędzie jest niewłaściwe.
Tematy odzwierciedlają czytelną hierarchię. site-a/line-2/machine-7/state jest przykładem, nie adresem obiektu. Oddziel stałą tożsamość od nazwy ekranowej, aby zmiana nazwy nie dzieliła historii. Nie umieszczaj sekretów ani danych osobowych w tematach.
Komunikat może zawierać wartość, jednostkę, czas źródła, jakość i wersję schematu. Opisz limit rozmiaru i pola opcjonalne. Odbiorcy powinni rozumieć wiadomość jednakowo, bez osobnego zgadywania rejestru.
Co rzeczywiście zapewnia QoS
OASIS MQTT 5.0 definiuje trzy poziomy. Dotyczą one odpowiedniego odcinka komunikacji protokołu, nie automatycznie jednej operacji bazy czy jednorazowego działania fizycznego.
| Poziom | Dostarczenie w protokole | Pytanie aplikacyjne |
|---|---|---|
| QoS 0 | Najwyżej raz | Czy można utracić obserwację? |
| QoS 1 | Co najmniej raz | Jak rozpoznawać powtórzenia? |
| QoS 2 | Dokładnie raz na odcinku protokołu | Co dzieje się w usługach dalej? |
Subskrybent może przetworzyć wiadomość i stracić potwierdzenie bazy. Ponowienie może powtórzyć operację aplikacji. Stałe ID, unikalność i granice transakcji nadal są potrzebne. QoS 2 nie stanowi nieograniczonej gwarancji biznesowej exactly-once od końca do końca.
Zachowane nie znaczy aktualne
Wiadomość retained może dać nowemu subskrybentowi ostatni zapis tematu, który jest stary. Interfejs sprawdza czas źródła i regułę aktualności. Natychmiastowy odbiór po połączeniu nie dowodzi obecnej sprawności urządzenia.
Last Will sygnalizuje utratę połączenia, lecz nie każdy błąd obiektu. Połączony kolektor może utracić pojedynczy czujnik. Dostępność urządzenia, sprawność kolektora i łączność aplikacji pozostają rozdzielone.
Przykładowy przepływ temperatury
Kolektor buforuje datowane pomiary podczas przerwy nadrzędnej, a potem wysyła z pierwotnymi ID. Aplikacja usuwa duplikaty, umieszcza spóźnione dane w historii i nie zastępuje bieżącego widoku starszym punktem.
Kolejka jest skończona. Określ czas przerwy, alarmy magazynu i awarię zapisu. Testuj wiele równoczesnych powrotów i ogranicz dosyłanie, aby nowe pomiary i odczyty działały. Ograniczone odstępy ponowień nie powinny przeciążać odzyskującej się sieci.
Pytania rozpoznawcze
- Gdzie działa broker i kto go utrzymuje?
- Jak zarządzane są tożsamości i prawa tematów?
- Jakie pola są obowiązkowe?
- Jak testuje się bufor, dosyłanie i duplikaty?
- Co dzieje się przy wymianie poświadczeń lub certyfikatów?
MQTT nie zastępuje modelu danych ani planu pracy. Sprawdź mały przepływ w normalnych warunkach, po przerwie i przy podwójnym dostarczeniu przed rozbudową.
Przykład duplikatu aplikacyjnego
Kolektor publikuje temperaturę observation-1042. Odbiorca zapisuje, ale potwierdzenie przetwarzania ginie. Ponowienie zachowuje ID i czas pierwotny. Odbiorca rozpoznaje istniejący rekord zamiast dodawać próbkę. Nowy identyfikator przy każdej próbie zniszczyłby ten dowód wspólnej obserwacji.
Inny konsument może oceniać alarm. Jego stan także wymaga projektu: brak podwójnych pomiarów nie zapewnia braku podwójnych powiadomień. Zapisz relację wejścia, przejścia alarmu i zadania wysyłki. Gdy dostawca przekroczy czas odpowiedzi, zachowaj niepewny wynik zamiast zapewniać, że nic nie wysłano. To zasada aplikacji, nie dodatkowa gwarancja MQTT.
Zaprojektuj odrzucenia. Nieznany schemat, błędna jednostka i niemożliwa tożsamość muszą być diagnozowalne. Bezmyślne ponawianie trwale wadliwego komunikatu zajmuje zasoby. Ogranicz obsługę i pokaż źródło w widoku operacyjnym. Nie loguj sekretów ani pełnych nieograniczonych treści dla wygody debugowania.
Sprawdź uprawnienia i odzyskiwanie
Testuj publikację i subskrypcję dozwolonych tematów, a następnie próbę poza zakresem z oczekiwanym odrzuceniem. Osobno sprawdź wymienione poświadczenia i wycofane urządzenie. Samo połączenie niewiele mówi o jego ograniczeniach.
Przerwij łącze nadrzędne przy działającym zbieraniu, potem przywróć historię i dane aktualne. Kontroluj pierwotne czasy, ID i wiek na panelu. Sprawdź pełny magazyn lokalny: stan ma być widoczny również po powrocie brokera. Udokumentuj wersję MQTT, sesje i zasady potwierdzania wraz z konfiguracją klienta oraz brokera. Przynieś ten zapis, przykład komunikatu i hierarchię tematów na przegląd integracji. Umożliwią ocenę niezawodności bez przypisywania jednemu QoS rozwiązania wszystkich problemów dostarczania.