JMS ist der API-Standard der Nachrichtenkommunikation der Java-Plattform, der Point-to-Point-Modelle unterstützt und Modelle ver?ffentlichen/abonniert, und ActivemQ ist die von ihm implementierende Nachricht. 1. Starten Sie den Activemq -Dienst und h?ren Sie sich den Standardport an. 2. Fügen Sie die Abh?ngigkeit von Activemq-Client im Maven-Projekt hinzu; 3. Erstellen Sie Produzenten, um Nachrichten über ConnectionFactory an Warteschlangen zu senden. 4. Erstellen Sie Verbraucher, um Nachrichten asynchron über Messagelistener zu erhalten. Diese Kombination realisiert die Systementkopplung, das Schneiden von Verkehrsspitzen, die zuverl?ssige Lieferung und die asynchrone Verarbeitung, die für herk?mmliche Java Enterprise -Anwendungen geeignet ist. Obwohl es modernere Alternativen gibt, haben sie immer noch Lern- und Nutzungswert.

In modernen verteilten Systemen ist die asynchrone Kommunikation ein zentrales Mittel zur Verbesserung der Systementkopplung, Skalierbarkeit und Reaktionsf?higkeit. Java Message Service (JMS) in Kombination mit Activemq ist eine klassische Kombination aus asynchronem Messaging, insbesondere für Java-Anwendungen auf Unternehmensebene.

Was sind JMS und Activemq?

JMS ist ein API -Standard für das Senden und Empfangen von Nachrichten in der Java -Plattform und unterstützt zwei Nachrichtenmodelle:

• Point-to-Point (Warteschlange) : Die Nachricht wird an die Warteschlange gesendet und ein Verbraucher verarbeitet eine Nachricht.
• Ver?ffentlichen/Abonnieren (Thema) : Die Nachricht wird in ein Thema ver?ffentlicht, und mehrere Abonnenten k?nnen dieselbe Nachricht erhalten.

Activemq ist eine von Apache entwickelte Open-Source-JMS-Spezifikations-basierte Messaging Middleware (Message Broker). Es unterstützt mehrere Protokolle (wie OpenWire, Stomp, MQTT) und kann auf Plattformen laufen, wodurch es ideal ist, um locker gekoppelte asynchrone Systeme zu bauen.

Wie kann man asynchrone Kommunikation mit JMS Activemq implementieren?

Um JMS zu verwenden, um asynchron mit ActivemQ zu kommunizieren, sind die folgenden Schritte normalerweise enthalten:

1. Starten Sie den Activemq -Service

Laden Sie zun?chst den Dienst von der offiziellen Website von Apache Activemq herunter und starten Sie den Dienst:

 Bin/Activemq -Start

Standardm??ig h?rt ACTICTEMQ tcp://localhost:61616 an und bietet eine Webkonsole http://localhost:8161 .

2. Fügen Sie Maven -Abh?ngigkeiten hinzu

Fügen Sie in Ihrem Java -Projekt (z. B. Maven -Verwendung) die folgenden Abh?ngigkeiten hinzu:

 <De vorangehen>
    <gruppe> org.apache.activemq </Groupid>
    <artifactid> activeemq-client </artifactId>
    <version> 5.17.3 </Version>
</abh?ngig>

3. Erstellen Sie einen Nachrichtenproduzenten (Produzent)

Der Produzent sendet Nachrichten an eine Warteschlange oder ein Thema:

 Javax.jms importieren.*;
import org.apache.activemq.activemqConnectionFactory;

