ApsaraMQ for RocketMQ é uma plataforma distribuída da Alibaba Cloud que unifica o processamento de mensagens, eventos e streams. Construída sobre o Apache RocketMQ, oferece baixa latência, alta concorrência, alta disponibilidade e alta confiabilidade. Com o lançamento do Apache RocketMQ 5.0, ApsaraMQ for RocketMQ agora disponibiliza uma versão server-side 5.x mais estável e confiável. Este tópico descreve as diferenças e a compatibilidade entre as versões server-side 5.x e 4.x do ApsaraMQ for RocketMQ.
Vantagens da versão 5.x
Em comparação com as versões server-side anteriores, o ApsaraMQ for RocketMQ 5.x oferece as seguintes vantagens:
-
Arquitetura mais avançada
Adota integralmente uma arquitetura de mensagens com separação entre armazenamento e computação. Os recursos de armazenamento e de computação podem ser escalados horizontalmente de forma independente, conforme a necessidade. Essa arquitetura viabiliza operações e manutenção (O&M) elásticas e eficientes, além de fornecer capacidades de alta performance em larga escala.
-
Menor barreira de desenvolvimento
Prioriza o uso de SDKs de cliente totalmente compatíveis com o Apache RocketMQ, mantendo também compatibilidade retroativa com todas as versões anteriores de SDK e operações de API.
Suporta identificação segura dentro de uma VPC. Para migrar para a cloud, basta modifique o ponto de acesso — nenhuma outra alteração no código é necessária.
-
Menor barreira de O&M
Disponibiliza soluções como rotação automática, elasticidade e um ambiente de staging leve. Essas soluções abordam desafios comuns, como avaliação de capacidade em produção, elasticidade para picos e vales de negócio, e ambientes de canary release diários. Essa abordagem reduz a barreira geral de O&M e minimiza os riscos.
-
Custos mais flexíveis
Por meio da otimização da tecnologia de infraestrutura cloud, as capacidades de computação para envio e recebimento de mensagens suportam uma combinação de tráfego reservado e em burst. Com isso, as empresas não precisam reservar grandes buffers para tráfego em burst.
O armazenamento de mensagens opera no modelo de pagamento conforme o uso, o que oferece vantagens elásticas significativas em comparação à vinculação de discos em cloud, que não permitem redução de capacidade.
-
Modelos de venda mais abrangentes
Oferece um conjunto mais completo de planos em camadas, com suporte a modelos de precificação mensal e por hora.
-
O novo LiteTopic model oferece melhor suporte para comunicação assíncrona em aplicações de IA
Resolve problemas comuns como longos tempos de processamento em tarefas de IA, escassez e alto custo de recursos de capacidade computacional, e conflitos entre a utilização de capacidade computacional e as flutuações de tráfego de negócio. Fornece um recurso de tópico leve e as soluções correspondentes, permitindo que desenvolvedores crie com facilidade um sistema de comunicação assíncrona robusto, eficiente e escalável. Isso suaviza picos e vales de requisições, alivia a pressão de processamento no backend, melhora a utilização de recursos e aumenta a economia de custos.
Descrição dos SDKs para cada versão
A tabela a seguir descreve os SDKs e o suporte a recursos para cada versão do ApsaraMQ for RocketMQ. Na tabela, ✔#10004; indica que o recurso é suportado e ✘#10008; indica que não é suportado.
Na tabela a seguir, ✔ indica que o recurso é suportado e ✘ indica que não é.
Comparison Item | ||||||
Protocolo | gRPC protocol v2 | Remoting protocol | Remoting protocol | Remoting protocol | gRPC protocol v1 | HTTP protocol |
Instâncias acessíveis | Instâncias da série 5.x |
|
|
| Instâncias da série 4.x | Instâncias da série 4.x |
Recomendações de uso | Use o SDK gRPC 5.x.
|
|
| |||
Envio de mensagens comuns, ordenadas, transacionais e agendadas | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo concorrente | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo ordenado de mensagens | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo ordenado de mensagens concurrency optimization | ✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; |
Consumo em broadcast | ✘#10008; | ✔#10004; | ✔#10004; | ✔#10004; | ✘#10008; | ✘#10008; |
Consumo em stream (como integração com Flink) | ✘#10008; | ✔#10004; | ✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; |
Rastreamento de mensagens | ✔#10004; | ✔#10004; | Suportado na versão 4.5.2 e posteriores | ✔#10004; | ✔#10004; | ✘#10008; |
✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | |
✔#10004; | Apenas instâncias da série 5.x são suportadas | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | |
Compatibilidade de recursos entre as versões 4.x e 5.x
As instâncias ApsaraMQ for RocketMQ 5.x foram construídas com base na experiência de produção de grandes clientes corporativos e contam com recursos e comportamentos otimizados para envio e recebimento de mensagens. Por isso, as configurações de parâmetros e os comportamentos de alguns recursos podem diferir em determinados cenários. Essas mudanças geralmente não afetam o fluxo principal de mensagens. Caso você atualize uma instância 4.x existente para a 5.x, avalie os riscos de acordo com as necessidades do seu negócio.
A tabela a seguir descreve as diferenças de recursos e comportamentos:
Diferença de recurso | Versão 4.x | Versão 5.x | Descrição |
Duração máxima para mensagens agendadas | 40 dias |
Para mais informações, consulte Quotas and limits. | Durações de agendamento muito longas podem representar um risco de estabilidade para o sistema. Evite configurar durações excessivamente longas — use durações menores para simular os cenários de negócio. Para mais informações, consulte Scheduled and delayed messages. Se você estiver migrando uma instância 4.x existente e a duração máxima não atender aos seus requisitos, abra um ticket para obter assistência. |
Suporte ao protocolo HTTP | ✔ | ✘ | A versão 5.x não suporta o protocolo HTTP. Se a sua instância 4.x atual utiliza o protocolo HTTP, adie a atualização. |
Política de autorização ram | Data link + control link | Suporta o control link, mas a política de autorização difere da versão 4.x. |
|
Roteamento global de mensagens | ✔ | Use o recurso Global Message Replication. | Global Message Replication suporta os tipos de instância open source, Alibaba Cloud 4.x e Alibaba Cloud 5.x, fornecendo sincronização entre regiões e entre instâncias para mensagens e progresso de consumo. |
Restrição de tipo de mensagem | Sem restrição | Estritamente restrito | Na versão 5.x, os tipos de mensagem são separados em tópicos para O&M e processamento independentes. O sistema valida rigorosamente o tipo da mensagem enviada em relação ao tipo de mensagem defina para o tópico. Se a validação falhar, a requisição de envie é rejeitada e uma exceção de incompatibilidade de tipo é retornada. Para mais informações, consulte Topic behavior constraints. |
Restrições de compra
As instâncias ApsaraMQ for RocketMQ 5.x estão disponíveis para compra por todos os usuários.
As instâncias ApsaraMQ for RocketMQ 4.x estão disponíveis para compra apenas por usuários existentes. Recomendamos que você atualize sua instância para a versão 5.x o quanto antes. Para realizar a atualização, abra um ticket para obter assistência.
Descrição da atualização da versão 4.x para a 5.x
No momento, não é possível atualizar diretamente instâncias 4.x para a versão 5.x por meio de uma ferramenta de atualização. Para migrar uma instância existente para a 5.x, adquira uma instância 5.x e, em seguida, migre gradualmente o tráfego do seu service para a nova instância, conforme ilustrado na figura a seguir.
Conforme ilustrado na figura anterior, você pode crie rapidamente os metadados na segunda etapa usando os recursos de importação/exportação de Topic e Group. Para mais informações, consulte Topic Import/Export e Group Import/Export.
Durante a migração do seu negócio, utilize a solução a seguir, que combina operações de leitura e escrita duplas com uma liberação em fases.
