Les files d'attente mettent les messages en tampon jusqu'à ce que les consommateurs les récupèrent. Créez, surveillez, associez et supprimez des files d'attente dans la console ApsaraMQ for RabbitMQ.
Prérequis
Assurez-vous de disposer des éléments suivants :
Une instance ApsaraMQ for RabbitMQ
Un vhost sur l'instance où vous souhaitez créer des files d'attente
(Facultatif) Pour les utilisateurs RAM : Accorder des autorisations (facultatif).
Créer une file d'attente
Connectez-vous à la console ApsaraMQ for RabbitMQ. Dans le volet de navigation de gauche, cliquez sur Instances.
Dans la barre de navigation supérieure, sélectionnez la région de votre instance, puis cliquez sur le nom de l'instance.
Dans le volet de navigation de gauche, cliquez sur Queues.
Sur la page Queues, cliquez sur Change à côté de vhost et sélectionnez le vhost sur lequel créer une file d'attente. Cliquez ensuite sur Create Queue.
-
Dans le panneau Create Queue, configurez les paramètres suivants et cliquez sur OK.
Parameter
Description
Queue Name
Le nom de la file d'attente. Règles de dénomination :
1. The queue name supports only letters, digits, hyphens (-), underscores (_), periods (.), pound signs (#), slashes (/), at signs (@), colons (:), commas (,), spaces ( ), and greater-than signs (>). Length: 1–255 characters.
2. After a queue is created, you cannot modify its name. If you want to modify its name, delete the queue and re-create it.
amq.est un préfixe réservé et ne peut pas être utilisé.
Auto Delete
Supprime la file d'attente après la désinscription du dernier consommateur. Yes : activé. No : désactivé.
Retry Policy
Paramètres de nouvelle tentative facultatifs.
Dead-letter Policy
Paramètres de lettres mortes facultatifs. Cliquez pour développer.
Politique de nouvelle tentative
|
Parameter |
Description |
|
Inherit Instance Configurations |
Indique s'il faut utiliser la politique de nouvelle tentative au niveau de l'instance. |
|
Maximum Number of Deliveries |
Nombre maximal de tentatives de distribution d'un message. |
|
Consumption Timeout Period |
Durée maximale accordée à un consommateur pour traiter un message. |
Politique de lettres mortes
|
Parameter |
Description |
|
DeadLetterExchange |
L'exchange qui reçoit les messages de lettres mortes. |
|
DeadLetterRoutingKey |
La clé de routage utilisée pour acheminer les messages de lettres mortes vers la file d'attente cible. |
|
MessageTTL |
Durée de vie en millisecondes. Les messages non consommés deviennent des lettres mortes après cette période et sont acheminés vers l'exchange de lettres mortes. Message TTL. |
FAQ
Q : Puis-je spécifier quel client consomme les messages ?
Non. ApsaraMQ for RabbitMQ ne permet pas de spécifier un client consommateur particulier. La distribution des messages suit les mécanismes standard de répartition tournante (round-robin) ou basée sur la priorité de RabbitMQ.
Q : Comment créer une file d'attente séquentielle (x-single-active-consumer) via le code ?
La console ApsaraMQ for RabbitMQ ne prend pas en charge la configuration du paramètre x-single-active-consumer. Pour créer une file d'attente séquentielle, utilisez le SDK. Appelez la méthode channel.queueDeclare et définissez "x-single-active-consumer": true dans le paramètre arguments.
Exemple :
Map<String, Object> arguments = new HashMap<>();
arguments.put("x-single-active-consumer", true);
channel.queueDeclare("my-queue", true, false, false, arguments);Nombre maximal de files d'attente
Si le quota de l'instance a atteint sa limite :
Pour les instances Enterprise, Professional et Platium Edition , cliquez sur Upgrade pour effectuer une mise à niveau.
Pour les instances (Shared) Pay-by-Messaging-Request, (Shared) Pay-by-Provisioned-Capacity-and-Elastic-Traffic, (Exclusive) Pay-by-Provisioned-Capacity-and-Elastic-Traffic, cliquez sur Change Quota pour ajuster la limite du nombre de files d'attente.
Pour connaître les limites selon les différentes instances, consultez Queues per instance sous Cluster limits dans Limits.
Consulter les statistiques des files d'attente
Les métriques varient selon l'édition de l'instance.
Sur la page Queues, recherchez la file d'attente cible et cliquez sur Details dans la colonne Actions.
-
Sur la page Queue Details, cliquez sur l'onglet Dashboard.
Instance edition
Monitoring source
Reference
Enterprise Edition, Enterprise Platinum Edition
Managed Service for Prometheus et Managed Service for Grafana
Standard Edition, Professional Edition
Cloud Monitor
L'édition Standard n'est plus disponible à l'achat. Les instances existantes peuvent toujours être utilisées.
Associer un exchange à une file d'attente
Sur la page Queues, recherchez la file d'attente cible et cliquez sur Details dans la colonne Actions.
Sur la page Queue Details, cliquez sur l'onglet Bound as Destination. Cliquez ensuite sur Add Binding.
Dans le panneau Add Binding, configurez Source Exchange et Routing Key, puis cliquez sur OK.
Pour les exchanges x-consistent-hash, la clé de routage spécifie le poids de la file d'attente (un entier compris entre 1 et 20).
Envoyer des messages à une file d'attente
Envoyez des messages à une file d'attente depuis un exchange associé.
Sur la page Queues, recherchez la file d'attente cible et cliquez sur Details dans la colonne Actions.
Sur la page Queue Details, cliquez sur l'onglet Bound as Destination.
Dans la liste des associations, recherchez l'association cible et cliquez sur Send Message dans la colonne Actions.
Dans le panneau Send Message, sélectionnez une option mandatory, saisissez un Message ID et un Message Body, puis cliquez sur OK.
Lors de l'envoi de messages à l'aide de l'exchange par défaut (avec un nom d'exchange vide), la clé de routage doit correspondre exactement au nom d'une file d'attente existante. Le compte client doit également disposer d'autorisations d'écriture sur la file d'attente cible. Si la file d'attente n'existe pas ou si les autorisations sont insuffisantes, les messages sont silencieusement ignorés sans qu'aucun enregistrement d'envoi n'apparaisse dans la console. Avant d'envoyer des messages, vérifiez que la file d'attente est correctement déclarée et que le compte client dispose des autorisations d'écriture requises.
Afficher les tags de consommateur
Un tag de consommateur identifie de manière unique un client consommateur. Le broker en génère automatiquement un si le client n'en spécifie pas. Utilisez le tag généré automatiquement plutôt qu'un tag personnalisé.
Chaque tag de consommateur doit être unique pour un seul client. Le SDK suit les consommateurs sur une connexion à l'aide d'un Map<String, Consumer> indexé par tag de consommateur. Si plusieurs consommateurs sur la même connexion partagent un tag, un seul reprendra après une reconnexion automatique. Les autres ne seront pas restaurés.
Pour afficher les tags de consommateur, le client consommateur doit être connecté au broker. Sur la page Queues, recherchez la file d'attente cible et cliquez sur Consumer Tags dans la colonne Actions.
Vider une file d'attente
Sur la page Queues, recherchez la file d'attente cible et choisissez More > Clear Messages dans la colonne Actions.
Supprimer des files d'attente
La suppression d'une file d'attente entraîne la suppression définitive de tous les messages non consommés. Cette action est irréversible.
-
Sur la page Queues, supprimez les files d'attente à l'aide de l'une des méthodes suivantes :
File d'attente unique : Recherchez la file d'attente et choisissez More > Delete dans la colonne Actions. Vous pouvez également cliquer sur le nom de la file d'attente ou sur Details, puis cliquer sur Delete dans le coin supérieur droit de la page Queue Details.
Plusieurs files d'attente : Sélectionnez les files d'attente et cliquez sur Batch Delete sous la liste des files d'attente.
Confirmez la suppression.