Wie eine Verbindung zu RabbitMQ mit RabbitMQ JMS-client aus einer vorhandenen JMS-Anwendung?

Habe ich eine generische standalone-JMS-Anwendung, die arbeitet mit folgenden JMS-Provider WebSphere, HornetQ und ActiveMq. Ich pass Kontext.INITIAL_CONTEXT_FACTORY und Kontext.PROVIDER_URL, die als Parameter an meine Anwendung, und erstellen Sie ein naming context, aus Ihnen etwas zu tun, wie diese

Properties environmentParameters = new Properties();
environmentParameters.put(Context.INITIAL_CONTEXT_FACTORY, property.context);
environmentParameters.put(Context.PROVIDER_URL, property.provider);
namingContext = new InitialContext(environmentParameters);

Und verwenden Sie das Kontext-Objekt lookup.

Ich verstehen, RabbitMQ nicht einen JMS-provider, damit es nicht ein InitialContext-Klasse oder einen Provider URL, aber es bietet ein JMS-Client, das ist eine Abstraktion, die von Ihrer Java-client gemäß der JMS-Spezifikation. RabbitMQ ist JMS-client Dokumentation ist ein Beispiel für die Definition von Objekten in JNDI-Ressource-Konfiguration als Teil einer web-Anwendung, aber ich konnte nicht herausfinden, wie zu tun, etwas ähnliches für meinen standalone-Anwendung, die erstellt ein naming context, basierend auf JNDI-Anbieter, JMS-client-Abhängigkeiten oder beim erstellen eines InitialContext aus den verfügbaren Abhängigkeiten.

So jemand kann werfen etwas Licht auf, wie dies geschehen kann? Hoffe meine Frage ist klar.

InformationsquelleAutor Niranjan Subramanian | 2015-10-28

8

Um JMS arbeiten mit RabbitMQ, müssen Sie aktivieren die plugin rabbitmq_jms_topic_exchange.

Sie können es herunterladen und folgt den Anweisungen auf dieser Website (Sie müssen login):

