ApsaraMQ for RocketMQ est un middleware de messagerie professionnel, produit phare de l'architecture Internet de niveau entreprise. Il prend en charge la communication asynchrone fiable par messages entre microservices, systèmes distribués et applications serverless. Ce service vous permet de créer facilement un système distribué évolutif, faiblement couplé et hautement disponible.
ApsaraMQ for RocketMQ est intégré à l'infrastructure d'Alibaba Group depuis plus de 11 ans et a servi l'événement commercial 11.11 d'Alibaba pendant neuf ans. Ce service offre une faible latence, une haute simultanéité, une haute disponibilité, une haute fiabilité ainsi qu'une puissante capacité d'accumulation de messages, et prend en charge des flux de données de l'ordre du billion. Vous pouvez utiliser MQ pour transmettre librement des données entre les composants applicatifs, quelle que soit l'échelle.
Avantages

-
Hautes performances et faible latence
Message Queue prend en charge jusqu'à 10 millions de requêtes par seconde (QPS) et un flux de messages de l'ordre du billion, sans limites de simultanéité ni de performances.

-
Haute fiabilité
Message Queue prend en charge l'écriture synchrone en double, la redondance des données en triple copie sur plusieurs serveurs et la technologie de basculement rapide des copies, garantissant une fiabilité des données allant jusqu'à 99,99999999 %.

-
Haute évolutivité
Message Queue prend en charge des files d'attente pouvant contenir des dizaines de milliers de messages. Le nombre de files d'attente s'adapte de manière élastique et la taille du cluster évolue automatiquement. Ce processus est entièrement transparent pour les utilisateurs.

