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

Kurzbeschreibung

Um das RabbitMQ-Federation-Plug-In auf einem Broker von Amazon MQ for RabbitMQ einzurichten, müssen Sie im Downstream-Broker Folgendes konfigurieren:

• Ein oder mehrere Verbund-Upstream-Parameter, die die Verbund-Verbindungen zu Remote-Warteschlangen oder -Austäusche definieren.
• Eine RabbitMQ-Richtlinie, mit der bestimmte Remote-Warteschlangen oder -Austäusche zusammengeführt werden können.
• Ein Austausch mit einer neuen Warteschlange, die daran gebunden ist, um Nachrichten zu empfangen.

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).

Erstellen Sie einen oder mehrere Verbund-Upstream-Parameter, die die Verbund-Verbindungen zu Remote-Warteschlangen oder -Austäuschen definieren

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 Federation Upstreams (Verbund-Upstreams).

7.    Wählen Sie Add a new upstream (Neuen Upstream hinzufügen).

8.    Geben Sie für Name einen Namen für Ihren Upstream-Parameter ein.

9.    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 Add upstream (Upstream hinzufügen).

Erstellen Sie eine RabbitMQ-Richtlinie, die den Verbund bestimmter Remote-Warteschlangen oder -Austäusche erlaubt.

1.    Öffnen Sie die RabbitMQ-Webkonsole des Downstream-Brokers. Anweisungen finden Sie in den Schritten 1–5 des Abschnitts Erstellen eines Verbund-Upstream-Parameters mithilfe der RabbitMQ-Webkonsole dieses Artikels.

2.    Wählen Sie die Registerkarte Admin. Wählen Sie dann im rechten Navigationsbereich Policies (Richtlinien).

3.    Wählen Sie Add / update a policy (Richtlinie hinzufügen/aktualisieren).

4.    Geben Sie unter Name einen Namen für Ihre Richtlinie ein.

5.    Geben Sie für Pattern (Muster) einen regulären Ausdruck ein, der den Warteschlangen- oder Austausch-Namen entspricht, die Sie zum Verbund zulassen möchten.

6.    Wählen Sie für Apply to (Übernehmen für) in der Dropdown-Liste Exchanges (Austäusche) aus.

Hinweis: Durch die Anwendung der Richtlinie auf Austäusche kann die Richtlinie nur auf einem Austausch im Downstream-Broker angewendet werden.

7.    Geben Sie für Priority (Priorität) die Ziffer 1 ein.

Hinweis: Die Einstellung Priority (Priorität) wird verwendet, um zu bestimmen, welche Richtlinie auf einen Austausch oder auf eine Warteschlange angewendet werden soll, wenn mehrere Richtlinien denselben Namen haben. Wenn Sie die Prioritätseinstellung als 1 angeben, wird verhindert, dass standardmäßige Amazon-MQ-Richtlinien mit demselben Namen die Richtlinie überschreiben.

8.    Geben Sie für Definition federation-upstream-set als Schlüssel in das erste Textfeld vor dem Zeichen = ein. Geben Sie dann all als Wert in das zweite Textfeld rechts neben dem Zeichen = ein.

9.    Wählen Sie Add / update policy (Richtlinie hinzufügen/aktualisieren).

Erstellen Sie einen Austausch mit einer neuen Warteschlange, die daran gebunden ist, um Nachrichten zu empfangen

1.    Öffnen Sie die RabbitMQ-Webkonsole des Downstream-Brokers. Anweisungen finden Sie in den Schritten 1–5 des Abschnitts Erstellen eines Verbund-Upstream-Parameters mithilfe der RabbitMQ-Webkonsole dieses Artikels.

2.    Wählen Sie die Registerkarte Queues (Warteschlangen).

3.    Geben Sie unter Ass a new queue (Neue Warteschlange hinzufügen) für Name einen Namen für die neue Warteschlange ein, die Nachrichten empfängt.

4.    Wählen Sie Add queue (Warteschlange hinzufügen).

5.    Wählen Sie die Registerkarte Exchanges (Austäusche).

6.    Geben unter Add a new exchange (Neuen Austausch hinzufügen) für Name den regulären Ausdruck ein, der dem Austausch-Namen entspricht, den Sie beim Erstellen der RabbitMQ-Richtlinie verwendet haben.

7.    Wählen Sie Add exchange (Austausch hinzufügen).

Hinweis: RabbitMQ erstellt auch einen Austausch auf dem Upstream-Broker, der automatisch denselben Namen hat.

8.    Wählen Sie die Registerkarte Exchanges (Austäusche).

9.    Wählen Sie unter All exchanges (Alle Austäusche) den Namen des neuen Austauschs aus, den Sie erstellt haben.

10.    Wählen Sie unter Bindings (Bindungen) für Add binding from this exchange (Bindung aus diesem Austausch hinzufügen) die Option To queue (Zur Warteschlange) aus der Dropdown-Liste. Geben Sie dann den Namen der Warteschlange ein, die Sie erstellt haben.

11.    Geben Sie für Routing key (Routing-Schlüssel) einen Wert Ihrer Wahl ein. Die Nachrichten, die mit diesem Wert an den Austausch auf dem Upstream-Broker gesendet werden, werden auch an die an diesem Austausch gebundene Warteschlange gesendet.

12.    Wählen Sie Bind (Bindung).

Testen der Einrichtung

Senden Sie eine Testnachricht an den Quellaustausch 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 Exchanges (Austäusche). Wählen Sie dann den Namen des Quellaustauschs 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 Routing key (Routing-Schlüssel) den Wert des Routing-Schlüssels ein, den Sie erstellt haben.

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

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

6.    Wählen Sie die Schaltfläche Publish message (Nachricht veröffentlichen). Die Testnachricht wird an den Quellaustausch gesendet. Wenn Ihr Verbund-Parameter richtig konfiguriert ist, wird die Nachricht auch 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.

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 Verbundparameter richtig konfiguriert ist, wird die Testnachricht, die Sie an den Quellaustausch gesendet haben, als Nutzlastwert angezeigt.

---

Ähnliche Informationen

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