Simple Message Queue (formerly MNS):Message ordonné

Définition de la fonctionnalité

Simple Message Queue (anciennement MNS) assure un traitement premier entré, premier sorti (FIFO) pour les messages appartenant au même groupe, garantissant ainsi une gestion séquentielle dans les scénarios métier.

Scénarios

Les messages ordonnés sont idéaux pour les scénarios métier exigeant un ordre strict des messages :

• Transitions d'état des commandes

  Dans les systèmes de commande e-commerce, les états tels que création de la commande → paiement → expédition → confirmation de livraison doivent être traités dans l'ordre chronologique afin de maintenir la cohérence de l'état métier.

• Traitement des transactions financières

  Dans les systèmes de trading boursier ou d'actions, les ordres présentant des prix d'achat identiques doivent être traités strictement selon l'ordre de leur soumission. Les systèmes en aval doivent gérer ces ordres conformément à leur séquence de soumission.

• Synchronisation de base de données

  Les bases de données en amont effectuent des opérations d'insertion, de suppression ou de mise à jour. Les journaux binaires sont transmis sous forme de messages aux systèmes en aval, qui les rejouent pour actualiser les données d'état de manière séquentielle et éviter toute incohérence des données.

• Enregistrement des journaux métier

  Les journaux des opérations métier critiques doivent être stockés strictement dans l'ordre chronologique pour faciliter l'audit et le dépannage.

Concepts clés

• MessageGroupId : Identifiant de groupe de messages. Le système garantit l'ordre des messages au sein de chaque groupe : les messages partageant le même MessageGroupId sont traités strictement dans l'ordre, tandis que les messages provenant de groupes différents peuvent être traités en parallèle.

• Délai de visibilité : Une fois extrait avec succès, un message reste invisible pour les autres consommateurs jusqu'à l'expiration du délai. Cela empêche plusieurs consommateurs de traiter simultanément le même message. Si le message n'est pas confirmé comme supprimé avant l'expiration du délai, il redevient visible.

• Mécanisme de verrouillage de groupe : Dans une file d'attente ordonnée, dès qu'un message avec un MessageGroupId spécifique est extrait mais non confirmé comme supprimé (c'est-à-dire qu'il reste invisible), tous les messages suivants du même MessageGroupId sont bloqués. Cela garantit un ordre de consommation strict. Ce n'est qu'après la confirmation de la suppression du message actuel ou l'expiration de son délai de visibilité que le message suivant du même groupe peut être extrait.

Différences par rapport aux messages standards

• Sémantique d'ordonnancement :

  • Messages standards (file d'attente/sujet standard) : Livraison au moins une fois selon la meilleure effort, sans garantie d'ordre.

  • Messages ordonnés (file d'attente/sujet FIFO) : Au sein du même MessageGroupId, les messages sont consommés strictement dans l'ordre de leur arrivée sur le serveur. Les messages antérieurs doivent être entièrement traités avant que les suivants ne puissent être consommés.

• Modèle de concurrence :

  • Messages standards : Aucune restriction de regroupement ; optimisé pour le débit global.

  • Messages ordonnés : Utilisent le MessageGroupId comme unité de concurrence — série au sein d'un groupe, parallèle entre les groupes.

• Exigences relatives aux messages :

  • L'envoi d'un message ordonné nécessite la spécification d'un MessageGroupId (s'applique aux files d'attente et aux sujets).

Prise en main

Utilisation de l'API

Limites

• Les régions prises en charge incluent Chine (Shenzhen), Chine (Shanghai) et Chine (Hangzhou). Pour demander la prise en charge FIFO dans d'autres régions, soumettez un ticket.

• ID de groupe requis : L'envoi de messages à une file d'attente ou un sujet FIFO nécessite un MessageGroupId.

• Compatibilité des types :

  • Files d'attente de lettres mortes (DLQ) : Seules les files d'attente du même type peuvent être liées. Les messages FIFO ne peuvent être liés qu'à des files d'attente de lettres mortes FIFO, et les messages standards ne peuvent être liés qu'à des files d'attente de lettres mortes standards.

  • Abonnements : Les sujets standards ne peuvent s'abonner qu'à des files d'attente standards. Pour une livraison ordonnée, abonnez les sujets FIFO aux files d'attente FIFO.

• Consultation non prise en charge : Les files d'attente FIFO ne prennent pas en charge l'interface de consultation des messages (PeekMessage).

Bonnes pratiques

• Conception des groupes :

  • Utilisez des valeurs MessageGroupId stables et uniformément réparties (telles que des ID de commande) pour éviter que quelques groupes à forte activité ne deviennent des goulots d'étranglement en termes de performances.

  • Pour les charges de travail extrêmement sollicitées, subdivisez les groupes au niveau de l'application afin d'augmenter la concurrence.

• Délai de visibilité : Définissez ce paramètre en fonction de la durée réelle de traitement pour garantir que votre application termine le traitement et confirme le message avant l'expiration du délai, réduisant ainsi les livraisons en double.

• Idempotence et nouvelles tentatives : Implémentez un traitement idempotent et une logique de nouvelle tentative dans les consommateurs pour assurer la cohérence de bout en bout.

• Réception par lot : Augmentez la valeur de numOfMessages pour améliorer le débit, tant que le délai de traitement par message reste acceptable.

FAQ