Wie Sie Ihr eigenes Einfache Java Message Queue schreiben . Die Message Queue fungiert als zentrale Verbindung , wo beide Programme absetzen und abholen Daten . Sie können schreiben Sie Ihre eigene Message Queue zur Einrichtung einer Schnittstelle zwischen zwei Programmen . Die grundlegende Message Queue- Setup erstellt eine Warteschlange Lage , baut eine Sitzung und sendet Nachrichten an die Warteschlange . Anleitung
1
Öffnen Sie Ihre Java -Programmiersoftware und das Projekt für die Warteschlange Code. Doppelklicken Sie auf die Code-Datei , um sie im Editor zu öffnen.
2
Erstellen Sie die URL oder Speicherort für die Warteschlange . In diesem Beispiel wird die Warteschlange in der C gesetzt : \\ Warteordner :
String queue = "c: \\ queue "; ConnectionFactory connect = new ActiveMQConnectionFactory ( Warteschlange ); Anschluss msg = connect.createConnection ( ); msg.start ();
3
starten Sie das Ziel Sitzung. Nachdem Sie den Speicherort des Ordners zu erstellen , müssen Sie den Ziel -Sitzung , um nach neuen Nachrichten zu hören. Der folgende Code legt die Sitzung Zuhörer :
Destination dest = session.createQueue ();
4
Senden Sie eine Nachricht an die Warteschlange , um die neue Session und Messaging-Service zu testen. In diesem Beispiel wird eine SMS-Nachricht an die Warteschlange gesendet :
MessageProducer pro = session.createProducer (Ziel) ; TextMessage text = session.createTextMessage ( "my message") ; pro.send ( Text );