Wie richte ich das RabbitMQ-Shovel-Plug-In auf meinem Amazon-MQ-Broker ein?

Letzte Aktualisierung: 19.04.2022

Ich möchte Nachrichten mithilfe des RabbitMQ-Shovel-Plugins von einem On-Premises-Broker zu einem Amazon-MQ-for-RabbitMQ-Broker verschieben. Wie richte ich meinen Broker von Amazon MQ for RabbitMQ ein, damit er mit dem RabbitMQ-Shovel-Plug-In funktioniert?

Kurzbeschreibung

Um das RabbitMQ-Shovel-Plug-In auf einem Broker von Amazon MQ for RabbitMQ zu konfigurieren, müssen Sie eine dynamische Shovel erstellen.

Um eine dynamische Shovel für einen Broker von Amazon MQ for RabbitMQ zu erstellen, können Sie eine der folgenden Optionen verwenden:

Auflösung

Hinweis: Für das folgende Verfahren sind zwei Broker erforderlich: Ein Upstream-Broker (On-Premises oder Cloud-basiert) und ein Downstream-Broker (der Amazon-MQ-for-RabbitMQ-Broker). Sie können eine dynamische Shovel entweder auf einem Downstream- oder Upstream-Broker konfigurieren. Dieses Beispielverfahren zeigt, wie eine dynamische Shovel auf einem Downstream-Broker erstellt wird.

So erstellen Sie mithilfe der RabbitMQ-Webkonsole eine dynamische Shovel auf einem Downstream-Broker

Wichtig: Stellen Sie sicher, dass Sie den Uniform Resource Identifier (URI) für Warteschlangen angeben, die nicht in dem Broker vorhanden sind, in dem die Shovel erstellt wird.

1.    Öffnen Sie die Amazon-MQ-Konsole.

2.    Wählen Sie im linken Navigationsbereich Brokers aus.

3.    Wählen Sie in der Spalte Name den Namen Ihres Downstream-Brokers aus.

4.    Wählen Sie im Bereich Connections (Verbindungen) die URL aus, die unter der RabbitMQ-Webkonsole aufgeführt ist. Die Anmeldeseite der RabbitMQ-Webkonsole für Ihren Downstream-Broker wird geöffnet.

5.    Geben Sie Ihren Benutzernamen und Ihr Passwort für Ihren Broker ein. Wählen Sie dann Login (Anmelden), um sich bei der RabbitMQ-Webkonsole anzumelden.

6.    Wählen Sie in der RabbitMQ-Webkonsole die Registerkarte Admin. Wählen Sie dann im rechten Navigationsbereich die Option Shovel Management (Shovel-Verwaltung).

7.    Wählen Sie Add a new shovel (Neue Shovel hinzufügen).

8.    Geben Sie unter Name einen Namen für Ihre Shovel ein.

9.    Wählen Sie für Source (Quelle) AMQP 0.9.1 aus der Dropdown-Liste aus. Führen Sie danach folgende Aktionen aus:
Wählen Sie in der Dropdown-Liste rechts von URI die Option Warteschlange.
Geben Sie in das Textfeld unter Queue (Warteschlange) den Namen der Quell-Warteschlange des Upstream-Brokers ein.
Löschen Sie für URI den standardmäßigen amqp://-Text und geben Sie den URI des Upstream-Brokers im folgenden Format ein:

amqps://$UPSTREAM_BROKER_USER:$UPSTREAM_BROKER_PASSWORD@$UPSTREAM_BROKER_ENDPOINT:5671

10.    Wählen Sie für Destination (Ziel) AMQP 0.9.1 aus der Dropdown-Liste aus. Führen Sie danach folgende Aktionen aus:
Wählen Sie in der Dropdown-Liste rechts von URI die Option Warteschlange.
Geben Sie in das Textfeld unter Queue (Warteschlange) den Namen der Ziel-Warteschlange des Downstream-Brokers ein.
Behalten Sie für URI den standardmäßigen amqp://-Text bei und geben Sie die URI des Downstream-Brokers im folgenden Format ein:

amqp://$DOWNSTREAM_BROKER_USER:$DOWNSTREAM_BROKER_PASSWORD@$DOWNSTREAM_BROKER_ENDPOINT:5671

11.    Wählen Sie Add shovel (Shovel hinzufügen).

Hinweis: Wenn die Quell- und Ziel-Warteschlangen noch nicht existieren, erstellt RabbitMQ sie automatisch.

So erstellen Sie eine dynamische Shovel auf einem Downstream-Broker mithilfe des RabbitMQ-Verwaltungs-Befehlszeilentools