-
Contrôle des autorisations
Message Queue contrôle les autorisations d'envoi et de réception de chaque message par topic et par ID du consommateur, garantissant ainsi la sécurité des messages.
Fonctionnalités
-
Hautes performances et faible latence
ApsaraMQ for RocketMQ garantit de hautes performances même en cas d'accumulation massive de messages, sans affecter le service du cluster. Cela s'avère particulièrement important lors de l'écrêtement de charge.
Fort de plusieurs années d'expérience au service de l'événement e-commerce annuel 11.11 d'Alibaba, l'équipe technique d'Alibaba Cloud a développé des méthodes pour résoudre les problèmes de gigue des temps de réponse causés par la surcharge système liée à une haute simultanéité. Parmi les mille milliards de messages envoyés lors de l'événement 11.11 de 2017, la latence enregistrée de 99,6 % des requêtes d'écriture de messages était inférieure à 1 ms, et inférieure à 10 ms pour 99,996 % des requêtes.
Le message est envoyé dès son arrivée sur le serveur, garantissant une distribution rapide.
-
Haute disponibilité, fiabilité et évolutivité
ApsaraMQ for RocketMQ fournit des services cloud de messagerie à haute disponibilité dans plusieurs régions à travers le monde. Les salles serveurs et les équipements matériels sont construits selon les normes élevées de l'IDC d'Alibaba. Chaque région dispose de plusieurs salles serveurs. Message Queue continue de distribuer efficacement les messages aux applications, même en cas de panne complète d'un serveur.
ApsaraMQ for RocketMQ prend en charge les solutions de déploiement multi-actif intra-ville dans plusieurs régions financières, notamment Chine orientale 1 (Hangzhou), Chine orientale 2 (Shanghai), Chine méridionale 1 (Shenzhen) et d'autres régions, afin de protéger les systèmes de transactions financières critiques.
-
Contrôle d'accès sécurisé
ApsaraMQ for RocketMQ prend en charge la création de comptes principaux et de sous-comptes, les fonctionnalités de liste noire et de liste blanche, ainsi que les fonctions STS de RAM d'Alibaba Cloud.
ApsaraMQ for RocketMQ prend en charge l'autorisation intercomptes ainsi que l'autorisation via les comptes principaux et les sous-comptes.
Les messages ordonnés sont consommés dans l'ordre d'émission (premier entré, premier sorti). Message Queue prend en charge l'ordre global et l'ordre segmenté des messages.
-
Modèle de sujet (Topic)
ApsaraMQ for RocketMQ prend en charge le mode Pub/Sub. Dans ce mode, le producteur envoie le message vers le topic spécifié. Un ou plusieurs consommateurs peuvent s'abonner au message.
ApsaraMQ for RocketMQ prend en charge la consommation en mode cluster et la consommation en mode diffusion. Les abonnés utilisant le même ID du consommateur appartiennent au même cluster. En mode cluster, chaque message ne doit être traité que par l'un des abonnés du cluster. En mode diffusion, chaque message est transmis à tous les abonnés du cluster, garantissant que chaque abonné le consomme au moins une fois.
-
Types de messages diversifiés
Le message standard est utilisé pour le découplage asynchrone entre systèmes, l'écrêtement de charge, la journalisation, la synchronisation de cache à grande échelle entre serveurs, ainsi que le calcul et l'analyse en temps réel.
Les messages ordonnés sont publiés et consommés dans l'ordre. Ils se divisent en messages ordonnés globalement et en messages ordonnés par partition.
ApsaraMQ for RocketMQ fournit une fonction de transaction distribuée basée sur le standard X/Open XA afin de garantir la cohérence des transactions.
Après l'envoi d'un message au serveur Message Queue, celui-ci transmet le message à l'heure planifiée spécifiée (par exemple, le 1er janvier 2016 à 15:00:00) à compter de l'heure d'envoi (l'heure actuelle).
Après l'envoi d'un message au serveur Message Queue, celui-ci transmet le message au moment différé spécifié (par exemple, 30 minutes plus tard) à compter de l'heure d'envoi (l'heure actuelle).
-
Outils de maintenance systématiques
ApsaraMQ for RocketMQ fournit un ensemble complet d'outils de maintenance pour vous aider à détecter et traiter rapidement les problèmes système.
Interrogez les messages par topic, ID de message ou clé de message sur le serveur Message Queue.
ApsaraMQ for RocketMQ enregistre l'intégralité des données relatives au processus complet, y compris le flux de messages depuis le producteur vers le serveur Message Queue puis vers l'utilisateur final. Il agrège et analyse ces données pour construire un traçage visuel de messages de bout en bout.
ApsaraMQ for RocketMQ permet de rejouer les messages consommés à un moment précis, constituant ainsi un puissant outil de dépannage.
Vous pouvez définir des règles de surveillance et d'alerte pour chaque ID client en fonction du délai de consommation et du volume d'accumulation de messages, afin de détecter rapidement les problèmes.
ApsaraMQ for RocketMQ fournit un ensemble complet d'API ouvertes HTTP RESTful de type contrôle, permettant de mettre en œuvre une série de fonctions de gestion des ressources et de maintenance, tout en facilitant l'accès.
Scénarios clients
-
Découplage
-
Écrêtement de charge
-
Transactions distribuées
-
Calcul en temps réel
-
Synchronisation de cache
-
Messagerie instantanée
Découplage
Le couplage faible entre systèmes contribue à améliorer l'évolutivité et la fiabilité, et constitue la meilleure approche de conception pour les applications modernes. Grâce à Message Queue, vous pouvez envoyer, stocker et recevoir des messages entre n'importe quel nombre de composants de services applicatifs (systèmes), sans aucune perte de message. Cela simplifie l'exploitation des composants de services applicatifs cloud (systèmes) et offre un meilleur rapport coût-efficacité.
Écrêtement de charge
Lors d'événements à grande échelle, tels que le pic de transactions à minuit pendant le festival e-commerce Tmall 11-11 d'Alibaba, la distribution d'enveloppes rouges en ligne lors du Gala du Nouvel An chinois et d'autres événements majeurs en ligne, un grand nombre de requêtes peuvent échouer lorsque le volume de requêtes externes dépasse la capacité de traitement du système. Sans mesures de protection appropriées, l'accumulation excessive de requêtes entraîne une expiration des délais et le système ne peut pas se restaurer automatiquement. Le système s'effondre alors et sa capacité de service devient nulle pour les services externes, ce qui a un impact négatif considérable sur l'expérience utilisateur.
Transactions distribuées
Dans le mode de traitement transactionnel conventionnel, les processus métier entre plusieurs systèmes ou composants applicatifs sont couplés au sein d'une transaction volumineuse, ce qui entraîne des temps de réponse élevés et des chaînes métier allongées, affectant ainsi la disponibilité du système. Grâce aux messages de transaction distribuée de Message Queue, vous pouvez séparer les activités critiques nécessitant un traitement synchrone des activités secondaires pouvant être traitées de manière asynchrone, et ainsi fragmenter une transaction volumineuse en transactions plus légères pour réduire les interactions entre systèmes.
Vous garantissez ainsi la cohérence des données entre les systèmes distribués et découplez les systèmes métier (panier, points de fidélité, etc.) les uns des autres, pour une architecture optimale.
Calcul en temps réel
Les données génèrent de la valeur lorsqu'elles sont en mouvement. L'analyse de données conventionnelle repose principalement sur le modèle de calcul par lots, qui ne permet pas d'effectuer une analyse en temps réel. En combinant Alibaba Cloud Message Queue avec un moteur de calcul courant (tel que Spark, Storm, EMR, ARMS et BeamRunner), vous pouvez facilement réaliser une analyse en temps réel de vos données métier.
Synchronisation de cache
Pour les sessions parallèles de grandes opérations ou les applications client à grande échelle, une architecture de cache à grande échelle est mise en place afin de réduire le temps de réponse (RT) des requêtes et d'améliorer l'expérience utilisateur. Dans le cadre de la promotion Tmall 11-11, une grande variété de produits est présentée aux clients sur l'application Shoutao, l'application Tmall et divers centres commerciaux spécialisés, et le prix de chaque produit fluctue en temps réel au fil de la promotion. Un grand nombre d'accès simultanés à la page de la base de données produit entraîne un temps de réponse élevé, et la bande passante du cache centralisé devient un goulot d'étranglement, empêchant de répondre aux demandes d'accès aux prix des produits. L'architecture multi-cache des centres commerciaux spécialisés utilise Message Queue pour synchroniser plusieurs caches et permettre aux clients d'accéder aux prix des produits.
IM
Au sein d'Alibaba, TradeManager (une application de communication commerciale instantanée) et DingTalk (une application de communication professionnelle) utilisent tous deux Message Queue pour leurs services de messagerie. Un grand nombre de messages sont générés lors de chaque interaction dans les conversations individuelles, les conversations de groupe et les notifications DingTalk.
Assistance améliorée pour vous
Conseil de prévente individualisé, assistance technique 24 h/24, 7 j/7, réponse plus rapide et plus de tickets.
Conseil de prévente individualisé
Assistance technique 24 h/24, 7 j/7
6 tickets gratuits par trimestre
