Tous les produits
Search
Centre de documentation

ApsaraMQ for RocketMQ:Migrer des clusters Apache RocketMQ auto-gérés vers ApsaraMQ for RocketMQ

Dernière mise à jour :Aug 09, 2026

Par rapport à la version open source d'Apache RocketMQ, Alibaba Cloud ApsaraMQ for RocketMQ offre une stabilité supérieure, une sécurité renforcée et un système d'exploitation et de maintenance (O&M) plus complet. Migrez vos clusters RocketMQ open source vers ApsaraMQ for RocketMQ pour améliorer la fiabilité et réduire la charge opérationnelle.

Comparaison des produits

Alibaba Cloud ApsaraMQ for RocketMQ présente des avantages significatifs par rapport à RocketMQ open source en termes d'architecture technique, d'élasticité, d'O&M et de fonctionnalités adaptées aux entreprises.

Élément

Cluster Apache RocketMQ auto-géré

ApsaraMQ for RocketMQ série 5.x

Storage elasticity

Absence de pool de ressources ; architecture couplant stockage et calcul.

S'appuie sur des pools de ressources à grande échelle issus de l'infrastructure cloud ; architecture découplant stockage et calcul.

API and SDK access

Prise en charge des SDK Apache RocketMQ.

  • Prise en charge des SDK Apache RocketMQ.

  • Prise en charge des SDK ONS d'Alibaba Cloud.

Technical architecture

  • Utilisation de disques locaux.

  • Impossible de mettre à l'échelle l'espace de stockage de manière élastique. Un espace insuffisant peut entraîner un nettoyage prématuré des données.

  • Coûts de stockage élevés dus aux multiples réplicas.

  • Repose sur une infrastructure de stockage cloud à grande échelle ; architecture entièrement serverless.

  • Utilisez l'espace de stockage selon vos besoins sans planifier la mise à l'échelle.

  • Facturation au paiement à l'utilisation. Pour un nombre identique de réplicas, le coût représente seulement un tiers de celui d'un cluster auto-géré.

Compute elasticity

  • Planifiez la capacité en fonction de l'utilisation du cluster.

  • Réservez de la capacité. La réduction de capacité (scaling in) est complexe.

  • Impossible de prendre en charge les pics de trafic en raison des limitations de vitesse de montée en puissance (scale-out).

  • Élasticité basée sur les pools de ressources de l'infrastructure cloud.

  • Élasticité planifiée : augmentez ou diminuez les spécifications à tout moment ; les modifications prennent effet en quelques minutes.

  • Élasticité non planifiée : prend en charge les pics de trafic. Inutile de réserver de grandes quantités de capacité, ce qui permet de réaliser des économies.

O&M complexity

  • L'O&M manuel via ligne de commande est coûteux et risqué.

  • Absence de système d'observabilité et de surveillance.

  • Plateforme PaaS (Platform as a Service) entièrement gérée : aucune opération d'O&M ni déploiement de ressources machines requis.

  • Fonctionnalités prêtes à l'emploi : diagnostic via tableau de bord, traçage des messages, surveillance et alertes.

Stability guarantee

Personnel technique expérimenté requis pour l'O&M auto-gérée.

Garantie claire basée sur un accord de niveau de service (SLA) :

  • Fiabilité des données : jusqu'à 99,99999999 %.

  • Disponibilité du service : jusqu'à 99,99 %.

Enterprise-grade features

Personnel technique expérimenté requis pour le développement personnalisé.

Fonctionnalités prêtes à l'emploi : déploiement canari de bout en bout, routage et réplication des messages, extraction, transformation et chargement (ETL), ainsi qu'intégration et analyse des événements.

Systematic disaster recovery

Personnel technique expérimenté requis pour l'O&M auto-gérée.

Plans de reprise après sinistre systématiques disponibles :

  • Reprise après sinistre en mode actif-actif intra-ville

  • Reprise après sinistre géographique

Fonctionnement de la solution de migration

Prérequis de base

RocketMQ est largement utilisé dans des scénarios métier critiques tels que le traitement des commandes et les paiements en ligne. Les systèmes en amont et en aval qui dépendent des services de messagerie ont des exigences strictes en matière de stabilité ; migrez donc les clusters RocketMQ avec précaution. La solution de migration doit répondre aux exigences suivantes :

  • Absence d'interruption de service

    Le processus de migration ne doit pas affecter les applications de messagerie de la couche supérieure ni provoquer un nombre significatif d'erreurs ou de pannes.

  • Absence de duplication significative des messages

    La migration ne doit pas générer un grand nombre de messages dupliqués. Cela évite à votre métier d'avoir à gérer une duplication systématique des messages causée par la migration.

  • Envoi et réception des messages en temps réel.

    La latence de bout en bout des messages ne doit pas augmenter de manière significative pendant la migration. Cela permet d'éviter les échecs de livraison des messages.

Conception de la solution

Pour satisfaire à ces exigences de migration, ApsaraMQ for RocketMQ fournit un outil de migration qui facilite les basculements fluides et transparents. L'outil gère la migration des métadonnées, telles que les topics, les groupes et les offsets des consommateurs, ainsi que celle des messages métier.

  • Migration des métadonnées : lisez les métadonnées depuis le cluster RocketMQ auto-géré source et copiez-les vers le cluster ApsaraMQ for RocketMQ de destination pour créer et synchroniser les métadonnées.

  • Migration des messages : ApsaraMQ for RocketMQ utilise un composant intégré de contrôle de routage pour faire office de proxy pour les informations de routage des topics en arrière-plan. Ce composant permet le basculement dynamique du trafic de lecture et d'écriture des clients, rendant le processus transparent pour vos services.Message migration

    Comme illustré dans la figure précédente, supposons que le Topic A du cluster source dispose de huit partitions en lecture et de huit partitions en écriture.

    La tâche de migration des données crée également un Topic A dans le cluster de destination, avec le même nombre de partitions en lecture et en écriture que le cluster source.

    Lorsque le processus de migration des messages démarre, le composant de contrôle de routage ApsaraMQ for RocketMQ gère les informations de routage des topics pour les clusters source et de destination. Il renvoie dynamiquement les informations des partitions en lecture et en écriture au client en fonction de l'étape de migration. Par exemple :

    • Scénario de double lecture : le composant renvoie les informations de l'ensemble des 16 partitions en lecture provenant des clusters source et de destination.

    • Écriture uniquement vers le cluster de destination : le composant renvoie uniquement les huit partitions en écriture du cluster de destination.

Avantages de la solution de migration

La solution de migration vers le cloud ApsaraMQ for RocketMQ utilise un composant propriétaire de proxy de métadonnées de routage des messages développé par Alibaba Cloud. Ce composant prend en charge le routage des messages, la planification et le contrôle du transfert de trafic avec une granularité au niveau du topic, offrant les avantages suivants :

  • Absence d'interruption de service et impact minimal sur la messagerie

    La solution de migration prend en charge le basculement sans interruption. Pendant le transfert de trafic, la messagerie n'est pas interrompue et les applications métier ne sont pas affectées. Le risque de latence ou de duplication des messages est très faible.

  • Aucune ressource supplémentaire requise

    Inutile de mettre à l'échelle horizontalement vos applications ou de les déployer sur plusieurs clusters. La migration nécessite uniquement une mise à jour progressive des configurations et ne requiert pas de ressources machines supplémentaires.

  • Faible impact métier et mise en œuvre aisée

    Pendant la migration, modifiez simplement la configuration de l'endpoint pour vos applications et effectuez un seul redémarrage. Le basculement ultérieur du trafic est automatiquement géré par des configurations dynamiques sur le serveur ApsaraMQ for RocketMQ. Mettez à niveau les applications en amont et en aval de manière indépendante, sans avoir à répertorier les dépendances de messagerie.

  • Prise en charge du déploiement canari et du rollback

    Les tâches de migration opèrent avec une granularité au niveau du topic. Effectuez un déploiement canari pour des topics spécifiques. Si des risques métier surviennent pendant la migration, effectuez un rollback à tout moment.