Wichtig: Stellen Sie sicher, dass Sie den Uniform Resource Identifier (URI) für Warteschlangen angeben, die nicht in dem Broker vorhanden sind, in dem die Shovel erstellt wird.

Führen Sie den folgenden Curl-Befehl aus:

curl -u $SHOVEL_BROKER_USER:$SHOVEL_BROKER_PASSWORD \
-X PUT https://$SHOVEL_BROKER_ENDPOINT/api/parameters/shovel/%2f/rmq-lab-shovel \
-H "content-type: application/json" \
-d '{"value": {"src-protocol": "amqp091","src-uri": "amqps://$UPSTREAM_BROKER_USER:$UPSTREAM_BROKER_PASSWORD@$UPSTREAM_BROKER_ENDPOINT:5671","src-queue": "shovel-demo-src-queue","dest-protocol": "amqp091","dest-uri": "amqps://$DOWNSTREAM_BROKER_USER:$DOWNSTREAM_BROKER_PASSWORD@$DOWNSTREAM_BROKER_ENDPOINT:5671","dest-queue": "shovel-demo-dest-queue"}}'

Wichtig: Ersetzen Sie $SHOVEL_BROKER_USER und $SHOVEL_BROKER_PASSWORD durch die Anmeldeinformationen des Downstream-Brokers. Ersetzen Sie $SHOVEL_BROKER_ENDPOINT durch den Endpunkt des Downstream-Brokers. Ersetzen Sie $UPSTREAM_BROKER_USER und $UPSTREAM_BROKER_PASSWORD durch die Anmeldeinformationen des Upstream-Brokers. Ersetzen Sie $UPSTREAM_BROKER_ENDPOINT durch den Endpunkt des Upstream-Brokers. Ersetzen Sie $DOWNTREAM_BROKER_USER und $DOWNTREAM_BROKER_PASSWORD durch die Anmeldeinformationen des Downstream-Brokers. Ersetzen Sie $DOWNTREAM_BROKER_ENDPOINT durch den Endpunkt des Downstream-Brokers. Ersetzen Sie $SOURCE_QUEUE_NAME durch den Namen der Quell-Warteschlange im Upstream-Broker. Ersetzen Sie $DESTINATION_QUEUE_NAME durch den Namen der Zielwarteschlange im Downstream-Broker.

Testen der Einrichtung

Eine Testnachricht an die Quell-Warteschlange des Upstream-Brokers

1.    Öffnen Sie die RabbitMQ-Webkonsole des Upstream-Brokers.

Hinweis: Weitere Informationen zum Zugriff auf die RabbitMQ-Webkonsole finden Sie unter Verwaltungs-Plug-In in der RabbitMQ-Dokumentation.

2.    Wählen Sie die Registerkarte Queues (Warteschlangen). Wählen Sie dann den Namen der Quell-Warteschlange aus.

3.    Wählen Sie im linken Navigationsbereich Publish message (Nachricht veröffentlichen). Der Abschnitt Publish message (Nachricht veröffentlichen) wird geöffnet.

4.    Geben Sie im Textfeld Payload (Nutzlast) eine Testnachricht ein.

Hinweis: Sie können die Textfelder Headers (Kopfzeilen) und Properties (Eigenschaften) leer lassen.

5.    Wählen Sie die Schaltfläche Publish message (Nachricht veröffentlichen). Die Testnachricht wird an die Quell-Warteschlange gesendet. Wenn Ihre dynamische Shovel richtig konfiguriert ist, wird die Nachricht auch von der Shovel verbraucht und an die Ziel-Warteschlange des Downstream-Brokers gesendet.

Stellen Sie sicher, dass die Testnachricht in der Ziel-Warteschlange des Downstream-Brokers eingeht.

1.    Öffnen Sie die RabbitMQ-Webkonsole des Downstream-Brokers. Anweisungen finden Sie in den Schritten 1–5 des Abschnitts So erstellen Sie eine dynamische Shovel auf einem Downstream-Broker mithilfe der RabbitMQ-Webkonsole dieses Artikels.

2.    Wählen Sie die Registerkarte Queues (Warteschlangen). Wählen Sie dann den Namen der Ziel-Warteschlange.

3.    Wählen Sie im linken Navigationsbereich Get messages (Nachrichten abrufen) aus. Der Abschnitt Get messages (Nachrichten abrufen) wird geöffnet.

4.    Wählen Sie die Schaltfläche Get messages (Nachrichten abrufen). Wenn der dynamische Shovel korrekt konfiguriert ist, wird die Testnachricht, die Sie an die Quell-Warteschlange gesendet haben, als Nutzlastwert angezeigt.


War dieser Artikel hilfreich?


Benötigen Sie Hilfe zur Fakturierung oder technischen Support?