Zu den erweiterten Konzepten von JMS geh?ren Nachrichtengruppen, Nachrichtenauswahl, Transaktions- und Best?tigungsmodi sowie tote Briefwarteschlangen. Die Nachrichtengruppe stellt sicher, dass die gleiche Gruppe von Nachrichten über JMSXGroupID vom gleichen Verbraucher verarbeitet wird, um die Sequenz zu gew?hrleisten. Die Nachrichtenauswahl filtern Nachrichten basierend auf Attributen wie MessageConsumer Consumer = Session.CreateConsumer (Thema, "eventType = 'login'"); Die Transaktion unterstützt die Sitzung. Die tote Briefwarteschlange erfasst mehrere fehlgeschlagene Nachrichten, die die nachfolgende Analyse und Wiederholung erleichtern und die Fehlertoleranzfunktionen des Systems verbessern.

Bei der Zusammenarbeit mit Java Messaging Service (JMS) ist es einfach, die Grundlagen auf den Markt zu bringen - Topics, Warteschlangen, Produzenten und Verbraucher. Aber sobald Sie die Grundlagen hinter sich haben, gibt es mehrere fortgeschrittene Konzepte, mit denen Ihr Messaging -System robuster, skalierbarer und zuverl?ssiger werden kann.

Hier sind einige wichtige Bereiche, die es wert sind, in den Aufbau oder die Aufrechterhaltung schwerwiegender JMS-basierter Anwendungen zu tauchen oder aufrechtzuerhalten.

Nachrichtengruppen

Nachrichtengruppen l?sen ein gemeinsames Problem in verteilten Systemen: So sorgen Sie die Meldungsreihenfolge bei der Verwendung mehrerer Verbraucher.

Normalerweise k?nnen Nachrichten, die an eine Warteschlange gesendet werden, von einer beliebigen Anzahl von Verbrauchern verarbeitet werden. Das ist gro?artig für die Skalierbarkeit, aber schlecht, wenn Nachrichtenauftragsauftr?ge wichtig sind. Wenn Sie beispielsweise Aktiengesch?fte für ein bestimmtes Konto verarbeiten, m?chten Sie nicht, dass Trade B vor dem Handel A nur weil zwei verschiedene Verbraucher sie au?erhalb der Reihenfolge abgeholt haben.

Wie es funktioniert:

• Jede Nachricht wird eine Gruppen -ID ( JMSXGroupID ) zugewiesen, die eine logische Gruppe identifiziert.
• Der JMS -Anbieter stellt sicher, dass alle Nachrichten in derselben Gruppe gleichzeitig vom gleichen Verbraucher verarbeitet werden.
• Sobald ein Verbraucher eine Gruppe aufgenommen hat, verarbeitet kein anderer Verbraucher Nachrichten aus dieser Gruppe, bis er ver?ffentlicht wird.

Dies gibt Ihnen die Bestellung pro Gruppe und erm?glicht gleichzeitig die Parallelit?t zwischen Gruppen.

Tipp: Achten Sie darauf, dass nicht zu viele Nachrichten einer einzigen Gruppe zuzuordnen. Wenn Sie dies tun, verlieren Sie die Vorteile der parallelen Verarbeitung.

Nachrichtenauswahl

Manchmal m?chten Sie nicht, dass jeder Verbraucher jede Nachricht erh?lt. Hier sind die Nachrichtenauswahl nützlich.

Mit den Selektoren k?nnen Verbraucher die von ihnen empfangenen Nachrichten filtern, die sie auf der Grundlage von Message Header -Eigenschaften oder benutzerdefinierten Eigenschaften erhalten, die vom Produzenten festgelegt wurden.

Beispiel:

Angenommen, Sie haben ein Thema, das Benutzerereignisse wie Anmeldung, Abmelden, Profil -Update usw. übertr?gt. M?glicherweise interessieren sich separate Verbraucher nur an bestimmten Arten von Ereignissen.

 MessageConsumer Consumer = Session.CreateConsumer (Thema, "eventType = 'login'");

In diesem Fall erh?lt der Verbraucher nur Anmeldeereignisse.

Anwendungsf?lle umfassen:

