MQTT Broker Tutorial – IoT-Anwendung besser bauen

Schneller Überblick

Bevywise Crystal MQ Broker Übersicht

BevywiseMQTT Brokerist eine komplette IoT Application Suite mit einem eingebauten MQTT Broker. Es handelt sich um einen zentralen MQTT Server, die die Kommunikation zwischen MQTT-fähigen Edge-Geräten / Internet der Dinge (IoT) erleichtert Geräte und sammelt Daten, die für die Datenanalyse und Visualisierung gespeichert werden können.

CrystalMQ Broker verwendet Message Queuing Telemetry Transport (MQTT) Protokoll als Standard-Messaging-Protokoll/Kommunikationsprotokoll.MQTArbeiten auf der Grundlage des Publikationsabonnements Modell. Es bietet Ihnen einen voll ausbaubaren Rahmen, der hilft Sie bauen leistungsstarke IoT/IIoT-Anwendungen für alle industriellen Anwendungsfälle auf.

Unterstützte MQTT-Versionen:

• MQT 3.1
• MQ3.1.1
• MQTT 5

Schlüsselfunktionen

Das ist ein Problem. Messaging:Kristall MQ verwendet ein themenbasiertes Messaging-Modell, bei dem Nachrichten veröffentlicht auf spezifische Themen, es den Abonnenten erlaubt, nur relevante Daten auf Basis ihrer Abonnements zu erhalten.

QoS Handling:CrystalMQ unterstützt verschiedene Servicequalität (QoS) Levels (0, 1, 2), um die Nachricht zu gewährleisten Liefersicherheit und Garantie, basierend auf den Anforderungen des Kommunikationsszenarios.

Das ist der Grund:Es verwaltet Client-Verbindungen, einschließlich Aufbau, Wartung, und Abschluss von MQTT-Verbindungen, sowie Handling-Verbindungs-Retries und Timeouts.

Sicherheit:Es bietet Sicherheitsfunktionen wie TLS-Verschlüsselung, Authentifizierungsmechanismen (Benutzername/Passwort, Kundenzertifikate), und Zugriffskontrolle, um eine sichere und autorisierte Kommunikation zu gewährleisten.

Persistenz:Es bietet die Möglichkeit, Nachrichten zu speichern und zu verwalten, um die Nachrichtenlieferung zu gewährleisten auch bei vorübergehenden Netzstörungen oder Kundenunverfügbarkeit.

Skalierbarkeit:Mit seiner Fähigkeit, Millionen von gleichzeitig zu unterstützen Verbindungen, es zeichnet sich durch die skalierbare und hochperformanteste MQTT Broker aus.

Erste Schritte

Dieser Abschnitt bietet einen umfassenden Leitfaden zum Herunterladen und Installieren die On-Premise oder selbstgehostete Version von Bevywise MQTT Broker auf Ihren gewählten Maschinen oder Server. Zusätzlich umfasst es Anweisungen zum Anschluss von Geräten und zum Testen von Messaging Szenarien (Veröffentlichung und Anmeldung) mit dem Broker.

Technische Details und Support

Dieser Abschnitt erklärt die Hardwareanforderungen und Dateien & Verzeichnisse für hochrangige Konfigurationen.

Hardwareanforderungen

Hardware-Anforderungen variieren je nach Nachrichtenrate und Größe.

Allerdings finden Sie die minimalen Anforderungen unten für Ihre Referenz.

• CPU - 1 Kern oder höher
• RAM – 2 GB oder höher
• Festplatte – 50 GB oder höher

Einführung von MQTT Broker Folders

Nach Abschluss des Installationsprozesses entdecken Sie die folgende Dateien und Ordner auf dem angegebenen Pfad.

Technischer Support

Für technische Fragen zu MQTT Broker oder müssen Sie über Ihre Anforderungen, können Sie immer erreichen uns

E-Mail:[email protected]
Nachricht: http://www.bevywise.com/contact-us.html
Telefon:Indien - +91 8072398868 / US - +1 707 879 8999

MQTT 5 Broker Properties

Dieser Abschnitt gibt einen detaillierten Überblick überMQTT 5Eigenschaften und die Konfigurationen, die Sie mit dieser Protokollversion spielen können.

Sitzungsablauf

MQTT 5 führt das Konzept von Session und Message Ablauf ein. Kunden kann Sitzungsablaufintervalle festlegen, dem Broker die getrennten Client-Sitzungen nach einem bestimmten Zeitraum zu reinigen.

