O ApsaraMQ for RocketMQ é uma plataforma de mensagens distribuídas baseada no Apache RocketMQ. Ela unifica o processamento de mensagens, eventos e fluxos com baixa latência, alta concorrência, alta disponibilidade e alta confiabilidade. Seus principais recursos incluem desacoplamento assíncrono, processamento de dados em fluxo e processamento orientado a eventos para aplicações distribuídas.
Por que escolher o ApsaraMQ for RocketMQ
O ApsaraMQ for RocketMQ baseia-se na infraestrutura cloud-native da Alibaba Cloud e é compatível com as principais APIs e recursos do Apache RocketMQ.
Em comparação com clusters autogerenciados, o ApsaraMQ for RocketMQ oferece os seguintes benefícios:
Arquitetura avançada
O ApsaraMQ for RocketMQ desacopla computação e armazenamento. Ambos escalam horizontalmente e de forma independente, permitindo operações e manutenção (O&M) elásticas e envio de mensagens de alto desempenho em grande escala.
Alto desempenho
Um cluster de instância única suporta até 1 milhão de transações por segundo (TPS) para envio e recebimento de mensagens, garantindo estabilidade durante picos de tráfego, como grandes promoções.
Segurança e confiabilidade
Armazenamento redundante entre zonas: Implantação em várias zonas com armazenamento de dados triplamente redundante. Se uma zona ficar indisponível, o serviço permanecerá acessível.
Replicação de dados: Suporte à replicação de dados entre regiões e dentro da mesma região. Regras de roteamento sincronizam dados entre instâncias de origem e destino.
SLA de estabilidade
A implantação multizona oferece um SLA líder do setor: 99,99% de disponibilidade do serviço e 99,99999999% de confiabilidade dos dados por meio de armazenamento com múltiplas réplicas.
Elasticidade e custo-benefício
A computação de mensagens combina capacidade reservada e capacidade burst, eliminando a necessidade de reservar grandes buffers para picos de tráfego e economizando até metade dos recursos de máquina. O armazenamento é serverless e com pagamento conforme o uso, oferecendo maior elasticidade e custos menores em comparação com discos em nuvem anexados.
O&M e observabilidade
Fornece recursos de O&M e observabilidade: integração com um clique ao OpenTelemetry e Prometheus, rastreamento ponta a ponta e suporte a OpenAPI para integração de O&M self-service.
Recuperação de desastres de nível financeiro
Suporta roteamento e replicação global de mensagens entre regiões com latência em nível de milissegundos, além de backup e sincronização de dados no nível de tópico.
Casos de uso
Baseado em armazenamento unificado de mensagens e uma camada leve de computação, o ApsaraMQ for RocketMQ atende a três cenários principais: desacoplamento assíncrono, processamento de dados em fluxo e processamento orientado a eventos.
Mensagens de negócios
-
Originalmente criado para o Double 11 da Alibaba, o ApsaraMQ for RocketMQ é amplamente utilizado em sistemas de microsserviços para logística, carrinhos de compras e pontos de crédito. O ApsaraMQ for RocketMQ proporciona estes benefícios:
-
Desacoplamento assíncrono para encurtar cadeias de processamento
O ApsaraMQ for RocketMQ desacopla serviços upstream de downstream, encurtando a cadeia de invocação. Isso resulta em tempos de resposta mais rápidos, menor acoplamento e maior eficiência para desenvolvedores.
-
Absorção de picos de carga para melhorar a estabilidade
Diferente de middlewares tradicionais que oferecem apenas operações assíncronas, o ApsaraMQ for RocketMQ foi projetado para cenários de transações online e inclui a absorção de picos de carga como recurso central, melhorando a estabilidade e reduzindo custos.
O ApsaraMQ for RocketMQ acumula centenas de milhões de mensagens e lida com modelos mistos de tráfego quente e frio. Ele absorve surtos de tráfego durante cenários de pico, como grandes promoções, mantendo os serviços downstream dentro de limites operacionais seguros.
-
-
A solução de ApsaraMQ for RocketMQ para mensagens transacionais distribuídas oferece os seguintes benefícios:
-
Sistema de alto desempenho
Baseadas em consistência eventual, as mensagens transacionais proporcionam maior throughput e escalabilidade do que as transações XA tradicionais.
-
Custo de desenvolvimento reduzido
Uma interface de duas fases coordena múltiplos ramos de transação, eliminando a necessidade de lógica de compensação de negócios.
A figura a seguir compara uma transação tradicional com a solução de mensagens transacionais do ApsaraMQ for RocketMQ:
-
-
O ApsaraMQ for RocketMQ fornece mensagens agendadas distribuídas com precisão de segundos, amplamente utilizadas para processamento de timeout de pedidos e agendamento atrasado distribuído.
As mensagens agendadas do ApsaraMQ for RocketMQ proporcionam estes benefícios:
-
Alta precisão de agendamento e baixa sobrecarga de desenvolvimento
Não há intervalos escalonados para horários de agendamento. Dispare eventos com precisão arbitrária sem necessidade de deduplicação no lado do negócio.
-
Alto desempenho e escalabilidade
Soluções de agendamento tradicionais exigem varreduras de banco de dados que criam gargalos de desempenho. O ApsaraMQ for RocketMQ utiliza processamento orientado a eventos para alcançar milhões de TPS.
-
Processamento de fluxo
O ApsaraMQ for RocketMQ oferece armazenamento de fluxo de alto throughput que conecta coleta de logs, integração de dados e sistemas analíticos. Utilize o ApsaraMQ for RocketMQ para distribuir dados upstream para sistemas downstream, como computação em tempo real e armazenamento offline.
Processamento orientado a eventos
Combine o ApsaraMQ for RocketMQ com o EventBridge para implementar arquiteturas orientadas a eventos. Regras visuais de eventos no EventBridge processam dados de mensagens e acionam destinos downstream, como Function Compute, endpoints HTTP ou serviços de terceiros.
Guia de migração
Primeiros passos
Crie uma instância do ApsaraMQ for RocketMQ: