Todos os produtos
Search
Central de documentação

ApsaraMQ for RocketMQ:Migrar clusters Apache RocketMQ autogerenciados para o ApsaraMQ for RocketMQ

Última atualização: Jun 27, 2026

Em comparação com o Apache RocketMQ open source, o ApsaraMQ for RocketMQ da Alibaba Cloud oferece maior estabilidade, segurança aprimorada e um sistema de O&M mais completo. Migre seus clusters RocketMQ open source para o ApsaraMQ for RocketMQ para melhorar a confiabilidade e reduzir a sobrecarga operacional.

Comparação de produtos

O ApsaraMQ for RocketMQ da Alibaba Cloud apresenta vantagens significativas sobre o RocketMQ open source em arquitetura técnica, elasticidade, O&M e recursos de nível empresarial.

Item

Cluster Apache RocketMQ autogerenciado

ApsaraMQ for RocketMQ série 5.x

Storage elasticity

Não possui pool de recursos e utiliza arquitetura com armazenamento e computação acoplados.

Aproveita pools de recursos em grande escala da infraestrutura de nuvem e utiliza arquitetura com armazenamento e computação desacoplados.

API and SDK access

Compatível com SDKs do Apache RocketMQ.

  • Compatível com SDKs do Apache RocketMQ.

  • Compatível com SDKs ONS da Alibaba Cloud.

Technical architecture

  • Utiliza discos locais.

  • O espaço de armazenamento não permite dimensionamento elástico. Espaço insuficiente pode causar limpeza prematura de dados.

  • Gera altos custos de armazenamento devido às múltiplas réplicas.

  • Baseado em armazenamento em nuvem de grande escala e totalmente serverless.

  • Use o espaço de armazenamento conforme necessário, sem planejar o dimensionamento.

  • Faturamento no modelo de pagamento conforme o uso. Para o mesmo número de réplicas, o custo é apenas um terço do valor de um cluster autogerenciado.

Compute elasticity

  • Exige planejamento de capacidade com base no uso do cluster.

  • Requer reserva de capacidade. A redução de escala é complexa.

  • Não suporta tráfego em rajada devido a limitações na velocidade de expansão.

  • Oferece elasticidade baseada nos pools de recursos da infraestrutura de nuvem.

  • Elasticidade planejada: atualize ou reduza especificações a qualquer momento, com alterações aplicadas em minutos.

  • Elasticidade não planejada: suporta tráfego em rajada. Elimina a necessidade de reservar grandes quantidades de capacidade, o que reduz custos.

O&M complexity

  • O O&M manual via linha de comando é custoso e de alto risco.

  • Não possui sistema de observabilidade e monitoramento.

  • Plataforma como Serviço (PaaS) totalmente gerenciada, que dispensa O&M e implantação de recursos de máquina.

  • Fornece recursos prontos para uso, como diagnósticos por painel, rastreamento de mensagens, monitoramento e alertas.

Stability guarantee

Requer equipe técnica experiente para O&M autogerenciado.

Oferece garantia clara de Acordo de Nível de Serviço (SLA):

  • Confiabilidade dos dados: até 99,99999999%.

  • Disponibilidade do serviço: até 99,99%.

Enterprise-grade features

Exige equipe técnica experiente para desenvolvimento personalizado.

Disponibiliza recursos prontos para uso, como canary release de ponta a ponta, roteamento e replicação de mensagens, extração, transformação e carga (ETL), além de integração e análise de eventos.

Systematic disaster recovery

Requer equipe técnica experiente para O&M autogerenciado.

Fornece os seguintes planos sistemáticos de recuperação de desastres:

  • Recuperação de desastres ativa-ativa intraurbana

  • Recuperação de desastres geográfica

Como funciona a solução de migração

Requisitos básicos