https://my.vmware.com/web/vmware/details?downloadGroup=VFRMQ_JMS_105&productId=349
1. Nach der Extraktion wird die Datei rjms-Thema-selector-1.0.5.ez im Ordner $RABBITMQ_SERVER\plugins.
2. Aktivieren Sie das plugin mit dem Befehl: rabbitmq-plugins enable rabbitmq_jms_topic_exchange
3. Überprüfen, ob das plugin läuft es ok mit dem Befehl: rabbitmq-plugins list
4. Starten Sie den RabbitMQ - ich bin mir nicht sicher, ob es wirklich notwendig ist, aber nur für den Fall 😉
5. Auf Ihre RabbitMQ web-management (http://localhost:15672/#/exchanges) können Sie die neuen Exchange haben Sie zur Verfügung:
6. Nun, in der Theorie :-), bist du schon in der Lage, eine Verbindung zu Ihrem RabbiMQ server mit den standard-Java-JMS-API.
Beachten Sie, dass müssen Sie erstellen eine .Bindungen-Datei, um die JNDI gefunden, die Ihren eingetragenen Objekte. Dies ist ein Beispiel für den Inhalt des it:
```
    ConnectionFactory/ClassName=com.rabbitmq.jms.admin.RMQConnectionFactory
    ConnectionFactory/FactoryName=com.rabbitmq.jms.admin.RMQObjectFactory
    ConnectionFactory/RefAddr/0/Content=jms/ConnectionFactory
    ConnectionFactory/RefAddr/0/Type=name
    ConnectionFactory/RefAddr/0/Encoding=String
    ConnectionFactory/RefAddr/1/Content=javax.jms.ConnectionFactory
    ConnectionFactory/RefAddr/1/Type=type
    ConnectionFactory/RefAddr/1/Encoding=String
    ConnectionFactory/RefAddr/2/Content=com.rabbitmq.jms.admin.RMQObjectFactory
    ConnectionFactory/RefAddr/2/Type=factory
    ConnectionFactory/RefAddr/2/Encoding=String
    # Change this line accordingly if the broker is not at localhost
    ConnectionFactory/RefAddr/3/Content=localhost
    ConnectionFactory/RefAddr/3/Type=host
    ConnectionFactory/RefAddr/3/Encoding=String
    # HELLO Queue 
    HELLO/ClassName=com.rabbitmq.jms.admin.RMQDestination
    HELLO/FactoryName=com.rabbitmq.jms.admin.RMQObjectFactory
    HELLO/RefAddr/0/Content=jms/Queue
    HELLO/RefAddr/0/Type=name
    HELLO/RefAddr/0/Encoding=String
    HELLO/RefAddr/1/Content=javax.jms.Queue
    HELLO/RefAddr/1/Type=type
    HELLO/RefAddr/1/Encoding=String
    HELLO/RefAddr/2/Content=com.rabbitmq.jms.admin.RMQObjectFactory
    HELLO/RefAddr/2/Type=factory
    HELLO/RefAddr/2/Encoding=String
    HELLO/RefAddr/3/Content=HELLO
    HELLO/RefAddr/3/Type=destinationName
    HELLO/RefAddr/3/Encoding=String
 
```
... Und dann... endlich... der code:
```
 
Eigenschaften environmentParameters = new Properties(); 
environmentParameters.put(Context.INITIAL_CONTEXT_FACTORY, "com.Sonne.jndi.fscontext.RefFSContextFactory"); 
environmentParameters.put(Context.PROVIDER_URL, "file:/C:/rabbitmq-Bindungen"); 
namingContext = new InitialContext(environmentParameters); 

ConnectionFactory connFactory = (ConnectionFactory) ctx.lookup("ConnectionFactory"); 
```
- Danke, ja mit Bezug auf Konfiguration, ich habe es hinbekommen, ich aber noch nicht herausfinden, wie diese zu erstellen .Bindungen-Datei. Ich kam über ein paar Beispiele, aber gibt es eine Möglichkeit diese Datei zu erstellen? Bestimmte Systeme wie IBM ein Fehler in WMQ kümmert sich um das erstellen dieser Datei für die Nutzer.
- Ich habe diese Datei erstellt, ohne die Hilfe von Werkzeug. Für die RabbitMQ-ich weiß nicht, ob es die Art und Weise, dass es automatisch erstellt wird, ich denke nicht so. Ich folgte der syntax nach einigen Messungen fand ich im internet und auch in den Vergleich ein .Bindungen-Datei automatisch erstellt, indem die IBM MQ-Explorer.
- Okay, ich verstehe. Auch was überrascht, ist, dass ich nicht finden, eine offizielle Dokumentation, die auf dieser .Bindungen-Datei, außer paar posts im internet. Auf jeden Fall werde ich versuchen Sie Ihre Antwort, und siehe.
- Müssen wir ausdrücklich hinzufügen eines exchange-was ist Typ x-jms-Thema? Standardmäßig sehe ich keinen exchange benannt jms.langlebig.Warteschlangen? Und in deinem screenshot, warum ist der Typ direkt? Sollte es nicht so etwas wie JMS-Warteschlange oder so?
- Eigentlich ist dies alles für Sie automatisch, wenn Sie das plugin installieren, dann sollten Sie nicht brauchen, etwas anderes zu tun neben der installation.
- nun, das war nicht der Fall für mich. Ich hatte nicht das zusätzliche exchange hervorgehoben ist in deinem screenshot. Sowieso beim laufen haben Sie sich Begegnung diese Ausnahme? Verursacht durch: javax.die Benennung.NamingException: Unbekannt Klasse [Kom.rabbitmq.jms.admin.RMQConnectionFactory]
- Überprüfen Sie, ob auf Ihrem classpath alle diese Abhängigkeiten: amqp-client-3.1.5.jar, fscontext.jar, geronimo-jms_1.1_spec-1.1.1.jar, providerutil.jar, rabbitmq-jms-1.0.5.jar.
- Yup, ich habe all diese in meinem classpath.
- Seien Sie vorsichtig mit der provider_url, wie angegeben und werden hier; es ist nicht eine kompatible Datei:// URI. Verwenden file:. Ihr .bindings Datei in Ihrem Arbeitsverzeichnis, file:/<blah> vermutlich sieht von der Wurzel Ihrer Datei-system. file:/C:/rabbitmq-bindings ist nicht eine URI, aber /C:/rabbitmq-bindings ist nur die Unix-Ausdrücken ein Windows-Pfad, verwurzelt in der C-Laufwerk.
InformationsquelleAutor Ualter Jr.