Sie können das Sitzungsablaufintervall im Broker konfigurieren und festlegen. Süßigkeiten

Sie können einen bestimmten Zeitrahmen für Sitzungsablauf definieren. Einmal konfiguriert, abgeschaltete Client-Sitzungen werden nach der angegebenen Dauer automatisch entfernt.

Sie haben die Möglichkeit, ein universelles Ablaufintervall für alle Sitzungen festzulegen Geräte.

Zusätzlich können Sie für jede einzelne Sitzung Ablaufintervalle festlegen Client, indem der Wert auf -1 gesetzt wird. In diesem Fall wird der Broker das CONNECT-Paket jedes Clients für den Ablauf der Sitzung überprüfen Intervallwert, und es wird diese Werte verwenden, um die Sitzungsreinigung entsprechend zu verwalten.

Maximal

Die Eigenschaft RECEIVE MAXIMUM wird verwendet, um die maximale Anzahl an QoS 1 und QoS 2 Nachrichten, die der Client gleichzeitig verarbeiten kann. Dies erhöht die Flexibilität und Effizienz der Nachrichtenlieferung für gleichzeitige Nachrichtenverarbeitung, bessere Ressourcennutzung und verbesserte Nachrichtenhandling Dynamik zwischen Kunden und Broker.

Sie können die Zahlen im Broker konfigurieren und festlegen. beschlagnahmt SERVER_RECEIVE_MAXIMUM.

Der Wert von SERVER_RECEIVE_MAXIMUM kann zwischen 1 und 65,535 liegen.

Ein Wert von 0 gibt an, dass der Client keine QoS 1 oder QoS verarbeiten kann 2 Nachrichten gleichzeitig, diese QoS-Levels für den Client effektiv deaktivieren.

Maximale QoS

MQTT Brokerkann den Kunden über den höchsten informierenQoS-Ebenees unterstützt einschließlich Maximale QoS im CONNACK Paket während des Verbindungsaufbaus.

Beim Empfang des Maximum QoS vom Broker im CONNACK-Paket, der Client muss sich an dieser maximalen QoS-Ebene beim Senden von PUBLISH-Paketen halten.

Der Broker kann jedoch noch SUBSCRIBE-Pakete von Kunden akzeptieren mit einem beantragten QoS von 0, 1, oder 2, unabhängig von seiner Unterstützung für QoS 1 oder QoS 2 ÖFFENTLICHE Pakete.

Sie können Maximum QoS im Broker definieren. Süßigkeiten

Maximale Packungsgröße

Die maximale Packung Größe Eigenschaft wird vom Broker verwendet, um die Client über das Maximum erlaubte Größe für Pakete. Der Client ist verpflichtet, Pakete nicht größer als diese Grenze zu senden den Server. Wenn der Server erhält ein Paket, das diese Größengrenze überschreitet, es gilt als Protokollfehler, und der Server wird den Client mit DISCONNECT-Paket abschalten.

Sie können die maximale Paketgröße im Broker einstellen. wie unten.

Thema Alias Maximum

Das "Topic Alias Maximum" ist eine Eigenschaft, die verwendet wird, um das Maximum anzugeben Anzahl Das Thema beschreibt, dass ein Client während der MQTT-Kommunikation mit dem Broker verwenden kann. Dies ermöglicht es dem Broker, den Client über die maximale Anzahl von Thema Aliases zu informieren, die es kann Verwendung.

Themen-Aliase sind kurze Referenzen zu Themen, die helfen, die Größe von MQTT-Steuerpaketen indem der Name des Themas durch eine kürzere Kennung ersetzt wird (Alias).

Sie können Maximum Topic Alias in broker.conf festlegen.

Ein Wert von 0 gibt an, dass der Broker das Thema Alias nicht unterstützt, und der Client sollte das Thema Aliases in seinen Nachrichten nicht verwenden.

Server halten Alive

Die"Server halten Alive"Mechanismus bezieht sich auf eine Funktion, die es dem MQTT Broker (Server) ermöglicht, Clients zu benachrichtigen etwa das maximale Zeitintervall für die Aufrechterhaltung einer aktiven Verbindung erlaubt.

