ApsaraMQ for RocketMQ est une plateforme de messagerie distribuée basée sur Apache RocketMQ. Elle unifie le traitement des messages, des événements et des flux avec une faible latence, une forte concurrence, une haute disponibilité et une grande fiabilité. Ses fonctionnalités principales incluent le découplage asynchrone, le traitement des données en flux et le traitement piloté par les événements pour les applications distribuées.
Pourquoi choisir ApsaraMQ for RocketMQ
ApsaraMQ for RocketMQ s’appuie sur l’infrastructure cloud-native d’Alibaba Cloud et est compatible avec les APIs et les fonctionnalités principales d’Apache RocketMQ.
Par rapport aux clusters gérés en interne, ApsaraMQ for RocketMQ offre les avantages suivants :
Architecture avancée
ApsaraMQ for RocketMQ dissocie le calcul du stockage. Le stockage et le calcul montent en charge horizontalement et indépendamment, permettant des opérations et une maintenance (O&M) élastiques ainsi qu’une messagerie haute performance à grande échelle.
Haute performance
Un cluster mono-instance prend en charge jusqu’à 1 million de transactions par seconde (TPS) pour l’envoi et la réception de messages, garantissant la stabilité lors des pics de trafic, tels que les grandes promotions commerciales.
Sécurité et fiabilité
Stockage redondant par zone : déployé sur plusieurs zones avec un stockage de données triple redondant. Si une zone devient indisponible, le service reste accessible.
Réplication des données : prend en charge la réplication des données inter-region et intra-région. Les règles de routage synchronisent les données entre les instances source et destination.
SLA de stabilité
Le déploiement multi-zones offre un SLA leader du secteur : 99,99 % de disponibilité du service et 99,99999999 % de fiabilité des données grâce au stockage multi-réplicas.
Élasticité et rentabilité
Le calcul des messages combine une capacité réservée et une capacité de pointe, éliminant le besoin de prévoir de larges tampons pour les pics de trafic et économisant jusqu’à la moitié des ressources machine. Le stockage est serverless et facturé au paiement à l’utilisation, offrant une plus grande élasticité et des coûts inférieurs à ceux des disques cloud attachés.
O&M et observabilité
Fournit des fonctionnalités d’O&M et d’observability : intégration en un clic avec OpenTelemetry et Prometheus, traçage de bout en bout et prise en charge d’OpenAPI pour l’intégration d’O&M en libre-service.
Reprise après sinistre de niveau financier
Prend en charge le routage et la réplication globaux des messages inter-régions avec une latence de l’ordre de la milliseconde, ainsi que la sauvegarde et la synchronisation des données au niveau des topics.
Cas d’utilisation
Basé sur un stockage de messages unifié et une couche de calcul légère, ApsaraMQ for RocketMQ prend en charge trois scénarios principaux : le découplage asynchrone, le traitement des données en flux et le traitement piloté par les événements.
Messages métier
-
ApsaraMQ for RocketMQ a été initialement conçu pour l’événement Double 11 d’Alibaba et est largement utilisé dans les systèmes de microservices pour la logistique, les paniers d’achat et les points de fidélité. ApsaraMQ for RocketMQ offre les avantages suivants :
-
Découplage asynchrone pour raccourcir les chaînes de traitement
ApsaraMQ for RocketMQ découple les services amont des services aval, ce qui raccourcit la chaîne d’invocation. Cela se traduit par des temps de réponse plus rapides, un couplage plus souple et une meilleure efficacité pour les développeurs.
-
Lissage des pics de charge pour améliorer la stabilité
Contrairement aux middleware traditionnels qui ne fournissent que des opérations asynchrones, ApsaraMQ for RocketMQ a été conçu pour les scénarios de transaction en ligne et intègre le lissage des pics de charge comme fonctionnalité principale, améliorant ainsi la stabilité et réduisant les coûts.
ApsaraMQ for RocketMQ accumule des centaines de millions de messages et gère des modèles de trafic mixtes (chauds et froids). Il absorbe les pics de trafic lors de scénarios de pointe, tels que les grandes promotions, maintenant ainsi les services aval dans des limites opérationnelles sûres.
-
-
La solution de distributed transactional message de ApsaraMQ for RocketMQ offre les avantages suivants :
-
Système haute performance
Basés sur la cohérence à terme, les messages transactionnels offrent un débit plus élevé et une meilleure évolutivité que les transactions XA traditionnelles.
-
Réduction des coûts de développement
Une interface en deux phases coordonne plusieurs branches de transaction, éliminant le besoin de logique de compensation métier.
La figure suivante compare une transaction traditionnelle à la solution de messages transactionnels ApsaraMQ for RocketMQ :
-
-
ApsaraMQ for RocketMQ fournit des scheduled messages distribués avec une précision à la seconde, largement utilisés pour le traitement des délais d’expiration des commandes et la planification différée distribuée.
Les messages planifiés ApsaraMQ for RocketMQ offrent les avantages suivants :
-
Haute précision de planification et faibles frais de développement
Aucun intervalle échelonné pour les heures de planification. Déclenchez des événements avec une précision arbitraire sans nécessiter de déduplication côté métier.
-
Haute performance et évolutivité
Les solutions de planification traditionnelles nécessitent des analyses de base de données qui créent des goulots d’étranglement en termes de performances. ApsaraMQ for RocketMQ utilise le traitement piloté par les événements pour atteindre des millions de TPS.
-
Traitement de flux
ApsaraMQ for RocketMQ fournit un stockage de flux à haut débit qui connecte la collecte de journaux, l’intégration de données et les systèmes d’analyse. Utilisez ApsaraMQ for RocketMQ pour distribuer les données amont vers des systèmes aval tels que le calcul en temps réel et le stockage hors ligne.
Traitement piloté par les événements
Combinez ApsaraMQ for RocketMQ avec EventBridge pour mettre en œuvre des architectures pilotées par les événements. Les règles d’événements visuelles dans EventBridge traitent les données des messages et déclenchent des cibles aval telles que Function Compute, des endpoints HTTP ou des services tiers.
Guide de migration
Premiers pas
Créez une instance ApsaraMQ for RocketMQ :