Für Menschen, die auf diese Ausnahme

Caused by: javax.naming.NamingException: Unknown class [com.rabbitmq.jms.admin.RMQConnectionFactory]

selbst nachdem @Ualter Jr ' s Antwort ist, weil Sie von falschen Einträgen in der .Bindungen-Datei.

Korrigiert habe ich die folgenden 2 Zeilen in .Bindungen Datei

ConnectionFactory/ClassName=com.rabbitmq.jms.admin.RMQConnectionFactory --->
ConnectionFactory/ClassName=javax.jms.ConnectionFactory

und

YourQueueName/ClassName=com.rabbitmq.jms.admin.RMQDestination --->
StriimQueue/ClassName=javax.jms.Queue

Wenn ich traf diese Ausnahme wieder habe ich gerade eröffnet dieses Klasse und festgestellt, dass es erwartet, dass die folgenden Klassennamen

      /*
     * Valid class names are:
     * javax.jms.ConnectionFactory
     * javax.jms.QueueConnectionFactory
     * javax.jms.TopicConnectionFactory
     * javax.jms.Topic
     * javax.jms.Queue
     *
     */

Korrektur diese Einträge würden es ermöglichen, die vorhandenen/neuen JMS-Anwendungen arbeiten mit RabbitMQ.

InformationsquelleAutor Niranjan Subramanian

Wir generieren können .Bindungen Datei RabbitMQ Verwendung unter java-code:

import java.util.Properties;
import javax.jms.ConnectionFactory;
import javax.jms.Queue;
import javax.jms.Topic;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.Reference;
import javax.naming.StringRefAddr;

Properties env = new Properties();
    env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.fscontext.RefFSContextFactory");
    env.put(Context.PROVIDER_URL, "file:bindings");
    Context ctx = new InitialContext(env);

    Reference connectionFactoryRef = new Reference(ConnectionFactory.class.getName(), RMQObjectFactory.class.getName(), null);
    connectionFactoryRef.add(new StringRefAddr("name", "jms/ConnectionFactory"));
    connectionFactoryRef.add(new StringRefAddr("type", ConnectionFactory.class.getName()));
    connectionFactoryRef.add(new StringRefAddr("factory", RMQObjectFactory.class.getName()));
    connectionFactoryRef.add(new StringRefAddr("host", "$JMS_RABBITMQ_HOST$"));
    connectionFactoryRef.add(new StringRefAddr("port", "$JMS_RABBITMQ_PORT$"));
    ctx.rebind("ConnectionFactory", connectionFactoryRef);

    String jndiAppend = "jndi";
    for (int i = 1; i <= 10; i++) {
        String name = String.format("queue%02d", i);
        Reference ref = new Reference(Queue.class.getName(), com.rabbitmq.jms.admin.RMQObjectFactory.class.getName(), null);
        ref.add(new StringRefAddr("name", "jms/Queue"));
        ref.add(new StringRefAddr("type", Queue.class.getName()));
        ref.add(new StringRefAddr("factory", RMQObjectFactory.class.getName()));
        ref.add(new StringRefAddr("destinationName", name));
        ctx.rebind(name+jndiAppend, ref);

        name = String.format("topic%02d", i);
        ref = new Reference(Topic.class.getName(), com.rabbitmq.jms.admin.RMQObjectFactory.class.getName(), null);
        ref.add(new StringRefAddr("name", "jms/Topic"));
        ref.add(new StringRefAddr("type", Topic.class.getName()));
        ref.add(new StringRefAddr("factory", RMQObjectFactory.class.getName()));
        ref.add(new StringRefAddr("destinationName", name));
        ctx.rebind(name+jndiAppend, ref);
    }

InformationsquelleAutor Chetan Laddha

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.