Während der Verbindungsaufbauphase (CONNACK-Paket), der MQTT Broker informiert den Kunden über das "Server Alive halten" Intervall. Das Intervall "Server Alive halten" gibt das Maximum an Zeitdauer (in Sekunden) dass der Kunde kann leer bleiben, ohne irgendwelche Steuerpakete (z.B. PINGREQ) an den Broker zu senden.

Sie können dies in mqtt definieren. Süßigkeiten

Wenn Sie hier den Halten am Leben angeben, wird der Client diesen Wert nutzen anstatt des in seinem CONNECT-Paket bereitgestellten Erhaltungswerts.

Wird jedoch der Wert auf -1 gesetzt, was bedeutet, dass der Broker nicht die Eigenschaft Server Keep Alive senden, und der Broker wird den von der Kunden in sein CONNECT-Paket.

Zurück zur Verfügung

Die Funktion "Retain Available" bezieht sich auf die Fähigkeit eines MQTT Broker zur UnterstützungZurück zur Übersicht. Eingehaltene Nachrichten sind spezielle MQTT-Nachrichten, die auf dem Broker und an neue Abonnenten geliefert, wenn sie ein Thema abonnieren.

Sie können aktivieren / deaktivieren Retain in mqtt.conf

Ein Wert von 0 bedeutet, dass gespeicherte Nachrichten deaktiviert sind. Ein Wert von 1 Mittel werden gespeicherte Nachrichten aktiviert.

Wild Card Abonnement Verfügbar

