Synchrone messaging möglich mit JMS/ein Fehler in WMQ?

Sagen wir, es ist eine mobile Anwendung, die benötigt, um eine sync-Anfrage/Abfrage einige Daten von einem server. Die Anfrage wird an hosted JMS-client zuerst, dass das veröffentlichen einer Nachricht/Anfrage auf die externe Queue (vom partner). Jetzt ist hier, wo es anfängt unklar zu sein. Wie bekomme ich eine Antwort von dem partner in der synchron-Mode.

  • Sollten die partner setzen separate queue für mich zu abonnieren und mir dann blockieren die mobile-Anfrage, bis ich die Antwort-Nachricht aus, die Sie trennen, die Warteschlange?
  • Hat JMS oder proprietäre WebSphere MQ Schnittstelle die Unterstützung für sync-Nachrichten?
  • Was sind andere Möglichkeiten, es zu implementieren, mit messaging?

Dank

InformationsquelleAutor user567068 | 2011-02-17
  1. 4

    Das lehrbuch-Muster ist wie folgt:

    1. JMS-app empfängt eine Anforderung von dem mobilen Gerät.
    2. JMS-app öffnet die reply-to-queue (die dynamische).
    3. JMS-app bereitet eine request-message Angabe des Ziels von #2 als das JMSREplyTo Ziel.
    4. JMS-app sendet die Anfrage außerhalb der syncpoint an den externen service provider.
    5. JMS-app wartet auf eine Antwort mit einem festgelegten Intervall warten. Wenn es verwendet eine dynamische reply-to-queue-es hat eine einfache erhalten. Wenn mehrere Instanzen überwacht werden die gleichen queue (die wahrscheinlich besser mit einem externen Dienst), dann verwendet es die JMSMessageID zurückgegeben, die von der "senden als" das JMSCorrelationID angegeben erhalten.
    6. JMS-app empfängt die Antwort des externen Dienstes.
    7. JMS-app Antworten auf das mobile Gerät.

    Beachten Sie, dass mit ein Fehler in WMQ das erwartete Verhalten des Diensteanbieters zu kopieren JMSMessageID aus der request-Nachricht an den JMSCorrelationID der Antwort. Es ist weniger üblich zu verlangen, dass der Absender zu generieren JMSCorrelation-ID und kopieren Sie es in das JMSCorrelationID der Antwort, aber einige Anwendungen verwenden, die Verhalten. Sie müssen verstehen, wie Ihr service provider beschäftigt sich mit diesem, um zu bestimmen, das richtige Verhalten für Ihre requester Anwendung.

    Wenn Sie die komplette ein Fehler in WMQ Client-Installation haben Sie bereits Beispielcode, der auch die meisten dieser. Wenn auf den standardmäßigen Speicherort installiert, suchen Sie in...

    C:\Program Files\IBM\Websphere MQ\tools\jms\samples\simple\simpleRequestor.java

    ...oder der entsprechende Ort unter /var/mqm für UNIX - /Linux-Distributionen. Dies ist einer der vielen Gründe, um die Vollversion installieren-client, anstatt Sie einfach nach den jar-Dateien. Wenn Sie brauchen, um den client herunterzuladen, ist geliefert, wie SupportPac MQC7.

    • Dank T. Rob, \n wir haben nicht ein Fehler in WMQ-server. Kann die reply-to-queue (vom 1.) eine remote-queue-wie auch? So, dass wir eine Reine client und nicht als host-server? Oder Sie haben zu haben, reply-to queue lokal? Auch in diesem Szenario arbeiten in einer konkurrierenden Umgebung? Wie wenn Hunderte von mobilen devices senden von Nachrichten durch die gleiche Verbraucher-und erhalten Antwort über den gleichen Hörer.
    • D ' Oh! Habe ich falsch verstanden, die Frage. Lassen Sie mich neu-schreiben Sie die Antwort.
    • Danke T. Rob. Sie machte es super klar! Können Sie mir bitte sagen, wenn für jede einzelne Anforderung von der mobilen, die ich ausführen, alle Schritte von SimpleRequestor.java (wie create connection factory, Verbindung, öffnen Sie die Warteschlange erstellen temp-Warteschlange, etc.). Oder sollte ich die Verbindung erstellen Fabrik -, Anschluss-und dest. Warteschlange nur einmal? Aber erstellen temp. (reply-to) queue für jede Anforderung? Auch temp. Warteschlange ist das etwas, was lokal erzeugt? Und nicht requre hosting-server, richtig?
    • Typischerweise ist die app öffnet eine Verbindung pro thread und Durchlaufen Sie die oben beschriebenen Schritte. Just bewusst sein, dass die Transaktionen beschränkt, die pro Verbindung, so bedeutet dies meist eine Verbindung pro thread. Wenn Sie mit einem externen Dienst, Sie werden Ihnen sagen, ob Sie die Unterstützung dynamischer Warteschlangen. Eine dynamische Warteschlange erstellt wird, auf dem QMgr Ihrer app verbunden ist. Es ist eigentlich ein bisschen ungewöhnlich für einen externen Dienst zu ermöglichen, client-verbindungen, anstatt dass Sie Ihren eigenen QMgr aber die Entscheidung ist bis zu Ihnen. Ein Fehler in WMQ unterstützt entweder Modell.
    InformationsquelleAutor T.Rob
  2. 2

    Den "Kunden" erstellen können eine temporäre queue, und übergeben Sie den Namen dieser in die Anfrage.

    Der "server" erhält eine Anfrage für eine bekannte Warteschlange, sendet aber die "replyTo" mit den Namen der Warteschlange sepecified durch die "client".

    JMS hat eine "replyTo" - Eigenschaft für diesen Zweck.

    Diese Weise der client sieht nur Nachrichten, die für ihn bestimmt.

    InformationsquelleAutor Peter Lawrey
  3. 0

    Auf der Spitze von meinem Kopf ich sehe 2 Möglichkeiten.

    1. erstellen 2 Warteschlangen: eingehende und ausgehende. Client sendet an eingehende Warteschlange und empfängt Nachrichten, die von der ausgehenden Warteschlange.

    2. können Sie verwenden die gleiche Warteschlange für beide. Nur spezielle Eigenschaft jeder Nachricht, und verwenden Selektor zum filtern von relevanten Nachrichten nur.

    dein server-Seite sollte senden Nachricht zuerst, und dann rufen Sie receive - Methode (siehe JMS-javadoc). Diese Methode blockiert, bis Sie bekommen die Nachricht oder timeout abgelaufen ist. Es ist für Sie wichtig, in dieser Art und Weise und nicht Nachrichten Abhören (Listener verwendet werden für async. Modus)

    InformationsquelleAutor AlexR
Schreibe einen Kommentar