Comment configurer le plug-in RabbitMQ Federation sur mon broker Amazon MQ ?

Brève description

Pour configurer le plugin RabbitMQ Federation sur un agent Amazon MQ pour RabbitMQ, vous devez configurer les éléments suivants sur l’agent en aval :

• Un ou plusieurs paramètres de federation-upstream qui définissent les connexions de fédération aux files d'attente ou aux échanges distants.
• Une politique RabbitMQ qui permet de fédérer des files d'attente ou des échanges distants spécifiques.
• Un échange avec une nouvelle file d'attente qui lui est liée pour recevoir des messages.

Solution

Remarque : la procédure suivante nécessite deux agents : un agent en amont (sur site ou dans le cloud) et un agent en aval (l’agent Amazon MQ pour RabbitMQ).

Créez un ou plusieurs paramètres federation-upstream qui définissent les connexions de fédération aux files d'attente ou aux échanges distants

1.    Lancez la console Amazon MQ.

2.    Dans le panneau de navigation de gauche, sélectionnez Agents.

3.    Dans la colonne Nom, choisissez le nom de votre agent en aval.

4.    Dans le panneau Connexions, sélectionnez l'URL répertoriée sous la console Web RabbitMQ. La page de connexion de la console Web RabbitMQ pour votre agent en aval s'ouvre.

5.    Entrez votre Nom d'utilisateur et votre Mot de passe pour votre agent. Ensuite, choisissez Ouvrir une session pour vous connecter à la console Web RabbitMQ.

6.    Dans la console Web RabbitMQ, choisissez l'onglet Administrateur. Ensuite, dans le panneau de navigation de droite, choisissez Federation Upstreams.

7.    Choisissez Ajouter un nouvel amont.

8.    Dans la zone Nom, saisissez un nom pour votre paramètre amont.

9.    Pour URI, supprimez le texte amqp:// par défaut et saisissez l'URI de l’agent en amont au format suivant :

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

10.    Choisissez Ajouter amont.

Créez une politique RabbitMQ qui permet de fédérer des files d'attente ou des échanges distants spécifiques

1.    Ouvrez la console Web RabbitMQ de l’agent en aval. Pour obtenir des instructions, reportez-vous aux étapes 1 à 5 de la section Pour créer un paramètre federation-upstream à l'aide de la console Web RabbitMQ de cet article.

2.    Choisissez l'onglet Administrateur. Ensuite, dans le panneau de navigation de droite, choisissez Politiques.

3.    Choisissez Ajouter/mettre à jour une politique.

4.    Pour Nom, saisissez un nom pour votre politique.

5.    Pour Modèle, saisissez une expression régulière qui correspond aux files d'attente ou aux noms d'échange que vous souhaitez autoriser à être fédérés.

6.    Pour Appliquer à, sélectionnez Échanges dans la liste déroulante.

Remarque : l'application de la politique aux Échanges permet de l'appliquer uniquement aux échanges de l’agent en aval.

7.    Pour Priorité, saisissez le chiffre 1.

Remarque : le paramètre Priorité est utilisé pour déterminer quelle politique doit être appliquée à un échange ou à une file d'attente si plusieurs politiques portent le même nom. Le fait de spécifier le paramètre Priorité sur 1 empêche les politiques Amazon MQ par défaut portant le même nom de remplacer la politique.

8.    Pour Définition, saisissez federation-upstream-set comme clé dans la première zone de texte, avant le signe =. Saisissez ensuite all comme valeur dans la deuxième zone de texte, à droite du signe =.

9.    Choisissez Ajouter/mettre à jour la politique.

Créer un échange avec une nouvelle file d'attente qui lui est liée pour recevoir des messages

1.    Ouvrez la console Web RabbitMQ de l’agent en aval. Pour obtenir des instructions, reportez-vous aux étapes 1 à 5 de la section Pour créer un paramètre federation-upstream à l'aide de la console Web RabbitMQ de cet article.

2.    Cliquez sur l'onglet Files d'attente.

3.    Sous Ajouter une nouvelle file d'attente, pour Nom, saisissez un nom pour la nouvelle file d'attente qui reçoit des messages.

4.    Choisissez Ajouter une file d'attente.

5.    Cliquez sur l'onglet Échanges.

6.    Sous Ajouter un nouvel échange, pour Nom, saisissez l'expression régulière qui correspond au nom d'échange que vous avez utilisé lors de la création de la politique RabbitMQ.

7.    Choisissez Ajouter un échange.

Remarque : RabbitMQ crée également un échange sur l’agent en amont qui porte automatiquement le même nom.

8.    Cliquez sur l'onglet Échanges.

9.    Sous Tous les échanges, choisissez le nom du nouvel échange que vous avez créé.

10.    Sous Liaisons, pour Ajouter une liaison à partir de cet échange, sélectionnez Mettre en file d'attente dans la liste déroulante. Entrez ensuite le nom de la file d'attente que vous avez créée.

11.    Pour Clé de routage, saisissez une valeur de votre choix. Les messages envoyés à l’échange sur l’agent en amont à l'aide de cette valeur sont également envoyés à la file d'attente liée à cet échange.

12.    Choisissez Liaison.

Pour tester la configuration

Envoyer un message de test à l'échange source de l’agent en amont

1.    Ouvrez la console Web RabbitMQ de l’agent en amont.

Remarque : pour plus d'informations sur la façon d'accéder à la console Web RabbitMQ, consultez Plugin de gestion dans la documentation RabbitMQ.

2.    Cliquez sur l'onglet Échanges. Sélectionnez ensuite le nom de l'échange source.

3.    Dans le panneau de navigation de gauche, choisissez Publier le message. La section Publier le message s'ouvre.

4.    Dans la zone de texte Clé de routage, saisissez la valeur de clé de routage que vous avez créée.

5.    Dans la zone de texte Charge utile, saisissez un message de test.

Remarque : vous pouvez laisser les zones de texte En-têtes et Propriétés vides.

6.    Cliquez sur le bouton Publier le message. Le message de test est envoyé à l'échange source. Si votre paramètre de fédération est correctement configuré, le message est également envoyé à la file d'attente de destination de l’agent en aval.

Vérifiez que le message de test est reçu par la file d'attente de destination de l'’agent en aval

1.    Ouvrez la console Web RabbitMQ de l’agent en aval.

2.    Cliquez sur l'onglet Files d'attente. Choisissez ensuite le nom de la file d'attente de destination.

3.    Dans le panneau de navigation de gauche, sélectionnez Recevoir les messages. La section Recevoir les messages s'ouvre.

4.    Cliquez sur le bouton Recevoir les messages. Si le paramètre de fédération est configuré correctement, le message de test que vous avez envoyé à l'échange source apparaît en tant que valeur de Charge utile.

---

Informations connexes

Comment configurer le plugin RabbitMQ Shovel sur mon agent Amazon MQ ?