O RocketMQ é amplamente utilizado em cenários de negócios críticos, como processamento de pedidos e pagamentos online. Os sistemas upstream e downstream dependentes de serviços de mensagens possuem requisitos rigorosos de estabilidade; portanto, migre os clusters RocketMQ com cuidado. A solução de migração deve atender aos seguintes requisitos:

  • Nenhuma interrupção de serviço

    O processo de migração não deve afetar as aplicações de mensagens da camada superior nem causar um número significativo de erros ou falhas.

  • Sem duplicação significativa de mensagens

    A migração não deve gerar muitas mensagens duplicadas. Isso evita que sua empresa precise lidar com duplicação sistemática de mensagens causada pela migração.

  • Envio e recebimento de mensagens em tempo real

    A latência de mensagens de ponta a ponta não deve aumentar significativamente durante a migração, evitando falhas na entrega.

Design da solução

Para atender a esses requisitos de migração, o ApsaraMQ for RocketMQ fornece uma ferramenta de migração que facilita transições transparentes e sem interrupções. Essa ferramenta gerencia a migração tanto de metadados (como tópicos, grupos e offsets de consumidores) quanto de mensagens de negócios.

  • Migração de metadados: o sistema lê os metadados do cluster RocketMQ autogerenciado de origem e os copia para o cluster ApsaraMQ for RocketMQ de destino, criando e sincronizando os metadados.

  • Migração de mensagens: o ApsaraMQ for RocketMQ utiliza um componente interno de controle de roteamento para atuar como proxy das informações de roteamento de tópicos em segundo plano. Esse componente permite a troca dinâmica do tráfego de leitura e gravação dos clientes, tornando o processo transparente para seus serviços.Message migration

    Conforme ilustrado na figura anterior, suponha que o Tópico A no cluster de origem tenha oito partições de leitura e oito partições de gravação.

    A tarefa de migração de dados também cria um Tópico A no cluster de destino com o mesmo número de partições de leitura e gravação do cluster de origem.

    Quando o processo de migração de mensagens começa, o componente de controle de roteamento do ApsaraMQ for RocketMQ gerencia as informações de roteamento de tópicos tanto dos clusters de origem quanto de destino. Ele retorna dinamicamente as informações de partição de leitura e gravação para o cliente com base no estágio da migração. Por exemplo:

    • Cenário de leitura dupla: o componente retorna as informações de todas as 16 partições de leitura dos clusters de origem e de destino.

    • Gravação exclusiva no cluster de destino: o componente retorna apenas as oito partições de gravação do cluster de destino.

Benefícios da solução de migração

A solução de migração para a nuvem do ApsaraMQ for RocketMQ utiliza um componente proprietário de proxy de metadados de roteamento de mensagens desenvolvido pela Alibaba Cloud. Esse componente suporta controle de roteamento de mensagens, agendamento e deslocamento de tráfego com granularidade no nível de tópico, oferecendo os seguintes benefícios:

  • Sem interrupções de serviço e impacto mínimo nas mensagens

    A solução de migração suporta transição contínua. Durante a troca de tráfego, o envio de mensagens não é interrompido e as aplicações de negócios não sofrem impacto. O risco de latência ou duplicação de mensagens é muito baixo.

  • Nenhum recurso adicional necessário

    Suas aplicações não precisam ser expandidas ou implantadas em múltiplos clusters. A migração requer apenas uma atualização gradual das configurações e não demanda recursos extras de máquina.

  • Baixo impacto nos negócios e fácil implementação

    Durante a migração, basta alterar a configuração de endpoint das suas aplicações e reiniciá-las uma única vez. A troca subsequente de tráfego é gerenciada automaticamente por configurações dinâmicas no servidor do ApsaraMQ for RocketMQ. Atualize as aplicações upstream e downstream independentemente, sem precisar mapear dependências de mensagens.

  • Suporte a canary release e rollback

    As tarefas de migração operam com granularidade no nível de tópico. Execute um canary release para tópicos específicos. Se surgirem riscos aos negócios durante a migração, realize um rollback a qualquer momento.