18.16 Java Message Service (JMS)
 
Der JMS (http://java.sun.com/products/jms/index.html) dient dem asynchronen Austausch von Daten. Er unterstützt zwei unterschiedliche Ansätze zum Versenden von Nachrichten, zum einen die Nachrichtenschlangen (Message Queues) und zum anderen ein Anmelde-Versendesystem (Publish-Subscribe). Bei gerichteten Punkt-zu-Punkt-Verbindungen (Point-to-Point-, PTP-, Systemen) sendet ein Client eine Nachricht an einen Empfänger, der die Nachricht in einer Queue einreiht. JMS definiert, wie der Client Nachrichten verschicken kann, und wie die Nachrichten aus der Schlange genommen werden. Beim Anmeldesystem interessiert sich der Client für bestimmte Nachrichten, die dann automatisch verteilt werden. Diese Nachrichten heißen in JMS Topics.
Jede Nachricht, die JMS versendet, besteht aus einem Kopf (Header), einigen Eigenschaften (Properties) und dem Körper (Body). Der Header enthält Felder mit Angaben zur Identität und nötige Informationen, damit die Nachricht vermittelt werden kann (Routing-Informationen). Die Properties sind zusätzliche Felder, die jede Applikation selbst bestimmen kann. Der Datenteil bildet der Körper, der aus unterschiedlichen Formaten bestehen kann: einem Datenstrom, der sequenziell verarbeitet wird, Schlüssel-Werte-Paaren, Text, einem Java-Objekt oder uninterpretierten Bytes.
Obwohl ursprünglich JMS ein reiner Java-Dienst war, gibt es die ersten Java Message Services für C++ etwa von der Firma Codemesh. Mit dem Produkt JMS Courier können C++-Applikationen die Java Messaging Services einsetzen.
Weitere Informationen finden sich unter:
18.16.1 OpenJMS
Open JMS (http://openjms.sourceforge.net/) ist eine Open-Source-Implementierung des Sun Java Message Services. Das Produkt ist gut ausgereift und einfach in der Installation. Es ist auf den Architekturen Windows 98/NT/2000, Linux oder Mac OS X mit einer Java 1.2- oder einer weiteren Installation problemlos lauffähig. Eine aktuelle Version liegt unter http://openjms.sourceforge.net/download.html. Die komprimierten Dateien unter den Namen openjms-version-src.zip beziehungsweise openjms-version-src.tgz enthalten alle benötigten Jar-Archive etwa für XML-Parsing, JDBC 2.0-Erweiterungen oder Transaktionsdienste. Die Pre-Build-Version enthält einige Beispiele, und es lohnt sich, diese Distribution zu installieren.
Installation und Start des Servers
Damit wir die beigelegten Testprogramme nutzen können, müssen wir OpenJMS erst einmal vorbereiten. Wir setzen in der Datei build.bat die Umgebungsvariable JAVA_HOME, sofern sie noch nicht gesetzt ist. Dann erzeugt die Batch-Datei build.bat (oder build.sh unter Unix) über ein Ant-Skript alle kompilierten Klassen, und im bin-Verzeichnis ist der Server bereit. Dieser lässt sich anschließend starten, wobei wir uns im bin-Verzeichnis befinden sollten. (Die Beispiele werden ebenfalls im bin-Verzeichnis gestartet.)
$ start startjms -config ..\config\rmi_jms.xml
OpenJMS 0.7.1 (build 1)
Exolab Inc. (C) 1999-2001. All rights reserved. www.openjms.org
0 [main] DEBUG exolab - Attribute name=serverClass
-> org.exolab.jms.server.rmi.RmiJmsServer
10 [main] DEBUG exolab - Attribute name=jmsServerName
-> OpenJmsServer
10 [main] DEBUG exolab - Attribute name=clientPingInterval -> 15
...
17:46:10.601 INFO [main] - JMS Server is bound to //localhost:1099/OpenJmsServer
17:46:10.631 INFO [main] - JMS Admin Server is bound to //localhost:1099/JmsAdminServer
17:46:11.141 INFO [main] - Bound connection factory JmsQueueConnectionFactory
17:46:11.151 INFO [main] - Bound connection factory JmsTopicConnectionFactory
Mit start öffnen wir unter Windows in der Shell ein neues Fenster, sodass wir in dem aktuellen Fenster gleich einen Konsumenten und Produzenten starten können.
18.16.2 Beispiel mit Konsument und Produzent im Publish–Subscribe-Modell
Am einfachsten können wir uns der Software nähern, wenn wir eine kleine Applikation ansehen. Wie es bei den Nachrichtendiensten üblich ist, gibt es einen Interessenten, den Konsumenten (engl. Consumer), der für Neuigkeiten ein offenes Ohr hat. Einen Beispiel-Konsumenten wollen wir nun starten. Er meldet sich bei einem Topic, welches wir »Inselnews« nennen wollen, an und horcht auf die Nachrichten, die an diesen Topic gehen.
$ start runconsumer -topic Inselnews
examples client.console.SimpleConsumer -topic Inselnews
Using provider url rmi://localhost:1099/JndiServer
Message listener has been set
Damit startet ein Konsument, der eine Minute auf Nachrichten wartet. Falls keine empfangen werden, beendet er sich. Doch schnell wollen wir ihm seinen Produzenten geben:
$ runpublisher -topic Inselnews -count 2
examples client.console.SimplePublisher -topic Inselnews -count 2
Finished publishing 2 messages
Der Produzent (auch Publisher genannt) wird jetzt zweimal eine Nachricht mit dem Inhalt »message X« an den Topic Inselnews verschicken. Da der Konsument auf dem Kanal Inselnews horcht und seine empfangenen Nachrichten auf dem Bildschirm ausgibt, ist dort zu sehen:
org.exolab.jms.message.TextMessageImpl@b0bad7,JMSDeliveryMode=
NON_PERSISTENT, Priority=7, JMSMessageID=ID:3062033699640309713
Die einfachen Batch-Dateien rufen lediglich den Java-Interpreter mit den Klassen client.console.SimpleConsumer und client.console.SimplePublisher auf, deren Quellcode im Verzeichnis src\examples\openjms\examples\client\console zu finden ist.
|
