JBoss-Sicherung - Apache AMQ
In diesem Kapitel lernen wir ActiveMQ kennen und erfahren, wie es als Vermittler von Nachrichten fungiert, damit Anwendungen miteinander kommunizieren können.
Was ist AMQ?
ActiveMQ ist ein in Java geschriebener Open Source-Nachrichtenbroker. Es entspricht vollständig den JMS 1.1-Standards.
JMS ist eine Spezifikation, die die Entwicklung eines nachrichtenbasierten Systems ermöglicht. ActiveMQ fungiert als Vermittler von Nachrichten, die sich zwischen Anwendungen befinden und eine asynchrone und zuverlässige Kommunikation ermöglichen.
Arten von Nachrichten
Zum besseren Verständnis werden im Folgenden zwei Arten von Messaging-Optionen erläutert.
Punkt zu Punkt
Bei dieser Art der Kommunikation sendet der Broker Nachrichten nur an einen Verbraucher, während die anderen Verbraucher warten, bis sie die Nachrichten vom Broker erhalten. Kein Verbraucher erhält die gleiche Nachricht.
Wenn keine Verbraucher vorhanden sind, speichert der Broker die Nachrichten, bis er einen Verbraucher erhält. Diese Art der Kommunikation wird auch als bezeichnetQueue based communicationDabei sendet der Produzent Nachrichten an eine Warteschlange und nur ein Verbraucher erhält eine Nachricht aus der Warteschlange. Wenn es mehr als einen Verbraucher gibt, erhalten sie möglicherweise die nächste Nachricht, aber nicht die gleiche Nachricht wie der andere Verbraucher.
Veröffentlichen / Abonnieren
Bei dieser Art der Kommunikation sendet der Broker dieselbe Kopie der Nachrichten an alle aktiven Verbraucher. Diese Art der Kommunikation wird auch als bezeichnetTopic based communicationDabei sendet der Broker dieselbe Nachricht an alle aktiven Verbraucher, die ein bestimmtes Thema abonniert haben. Dieses Modell unterstützt die Einwegkommunikation, bei der keine Überprüfung der übertragenen Nachrichten erwartet wird.
Warteschlange und Themen erstellen
Die Sicherung wird mit ActiveMQ geliefert. Wir können über die FMC-Konsole (die browserbasierte Oberfläche für die Arbeit mit AMQ) auf ActiveMQ zugreifen.
Melden Sie sich mit FMC an localhost:8181 und auswählen ActiveMQ Tab.
- Klicken Sie auf + Erstellen
- Geben Sie den Namen der Warteschlange / des Themas ein
- Wählen Sie im Optionsfeld Warteschlange / Thema aus
- Klicken Sie auf Warteschlange erstellen / Thema erstellen
Jetzt sollten Sie das sehen können TestQ erstellt unter root → Queue →
Um das erstellte Thema zu überprüfen, folgen Sie root → Topic.
Durchsuchen / Löschen von Inhalten der Warteschlange
Melden Sie sich mit FMC an localhost:8181
Wählen Sie die Registerkarte ActiveMQ
Root → Warteschlange → TestQ <Warteschlange auswählen, die Sie durchsuchen möchten> → Durchsuchen
- Um den Inhalt dieser Nachricht zu überprüfen, klicken Sie auf diese bestimmte Nachricht.
Sie können eine bestimmte Nachricht löschen, indem Sie auf die Schaltfläche Löschen in der oberen rechten Ecke klicken