Ein Wildcard-Abonnement bezieht sich auf ein Abonnement-Muster, das erlaubt Kunden abonnieren mehrere Themen mit Wildcard-Zeichen (+, #).

Sie haben die Möglichkeit, den MQTT Broker zu konfigurieren, um entweder zu aktivieren oder die Wildcard Funktion basierend auf Ihren Anforderungen deaktivieren.

Ein Wert von 0 bedeutet, dass Wild Card Subscription deaktiviert ist. Ein Wert von 1 bedeutet, dass das Wild Card Subscription aktiviert ist.

Subscription Identifiers Verfügbar

Subscription-Identifier sind ein Feature, das MQTT-Clients ermöglicht Empfänger Kennungen zu ihren Abonnements. Abonnementkennzeichen werden verwendet, um einzelne Abonnements eindeutig zu identifizieren hergestellt durchMQTT Kundenzu spezifischen Themen. Jedes Abonnement kann einer eindeutigen Kennung zugeordnet werden.

Ein Wert von 0 bedeutet, dass Abonnementkennzeichen deaktiviert sind. Ein Wert von 1 bedeutet, dass Abonnement-Kennzeichen aktiviert werden.

MQT Geteiltes Abonnement

Unser Broker unterstützt standardmäßig freigegebene Abonnements und ermöglicht Daten werden unter abonnierte Geräte. Wenn ein Publisher Daten an ein Thema sendet, wird es unter allen abonniert Kunden. Zum Beispiel, wenn zwei Kunden sind abonniert auf 'Topic 1', der Broker wird das Senden von Nachrichten zwischen ihnen wechseln.

Geteilte Abonnements folgen dem untenstehenden Format

Sie können das gleiche in mqtt aktivieren / deaktivieren. Süßigkeiten

Anmerkung:Bitte beachten Sie, dass während der Funktion der gemeinsamen Abonnements innerhalb von Knoten in einer Clusterumgebung erstrecken sie sich nicht über den gesamten Cluster.

MQTT Broker Benutzeroberfläche und Dashboard

Unser Broker UI ermöglicht Ihnen die Überwachung, Visualisierung und Verwaltung Ihrer angeschlossenen Geräte und Daten. Dieser Abschnitt bietet einen tiefen Blick auf wie Sie auf das Dashboard zugreifen und MQTT-Daten in einer gewünschten Weise visualisieren können.

Zugang zum UI / Dashboard

Standardmäßig startet die UI des Brokers im Port 8080. Sie können darauf zugreifen, indem Sie zum Browser navigieren und eingeben

Oder

Kunden

Dieses Menü zeigt die komplette Liste der Geräte (beide aktiv & inaktiv) die mit demMQTT Broker. Dies bietet Ihnen eine hohe Sicht auf jedes angeschlossene Gerät.

Lassen Sie uns tiefer graben, um zu wissen, wie das helfen kann.

Dashboard bietet die neuesten schnellen Ereignisse von Geräten. Aber wie kann wir erhalten die komplette Liste der Ereignisse veröffentlicht und die Befehle empfangen, wenn es ein Abonnent ist?

Wie kann ich einen sofortigen Befehl an die Geräte senden?

Alle diese Fragen können beantwortet werden, wenn Sie die optimale Nutzung von Clients Menu.

• Gehen Sie zu Kunden
• Klicken Sie auf einen Client

Veranstaltungen

Die vollständige Liste der Ereignisse, die vom ausgewählten Gerät veröffentlicht werden. Sie können auch die Liste der Nachrichten veröffentlicht zusammen mit seinen zugehörigen Themen von den ausgewählten Gerät.

• QoS-Ebene jedes Themas veröffentlicht. Lesen Sie unseren Blog, um mehr über Quality of Service (QoS) zu erfahren Niveau.
• Der Zeitpunkt, zu dem die Nachricht veröffentlicht wurde.

Befehle

Die vollständige Liste der von dem ausgewählten Gerät abonnierten Befehle. Du kann auch erhalten,

• Die Liste der Nachrichten, die vom ausgewählten Gerät zusammen mit seinen zugehörigen Themen empfangen werden.
• QoS-Ebene jedes Themas abonniert.
• Der Zeitpunkt, zu dem die Nachricht vom empfangenen empfangen wurde.

Themen eintragen

Dies ist eine Liste der Themenfilter, die vom jeweiligen Client abonniert werden.

Befehl senden

„Send Command“ hilft Ihnen, Sofortnachrichten an den Client zu senden.

Folgen Sie den Schritten, um einen sofortigen Befehl zu senden :

• Wählen Sie den Themennamen aus dem Dropdown-Menü.
• Stellen Sie sicher, dass das Thema durch das Gerät abonniert wird, an das Sie den Befehl senden.
• Geben Sie den Befehl ein, der im Nachrichten-Tab gesendet werden soll.

Themen

Die absolute Liste der von allen Geräten veröffentlichten und abonnierten Themen mit dem Broker verbunden.

Systemprotokoll

Die Verbindung der Vorrichtung mit dem Broker kann sein aus so vielen Gründen eingeschränkt/unterbrochen. Die Registerkarte Device Log enthält eine Liste von Fehlern, die während der Verbindung eines Geräts mit dem Broker aufgetreten. Das hilft Ihnen, den Grund hinter der Scheitern.

Die folgende Liste hilft Ihnen, den Grund für den Fehler zu identifizieren.

Sicherheit

SicherheitMQTT-Sicherheitist unerlässlich, um sensible Daten zu schützen und die Integrität von Messaging-Systemen zu erhalten. von die wichtigsten Aspekte der MQTT-Sicherheit zu behandeln, können Organisationen eine robuste Sicherheit schaffen Haltung für MQTT-basierte Bereitstellungen, Schutz sensibler Daten, unberechtigten Zugriff verhindern und die Integrität und Vertraulichkeit von MQTT aufrecht erhalten Kommunikation.

Hier sind drei Sicherheitsstufen in Bevywise MQTT Broker:

Geräte-Level Authentication

Die Authentifizierung auf Geräteebene beinhaltet die Validierung der Identität von Geräten Verbindung zum MQTT-Broker. Dies ist entscheidend, um nicht autorisierte Geräte zu verhindern vom Zugriff auf den Broker und stellt sicher, dass nur vertrauenswürdige Geräte veröffentlichen und abonnieren können Themen.

Damit können Sie Ihre Geräte sicherer mit Authentifizierungsdaten. Dies erfordert, dass Sie Authentication Feld in mqtt aktivieren. conf-Datei in conf-Ordner vorhanden.

Authentication aktivieren :

• Gehen Sie zu ./CrystalMQ/conf (Path kann variieren)
• Open mqtt.conf
• Das Feld AUTHENTICATION_ENABLED ist auf DISABLED eingestellt. Ändern Sie es auf DEFAULT.

Speichern Sie die Datei und starten Sie den Broker neu.

Geh zur UI von MQTT Broker. Sie finden das Menü „Sicherheit“ angezeigt. Sie können Ihre Authentication Anmeldeinformationen für eine sichere Geräteverbindung erstellen.

Authentication erstellen Angaben:

Fügen Sie MQTT Benutzername (Access Key) und Passwort (Access Token) hinzu, die sein können verwendet von bestimmten ClientIds. 'Clients' - kann auf einen einzelnen ClientId geändert werden, oder eine Liste von Komma getrennt Kunde Ids (Wildcards werden unterstützt). '*' bedeutet, dass Clients mit jedem Client Id kann verbinden.

Diese Anmeldeinformationen können auch gelöscht werden.

MQTT Benutzername (Access Token) kann entweder einfach oder als Verdauung gespeichert werden in der Datenbank. Einstellung SECURE_MQTT_PASSWORD = TRUE in conf/datastore. konvertiert wird MQT Passwörter als Verdauung und wird nicht in der UI angezeigt.

Speichern Sie die Datei und starten Sie den Broker neu.

Bitte beachten Sie, dass das Schalten dieser Konfiguration erforderlich ist, um die bestehende Datenbank.

Zugangskontrolllisten (ACLs)

ACLs werden verwendet, um körnige Berechtigungen zu definieren und zu steuern, welche Geräte oder Kunden können ausführen spezifische Aktionen (z.B. veröffentlichen, abonnieren) aufMQT Themen. Diese Höhe Sicherheit hilft bei der Durchsetzung feinkörniger Zugangskontrollrichtlinien innerhalb des MQTT-Brokers.

Mit ACL aktiviert, können Sie festlegen, welche Themen die Geräte erlaubt sind bis publizieren oder abonnieren, sowie welche Themen sie vom Zugriff beschränkt sind.

ACL aktivieren

Um ACL zu aktivieren, gehen Sie in die Datei "mqt.conf" im Ordner "conf". Dann setzen Sie sich wie : TOPIC_ACL = TRUE. Speichern Sie die Datei und starten Sie den Broker neu.

MQT Benutzername ACL

Aktivieren Sie Geräte-Authentifizierung, um MQTT Username basierend ACL zu verwenden.

Navigieren Sie zum Menü 'Sicherheit'

Wählen Sie unter dem Abschnitt Access Control List MQTT Username aus

Bei der Erstellung von MQTT Username/Password sind Standard-ACL-Einstellungen automatisch generiert, die ÖFFENTLICHE/SUBSCRIBE aller Themen erlaubt. Dies kann durch Klicken auf 'Bearbeiten' im MQTT-Benutzernamen bearbeitet werden.

Comma Getrennte Liste der Themen kann konfiguriert werden, um erlaubt/geregelt werden für Publizieren und Abonnieren eines jeden Kunden Verbindung mit diesem MQTT Username. Sowohl die Publish als auch Abonnieren von Themen akzeptieren MQTT-like Filter.

(z.B. Raum/+/Temperatur)

Kundenbasiertes ACL

Sie können auch ACL basierend auf dem ClientId festlegen. ACL kann nur hinzugefügt werden bereits angeschlossene Kunden.

Wählen Sie im Sicherheitsmenü unter der Abschnitt "Zugriffskontrolle" aus 'Clients' und ACL für einen angeschlossenen Client hinzufügen.

TLS / SSL Verschlüsselung

Transport Layer Security (TLS) oder Secure Sockets Layer (SSL) Verschlüsselung fügt eine Sicherheitsschicht hinzu Verschlüsselung von MQTT-Kommunikation zwischen Clients und dem Broker. Dadurch wird verhindert, dass während des Zugriffs auf MQTT-Nachrichten eavesdropping, tampering oder unberechtigter Zugriff auf MQTT-Nachrichten erfolgt Übertragung.

TLS / SSL aktivieren

Um TLS zu aktivieren, setzen Sie TLS_ENCRYPTION = TRUE in conf/mqtt.conf :

Da TLS aktiviert ist, startet Broker im Port 8883 statt von 1883.

Anmerkung:WSS_PORT_NO startet die MQTT SSL-Version in Websocket.

MQTTRoute kommt standardmäßig mit Self-Signed Certificate for Server. Die Zertifikate finden Sie inCrystalMQ/Zertifikat

Root-Zertifikat (root.crt) muss auf dem Gerät / Client hochgeladen werden Seite, so dass der Client Überprüfen Sie, ob das Zertifikat des Servers (server.crt) durch sein vertrauenswürdiges Root-Zertifikat signiert wurde.

Wenn Sie Ihr eigenes selbstsigniertes Zertifikat erstellen müssen, überprüfen Sie unten.

Selbstsignierte Zertifikatserstellung - Linux

Erzeugen Sie den Schlüssel der Bescheinigungsbehörde

Geben Sie die Passform für den Schlüssel ein und speichern Sie ihn.

Ergebnis:

Erstellung eines Zertifikats-Antrags für die CA

Geben Sie einen beliebigen Organisationsnamen ein (z.B. Bevywise) und lassen Sie andere leer.

Ergebnis:

Erstellen Sie das Wurzelzertifikat der CA

Ergebnis :

Erstellen Sie den Server / MQTT Brokers Schlüsselpaar

Ergebnis :

Erstelle eine Bescheinigungsunterzeichnungsanfrage

Dies kann mit dem Serverschlüssel (server.key) geschehen, um zu senden. sie an die Bescheinigungsbehörde für die Identitätsprüfung

Geben Sie einen beliebigen Organisationsnamen (z.B.Bevywise Inc) an und geben Sie den gemeinsamen Name. Comman-Name (z.B. tempmyaccount.mqttserver.com) sollte der Domain-Name Ihres Servers in der MQTT Broker läuft.

Oder geben Sie localhost ein, wenn MQTT Broker auf einer lokalen Maschine arbeitet.

Ergebnis :

Erstellung und Unterzeichnung des Serverzertifikats

Dieser Schritt ist es, ein neues Server-Zertifikat zu erstellen und es mit der Leistung zu unterschreiben der Bescheinigungsbehörde.

Ergebnis :

Jetzt haben Sie die folgenden Zertifikate und Schlüssel in der Hand.

• ca-root.crt (Name an root.crt)
• Server
• Server.key

Jetzt, server.crt und server. Schlüssel sollte auf dem Server hochgeladen werden ../MQTTRoute/Zertifikat/Server, und root.crt sollten auf dem Client bereitgestellt werden, so dass der Client kann Überprüfen Sie, ob das Zertifikat des Servers (server.crt) durch sein vertrauenswürdiges Root-Zertifikat signiert wurde.

Datenbankkonfiguration

Die Optionen, um zu konfigurieren, wie Daten von der Broker wird in Bevywise/CrystalMQ/conf/datastore.conf gesetzt.

Geräteinformationen (Geräte-IDs und Abonnements) und MQTT Payload (Veröffentlichte/Empfehlte Nachrichten) werden vom Broker in einer der relationalen Datenbanken standardmäßig gespeichert. Die Beziehung Datenbanken, die von die Broker sind: SQLite, MySQL, MSSQL & PostgreSQL. Die UI nutzt diese Datenbank.

Wenn die Daten jedoch in einer anderen Datenbank gespeichert werden müssen, außerhalb der Broker, dann kann es auch konfiguriert werden.

Aktivieren / Deaktivieren von Speicher in Relational Datenbank

Um beide Geräteinformationen (Geräte-IDs, Abonnements) zu speichern und Payload (veröffentlichte/empfangte Nachrichten) in der Datenbank,

• Gehen Sie zu Bevywise/CrystalMQ/conf/datastore.conf
• Set, RELATIONAL_PERSISTENCE_ENABLED als Wahr und aktivieren Sie PAYLOAD_TO_DB

Wenn Sie beide Geräteinformationen und Payload nicht speichern möchten Datenbank, dann eingestellt

In diesem Fall ist CrystalMQ UI NICHT verfügbar. Daher PAYLOAD_TO_DB ist als DISABLED angenommen.

Um nur die Geräteinformationen in der Datenbank zu speichern und NICHT das MQTT Payloads, eingestellt

In diesem Fall sind im UI nur Geräteinformationen zu erkennen.

Lassen Sie uns unten die Relational Database Configurations sehen.

MQT Sparkplug B-Unterstützung

MQT Sparkplug Bsetzt auf einen MQTT-Broker, um die Kommunikation zwischen Industriegeräten zu erleichtern, Sensoren und Anwendungen wie SCADA, Historians, etc. Der MQTT-Broker dient als Basis Kommunikation Infrastruktur, die an derMQT Das ist alles.Standards und behandelt das Routing von Sparkplug B-konformen Nachrichten.

Sparkplug B-konforme Geräte und Anwendungen veröffentlichen und abonnieren Themen zum MQTT-Broker, nach den durch das Sparkplug B-Protokoll vorgegebenen strukturierten Datenformaten und Richtlinien.

Der MQTT-Broker liefert das Kommunikations-Backbone und Protokoll Unterstützung, während MQTT Sparkplug B die Standards und Konventionen für den Datenaustausch innerhalb industrieller IoT-Ökosysteme definiert, die Nutzung der Fähigkeiten des MQTT-Protokolls für effiziente, zuverlässige und skalierbare industrielle Automatisierung und Überwachung.

Unser Broker unterstützt standardmäßig Sparkplug-fähige Geräte ohne Änderungen der Konfiguration erfordern Datei. Aber es ist Wesentlich zu überprüfen, ob die Einstellung "Authentifizierung" im mqtt aktiviert ist. beschlagnahmt.

MQT Clustering

GewährleistungDas ist gut. Wie man sieht, mehr als 1 robuste Broker können verwendet werden. Unser CrystalMQ mit dem eingebautInter-Broker Communicator (IBC)ermöglicht es allen Brokern im Cluster, miteinander zu sprechen, um sicherzustellen, kontinuierliche Kommunikation mit den Geräten unabhängig von Kunden, die sich mit einem Broker im Cluster verbinden.

Ein Lastausgleich kann an der geräteseitigen Kante eingerichtet werden, um die Last.

Um mehr über die interbroker Kommunikationsfunktionalität zu erfahren, lesen Sie unser hochverfügbares Blog.

Um hohe Verfügbarkeit in CrystalMQ zu aktivieren, sollten Sie die interbroker kommunikator zuerst.

InterBroker Communicator aktivieren

Die eingebaute Inter-Broker Communicator-Funktion (IBC) sorgt für nahtlose Kommunikation zwischen allen Brokern innerhalb eines Clusters. Dies garantiert eine kontinuierliche Verbindung mit Geräten in beide Richtungen, unabhängig davon, mit welchen Broker-Clients sich verbinden.

Um IBC nach der Installation von MQTTRoute auf Brokermaschinen zu aktivieren, ändern Sie die Konfiguration in Bevywise/MQTTRoute/conf/mqtt.conf wie folgt:

Die folgende Abbildung zeigt den Aufbau:

Dabei werden zwei oder mehr Broker mit aktiviertem IBC gruppiert einen Cluster bilden. Ein Lastwaager ist dann konfiguriert, um Workloads gleichmäßig über diese Broker zu verteilen. Alle MQTT Broker im Cluster bleiben aktiv, und IBC innerhalb jedes Brokers sorgt für dauerhafte Kommunikation durch die Nutzung eines gemeinsamen Datenbank (DB). Das heißt dass Broker nicht direkt miteinander kommunizieren. Stattdessen drücken sie Daten auf die Zentrale Datenbank, die andere erlaubt Broker auf diese Daten zugreifen. Als Ergebnis hat jeder Broker Zugriff auf Client-Details und Daten.

Prozessüberwachung mit Monit

Um den MQTT Broker als Service zu betreiben, benötigen wir die Monit Version 5.25. Monit ist eine Open Source Dynamik Monitoring-Tool für Linux-Systeme, die zur Überwachung und Verwaltung von Systemprozessen verwendet wird. Und auch, es führt automatisch Wartung oder Reparatur eines bestimmten Prozesses (d.h. Neustart des Dienstes) und Ausführung signifikant wenn erforderlich, informelle Aktionen unter Fehlerbedingungen.

& Installation Monit:

Extrahieren Sie das Archiv mit dem Befehl unten :

Kopieren Sie die Monitrc-Datei und fügen Sie sie unten an Ort:

Enable Monit HTTP interface :

Aktivieren Sie die HTTP-Schnittstelle, indem Sie die folgenden Zeilen nicht kommentieren /etc/monitrc Datei.

Wenn Sie möchten, können Sie admin:monit mit Benutzername und Passwort ändern verwenden wollen

Starten Sie Monit:

Öffnen Sie Monit UI mit der folgenden URL in Ihrem Webbrowser http://localhost:2812

Erweiterungen

CrystalMQ hat bestimmte Erweiterungen, um es für Benutzer flexibel zu machen. Du kannst anpassen Sie es basierend auf Ihren Bedürfnissen.

Diese benutzerdefinierten Erweiterungen können einzeln oder in Kombinationen verwendet werden erfüllen Ihre Anforderungen über einen MQTT Broker hinaus.

In CrystalMQ/extensions/extension_globals.py gibt es Objekte, die kann verwendet werden, um die interne Datenbank abzufragen, Live-Updates an UI zu senden und Nachrichten an eine verbundener Client.

Diese Objekte können in den Erweiterungen verwendet werden, um zwingende Anpassungen.