• Meldungen an verschiedenen Diensten basierend auf dem Inhaltstyp weiterleiten
• Senden von Testmeldungen an spezielle Testverbraucher, ohne Live -Live zu beeinflussen
• Implementierung von leichten Pub-/Subfiltern ohne Verwaltung mehrerer Themen

Hinweis: Nicht alle JMS -Anbieter implementieren Selektoren mit der gleichen Leistung. In Umgebungen mit hohem Durchsatz testen Sie, wie sich die Selektoren auswirken.

Transaktionen und Best?tigungsmodi

Das richtige Erhalten von Nachrichtenzubereitungen bedeutet, Transaktionen und Best?tigungsmodi zu verstehen.

Wenn Sie eine Nachricht erhalten, müssen Sie dem Broker mitteilen, ob Sie sie erfolgreich behandelt haben. Wenn etwas schief geht, m?chten Sie wahrscheinlich, dass die Nachricht neu zugestellt wird.

Es gibt ein paar Hauptanerkennungsmodi:

• Session.AUTO_ACKNOWLEDGE - best?tigt automatisch das Empfang, sobald die Nachricht empfangen wird
• Session.CLIENT_ACKNOWLEDGE - verlangt von dem Client, message.acknowledge()
• Session.DUPS_OK_ACKNOWLEDGE - Faule Best?tigung, die zu Duplikaten führen kann, aber die Leistung verbessert
• Session.SESSION_TRANSACTED - Aktiviert lokale Transaktionen (mehr dazu unten)

Mit Transaktionen k?nnen Sie Nachrichtensende senden und empfangen, damit entweder alle erfolgreich sind oder keine. Dies ist nützlich, wenn Sie zwischen Nachrichtenverbrauch und Datenbankaktualisierungen koordinieren müssen.

 Session Session = Connection.CreateSession (true, 0);
MessageProducer Producer = Session.CreateProcer (Queue);
TextMessage message = session.createTextMessage ("Hallo");
Produzent.Send (Nachricht);

Session.Commit (); // Alle Operationen in dieser Sitzung sind begangen

Wenn eine Ausnahme vor dem Rufen commit auftritt, k?nnen Sie zurückrollen und wiederholen.

WICHTIG: Transaktionen sind lokal zu einer Sitzung und umfassen nicht mehrere Ressourcen, es sei denn, Sie verwenden XA -Transaktionen und einen Transaktionsmanager.

Dead Letter -Warteschlangen (DLQs)

Egal wie solide Ihr System ist, einige Nachrichten werden nicht korrekt verarbeitet. Unabh?ngig davon, ob es sich um missgebildete Daten, fehlgeschlagene Gesch?ftslogik oder externe Serviceprobleme handelt, werden Sie schlie?lich Nachrichten begegnen, die immer wieder fehlschlagen.

Dead Letter -Warteschlangen wirken als Sicherheitsnetz. Wenn eine Nachricht nach einer bestimmten Anzahl von Versuchen nicht übermittelt wird, wird sie in den DLQ verschoben, anstatt endlos durch Ihr System zu schleifen.

So konfigurieren Sie es h?ngt vom JMS -Anbieter ab , aber die meisten Broker bieten Einstellungen an wie:

• Max -Nachbereitungsversuche
• Zeitverz?gerung zwischen Wiederholungen
• Target Dead Letter Warteschlange Name

Sobald Nachrichten im DLQ landen, k?nnen Sie sie manuell inspizieren oder ein Tool erstellen, um sie sp?ter neu zu verarbeiten.

Pro -Tipp: überwachen Sie Ihren DLQ regelm??ig. Es ist oft der erste Ort zum Aussehen, wenn die Dinge stromabw?rts schief gehen.

Dies sind nicht die einzigen fortschrittlichen Funktionen in JMS, aber sie decken einige der wirkungsvollsten bei der Skalierung oder Behebung von Messaging -Systemen ab.

Jedes Konzept befasst sich mit realen Problemen-Best?tigung, Filterung, Zuverl?ssigkeit und Fehlerbehandlung-und zu wissen, wie und wann sie angewendet werden müssen, einen gro?en Unterschied im Systemverhalten ausmachen.

Grunds?tzlich ist das.

Das obige ist der detaillierte Inhalt vonJMMA -Messaging -Warteschlangen (JMS) Fortgeschrittene Konzepte. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!