Présentation des files d’attente de messages
Le framework Message Queue (MQF) est un système qui permet à un module de publier des messages dans des files d’attente. Elle définit également les consommateurs qui recevront les messages de manière asynchrone. Le MQF utilise RabbitMQ comme courtier de messagerie, qui fournit une plateforme évolutive pour envoyer et recevoir des messages. Il comprend également un mécanisme de stockage des messages non diffusés. RabbitMQ est basé sur la spécification AMQP (Advanced Message Queuing Protocol) 0.9.1.
Le diagramme suivant illustre la structure de Message Queue :
-
Un éditeur est un composant qui envoie des messages à un échange. Il sait vers quel échange publier et le format des messages qu'il envoie.
-
Un central reçoit les messages des éditeurs et les envoie vers les files d'attente. Bien que RabbitMQ prenne en charge plusieurs types d’échanges, Commerce utilise uniquement les échanges de sujets. Une rubrique comprend une clé de routage, qui contient des chaînes de texte séparées par des points. Le format d’un nom de rubrique est
string1.string2: par exemple,customer.createdoucustomer.sent.email.Le courtier vous permet d’utiliser des caractères génériques lors de la définition de règles pour le transfert de messages. Vous pouvez utiliser un astérisque (
*) pour remplacer une chaîne ou un signe dièse (#) pour remplacer 0 ou plusieurs chaînes. Par exemple,customer.*filtrez surcustomer.createetcustomer.delete, mais pas surcustomer.sent.email. Toutefois,customer.#filtrez surcustomer.create,customer.deleteetcustomer.sent.email. -
Une file d'attente est une mémoire tampon qui stocke les messages.
-
Un client reçoit des messages. Il sait quelle file d’attente utiliser. Il peut mapper les processeurs du message à une file d’attente spécifique.
Un système de file d’attente de messages de base peut également être configuré sans utiliser RabbitMQ. Dans ce système, un adaptateur MySQL stocke les messages dans la base de données. Trois tables de base de données (queue, queue_message et queue_message_status) gèrent la charge de travail de la file d'attente des messages. Les tâches cron permettent aux consommateurs de recevoir des messages. Cette solution n'est pas très évolutive. RabbitMQ doit être utilisé chaque fois que possible.