Découvrez les concepts clés utilisés dans ApsaraMQ for RabbitMQ. Si vous débutez avec la messagerie asynchrone, commencez par l'aperçu du flux de messages pour comprendre l'interaction entre les différents composants. Utilisez la référence alphabétique pour rechercher des termes spécifiques.
Aperçu du flux de messages
Un message traverse quatre étapes, du producteur au consommateur :
Un producteur publie un message vers un exchange en utilisant une clé de routage.
L'exchange évalue ses bindings (règles associant les clés de routage aux files d'attente) et achemine le message vers une ou plusieurs queues.
Le message reste dans la file d'attente jusqu'à ce qu'un consommateur le récupère.
Le consommateur traite le message et envoie un accusé de réception au broker.
Ces composants résident au sein d'un vhost, qui assure une isolation logique. Plusieurs vhosts s'exécutent sur une seule instance, c'est-à-dire la ressource gérée ApsaraMQ for RabbitMQ que vous provisionnez sur Alibaba Cloud.
Producer --> Exchange --> Binding --> Queue --> Consumer
| |
| (routing key | (acknowledgment)
| + exchange type |
| determine routing) |
| |
+---------+ +-------------+
| vhost | | channel |
+----+----+ +------+------+
| |
+----+----+ +------+------+
|instance | | connection |
+---------+ | (TCP) |
+-------------+Référence alphabétique
A
Alternate exchange
Exchange de secours. Lorsqu'aucun binding ne correspond à la clé de routage, l'exchange ne peut pas acheminer le message vers une queue. Il transfère alors le message vers son alternate exchange (AE) configuré.
Arguments
Paramètres de configuration au niveau de la queue. Utilisez les arguments pour définir des propriétés telles que la durée de vie du message (TTL), l'exchange de lettres mortes et la clé de routage des lettres mortes.
Auto delete
Attribut des exchanges et des queues qui contrôle le nettoyage automatique :
Exchange : suppression automatique une fois que toutes les queues se sont désassociées (unbind).
Queue : suppression automatique une fois que tous les consommateurs se sont désabonnés.
B
Binding
Règle de routage liant un exchange à une queue. L'exchange utilise les bindings pour déterminer quelles queues recevront un message donné. Chaque binding inclut généralement une clé de binding ou un motif que l'exchange compare à la clé de routage du message.
C
Channel
Connexion virtuelle légère qui fonctionne en multiplexage sur une seule connexion TCP. Établir une nouvelle connexion TCP pour chaque opération étant coûteux, AMQP utilise des channels pour partager une même connexion entre plusieurs tâches simultanées. Un modèle courant consiste à ouvrir un channel par thread.
Pour plus d'informations, consultez Connections and channels.
Connection
Connexion TCP physique entre un client (producteur ou consommateur) et le broker ApsaraMQ for RabbitMQ. Une seule connexion peut transporter plusieurs channels.
Pour plus d'informations, consultez Connections and channels.
Consumer
Application qui s'abonne à une queue pour recevoir et traiter les messages.
D
Dead-letter exchange
Exchange qui achemine les messages de lettres mortes vers une dead-letter queue. Tout type d'exchange standard (direct, fanout, topic ou headers) peut servir de dead-letter exchange. Le routage repose sur la clé de routage des lettres mortes et les en-têtes du message.
Pour plus d'informations, consultez Dead-letter exchanges.
Dead-letter message
Message que le broker transfère vers un dead-letter exchange. Un message devient une lettre morte dans l'une des situations suivantes :
Le consommateur rejette le message avec
basic.rejectoubasic.nacket le paramètrerequeueest défini surfalse.La consommation du message échoue après 16 tentatives de redistribution. Pour plus d'informations, consultez Retry policies.
Le message dépasse sa durée de vie (TTL) dans la queue. Pour plus d'informations, consultez Message TTL.
Dead-letter queue
Queue liée à un dead-letter exchange. Les dead-letter queues stockent les messages de lettres mortes pour inspection ou retraitement ultérieur.
Dead-letter routing key
Clé de routage utilisée pour acheminer un message de lettre morte du dead-letter exchange vers la dead-letter queue. Si aucune clé de routage de lettre morte n'est définie, la clé de routage d'origine du message est utilisée.
Delayed message
Message que le broker conserve pendant un délai spécifié avant de le livrer aux consommateurs. Les messages différés sont utiles pour le traitement planifié, par exemple l'envoi d'un rappel 30 minutes après la passation d'une commande.
Pour plus d'informations, consultez Delayed messages.
Durability
Propriété des queues, des exchanges et des bindings. Les entités durables survivent aux redémarrages du broker ; les entités non durables sont supprimées lors du redémarrage du broker.
E
Exchange
Couche de routage située entre les producteurs et les queues. Un producteur publie un message vers un exchange, qui l'achemine vers une ou plusieurs queues en fonction du type d'exchange, des bindings et de la clé de routage.
Pour plus d'informations, consultez Exchanges.
I
Instance
Ressource gérée ApsaraMQ for RabbitMQ sur Alibaba Cloud. Une instance est une entité indépendante contenant des vhosts, des exchanges, des queues et d'autres ressources.
Instance throttling
Limitation de débit qui s'active lorsque le pic de transactions par seconde (TPS) d'une instance dépasse le seuil TPS configuré lors de l'achat. Lorsque la limitation est déclenchée :
Le broker renvoie un code d'erreur et un message d'erreur.
Le broker ferme le channel utilisé par la requête actuelle. Détectez cette exception dans votre code et rouvrez le channel.
Pour plus d'informations, consultez Best practices for instance throttling.
Internal
Attribut d'un exchange. Un exchange interne ne peut pas recevoir de messages directement des producteurs ; il ne reçoit des messages que d'autres exchanges via des bindings exchange-to-exchange.
M
Message ID
Attribut de type chaîne courte facultatif servant d'identifiant unique pour un message. Les IDs de message facilitent le suivi et la déduplication des messages dans des cas d'utilisation tels que le suivi de commandes ou le traitement de tickets.
Les brokers ApsaraMQ for RabbitMQ ne garantissent pas l'idempotence des messages. Pour assurer un traitement idempotent, attribuez un identifiant unique à chaque message et implémentez une logique de déduplication dans votre consommateur.
Pour plus d'informations, consultez Implementing idempotence.
Message TTL
Durée maximale pendant laquelle un message peut rester dans une queue avant d'expirer, spécifiée sous forme d'entier non négatif en millisecondes. Par exemple, un TTL de 1 000 signifie que le message expire après 1 seconde dans la queue. Les messages expirés sont soit supprimés, soit acheminés vers un dead-letter exchange si celui-ci est configuré.
Pour plus d'informations, consultez Message TTL.
P
Producer
Application qui crée et publie des messages vers un exchange.
Q
Queue
Tampon stockant les messages jusqu'à ce que les consommateurs les récupèrent. Chaque message peut être acheminé vers une ou plusieurs queues.
R
Routing key
Chaîne que le producteur associe à chaque message. L'exchange utilise la clé de routage — conjointement avec son type et ses bindings — pour déterminer quelles queues recevront le message. Le comportement de correspondance exact dépend du type d'exchange.
V
Vhost
Hôte virtuel assurant l'isolation logique des ressources au sein d'une instance. Chaque vhost possède son propre ensemble d'exchanges, de queues et de bindings, de sorte que les applications hébergées sur différents vhosts n'interfèrent pas entre elles.
Une instance peut contenir plusieurs vhosts, et chaque vhost peut contenir plusieurs exchanges et queues. Spécifiez un vhost lors de la connexion d'un producteur ou d'un consommateur à ApsaraMQ for RabbitMQ.