?ffentliche Klasse MessageProducer {
    private statische endgültige Zeichenfolge broker_url = "tcp: // localhost: 61616";
    private statische endgültige String queue_name = "Beispiel.Queue";

    public static void main (String [] args) l?st JmSexception {aus
        ConnectionFactory Factory = new ActiveMQConnectionFactory (Broker_url);
        Connection Connection = factory.CreateConnection ();
        Connection.Start ();

        Sitzung Session
        Destination destination = session.createqueue (queue_name);
        MessageProducer Producer = Session.CreateProcer (Ziel);

        TextMessage message = session.createTextMessage ("Hallo von JMS Producer!");
        Produzent.Send (Nachricht);
        System.out.println ("gesendete Nachricht:" message.getText ());

        Produzent.CLOSE ();
        Sitzung.CLOSE ();
        Connection.close ();
    }
}

4. Erstellen Sie einen Nachrichtenverbraucher

Verbraucher empfangen Nachrichten asynchron und verwenden normalerweise MessageListener , um zu implementieren:

 Javax.jms importieren.*;
import org.apache.activemq.activemqConnectionFactory;

?ffentliche Klasse MessageConsumer {
    public static void main (String [] args) l?st JmSexception {aus
        ConnectionFactory Factory = new ActiveMQConnectionFactory (Broker_url);
        Connection Connection = factory.CreateConnection ();
        Connection.Start ();

        Sitzung Session
        Destination destination = session.createqueue (queue_name);
        MessageConsumer Consumer = Session.CreateConsumer (Ziel);

        Consumer.SetMessagelistener (New Messagelistener () {
            @Override
            public void onMessage (Nachrichtennachricht) {
                if (messageinstance von textMessage) {
                    versuchen {
                        System.out.println ("empfangen:" ((textMessage) meldung) .GIETTEXT ());
                    } catch (jmsexception e) {
                        E. printstacktrace ();
                    }
                }
            }
        });

        // Halten Sie das Programm laufen und warten Sie auf Nachrichten (kann in tats?chlichen Anwendungen eleganter sein)
        System.out.println ("Warten auf Nachrichten ...");
    }
}

Hinweis: Nachdem der Verbraucher setMessageListener verwendet hat, ist die Nachrichtenverarbeitung asynchron und blockiert den Hauptfaden nicht.

Nutzungsszenarien und Vorteile

• Systementkopplung : Die Hersteller müssen die Existenz von Verbrauchern nicht kennen.
• Verkehrsspitzenschnitt : In hohen Parallelit?tsszenarien kann die Meldungswarteschlange Anforderungen pufferen.
• Zuverl?ssige Lieferung : ActivemQ unterstützt anhaltende Nachrichten, um sicherzustellen, dass Nachrichten nicht verloren gehen.
• Asynchrone Verarbeitung : zeitaufw?ndige Vorg?nge wie das Senden von E-Mails und die Protokollverarbeitung k?nnen in die Warteschlange für asynchrone Ausführung platziert werden.

Dinge zu beachten

• Verbindungsmanagement : Es wird empfohlen, Verbindungspools (z. B. PooledConnectionFactory ) in Produktionsumgebungen zu verwenden.
• Transaktions- und Best?tigungsmodus : SELECT Session.SESSION_TRANSACTED .
• Ausnahmebehandlung : Wenn ein Netzwerk unterbrochen wird oder ein Verbraucherabsturz ist, müssen die Wiederverbindung und Wiederholungsmechanismen vernünftigerweise konfiguriert werden.
• Persistenter Abonnement : Wenn der Verbraucher offline ist, kann er/sie über ein anhaltendes Abonnement verpasste Nachrichten erhalten.

Grunds?tzlich ist das. JMS Activemq ist nicht die neueste Technologie (jetzt modernere Optionen wie Kafka, Rabbitmq usw.), aber sie wird immer noch h?ufig in traditionellen Java -EE- oder Frühlingsprojekten verwendet, insbesondere für Szenarien, die Standard -JMS -Unterstützung erfordern. Das Beherrschen ist sehr hilfreich, um die Prinzipien von Message Middleware zu verstehen.

Das obige ist der detaillierte Inhalt vonJava Message Service (JMS) mit ActivemQ für asynchrone Kommunikation. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!