ApsaraMQ for RocketMQ

O ApsaraMQ for RocketMQ é um serviço de fila de mensagens distribuída que suporta comunicação assíncrona confiável baseada em mensagens entre microsserviços, sistemas distribuídos e aplicações serverless.

O ApsaraMQ for RocketMQ é um middleware de mensagens profissional como produto central na arquitetura de Internet empresarial. Ele suporta comunicação assíncrona baseada em mensagens confiáveis entre microsserviços, sistemas distribuídos e aplicações serverless. Este serviço pode ser usado para criar facilmente um sistema distribuído escalável com acoplamento flexível e alta disponibilidade.

O ApsaraMQ for RocketMQ está integrado na infraestrutura do Alibaba Group há mais de 11 anos e tem suportado o evento de vendas de comércio eletrônico 11-11 da Alibaba por nove anos. Ele apresenta baixa latência, alta concorrência, alta disponibilidade, alta confiabilidade e capacidade poderosa de pilha de mensagens, além de suportar inundações de dados em nível trilionário. Você pode usar o MQ para transmitir livremente dados entre componentes de aplicativos em qualquer escala.

Benefícios

Alto Desempenho e Baixa Latência
A Fila de Mensagens suporta 10 milhões de consultas por segundo (QPS) e fluxo de mensagens em trilhões, sem limites de concorrência ou desempenho superior
Alta Confiabilidade
A Fila de Mensagens suporta gravação dupla síncrona, redundância de dados ultratripla em servidores e tecnologia de cópia de dados de comutação rápida, garantindo confiabilidade de dados de até 99,99999999%
Alta Escalabilidade
A Fila de Mensagens suporta filas de dez mil mensagens. O número de filas pode ser escalado elasticamente e a escala do cluster pode ser automaticamente dimensionada. Este processo é totalmente transparente para os usuários
Controle de Permissões
A Fila de Mensagens controla as permissões de envio e recebimento de cada mensagem pelo tópico da mensagem e ID do consumidor, garantindo a segurança das mensagens

Recursos

  • Alto Desempenho e Baixa Latência

    O ApsaraMQ for RocketMQ garante alto desempenho mesmo no caso de um acúmulo massivo de mensagens, sem afetar o serviço do cluster. Isso é particularmente importante durante o deslocamento de carga (armazenamento de buffer).


    A partir de anos de experiência no atendimento ao evento anual de comércio eletrônico 11-11 da Alibaba, a equipe técnica da Alibaba Cloud desenvolveu métodos para resolver problemas de oscilação no tempo de resposta de solicitações causados por sobrecarga do sistema devido à concorrência extremamente alta. Entre o fluxo de trilhões de mensagens enviadas durante o evento 11-11 realizado em 2017, a latência registrada de 99,6% das solicitações de gravação de mensagens foi inferior a 1 ms, e inferior a 10 ms para a latência registrada de 99,996% das solicitações de gravação de mensagens.


    A mensagem é enviada imediatamente após chegar ao servidor, garantindo a entrega oportuna da mensagem.

  • Alta disponibilidade, confiabilidade e escalabilidade

    O ApsaraMQ for RocketMQ oferece serviços de nuvem de mensagens altamente disponíveis em várias regiões ao redor do mundo. As salas de servidores e as instalações de hardware são construídas de acordo com padrões elevados, conforme o IDC da Alibaba. Cada região é implantada com múltiplas salas de servidores. Mesmo se um servidor inteiro estiver fora de serviço, a Fila de Mensagens ainda pode liberar efetivamente mensagens para os aplicativos.


    O ApsaraMQ for RocketMQ suporta soluções de implantação multiativa na mesma cidade em várias regiões financeiras, incluindo Leste da China 1 (Hangzhou), Leste da China 2 (Shanghai), Sul da China 1 (Shenzhen) e outras regiões, protegendo sistemas de transações financeiras centrais.

  • Controle de acesso seguro

    O ApsaraMQ for RocketMQ suporta criação de conta primária e subconta, funcionalidade de lista negra e lista branca e as funções STS do RAM da Alibaba Cloud.


    O ApsaraMQ for RocketMQ suporta autorização entre contas e autorização por meio de contas primárias e subcontas.


    As mensagens ordenadas são consumidas na ordem de publicação (primeiro a entrar, primeiro a sair). A fila de mensagens suporta ordenação global e ordenação segmentada de mensagens.

  • Modelo de tópico (tópico)

    O ApsaraMQ for RocketMQ suporta o modo Pub/Sub. Nesse modo, o criador envia a mensagem para o tópico especificado. Um ou vários consumidores podem assinar a mensagem.


    O ApsaraMQ for RocketMQ suporta consumo por cluster e consumo por broadcast. Assinantes que usam o mesmo ID de consumidor pertencem ao mesmo cluster. No modo de consumo por cluster, cada mensagem precisa ser processada por apenas um dos assinantes no cluster. No modo de consumo por broadcast, cada mensagem é enviada para todos os assinantes no cluster, garantindo que a mensagem seja consumida por cada assinante no cluster pelo menos uma vez.

  • Tipos diversificados de mensagens

    Mensagens comuns são usadas para desacoplamento assíncrono de negócios entre sistemas, deslocamento de carga, registro de logs, sincronização de cache em larga escala entre hosts e computação e análise em tempo real.


    Mensagens ordenadas são publicadas e consumidas em ordem, divididas em mensagens com ordenação global e particional.


    O ApsaraMQ for RocketMQ fornece uma função de transação distribuída conhecida como X/Open XA para garantir a consistência das transações.


    Depois que uma mensagem é enviada ao servidor de fila de mensagens, o servidor envia a mensagem no momento especificado (por exemplo, às 15:00:00 em 1 de janeiro de 2016) após o horário de envio da mensagem (horário atual).


    Depois que uma mensagem é enviada ao servidor de fila de mensagens, o servidor envia a mensagem no momento de atraso especificado (por exemplo, 30 minutos depois) após o horário de envio da mensagem (horário atual).

  • Ferramentas de manutenção sistemáticas

    O ApsaraMQ for RocketMQ fornece um conjunto abrangente de ferramentas de manutenção para ajudar você a detectar e resolver problemas do sistema rapidamente.


    Consulte mensagens por tópico, ID de mensagem ou chave de mensagem no servidor de fila de mensagens.


    O ApsaraMQ for RocketMQ registra dados completos sobre todo o processo, incluindo o fluxo de mensagens desde o criador até o servidor de fila de mensagens e depois até o usuário final, agrega e analisa os dados e constrói um rastreamento visual de mensagens de ponta a ponta.


    O ApsaraMQ for RocketMQ pode reproduzir mensagens consumidas em um horário especificado, funcionando como uma poderosa ferramenta de solução de problemas.


    Você pode definir regras de monitoramento e alerta para cada ID de cliente com base no tempo de atraso de consumo e na quantidade de mensagens acumuladas, para detectar problemas em tempo hábil.


    O ApsaraMQ for RocketMQ fornece um conjunto completo de APIs abertas RESTful HTTP padrão do tipo controle, que podem implementar uma série de funções de gerenciamento e manutenção de recursos, além de facilitar o acesso.

Cenários de clientes

  • Desacoplamento
  • Deslocamento de carga (armazenamento de buffer)
  • Transações distribuídas
  • Computação em tempo real
  • Sincronização de cache em larga escala
  • IM
Desacoplamento

Desacoplamento

O acoplamento flexível entre sistemas ajuda a melhorar a escalabilidade e confiabilidade, e é a melhor solução de design para aplicações modernas. Usando a Fila de Mensagens, você pode enviar, armazenar e receber mensagens entre qualquer quantidade de componentes de serviço de aplicativo (sistemas) sem perda de mensagens. Isso simplifica a execução de componentes de serviço de aplicativo em nuvem (sistemas) e oferece maior custo-benefício

Deslocamento de carga (armazenamento de buffer)

Deslocamento de carga (armazenamento de buffer)

Durante eventos em larga escala, como o pico de transações à meia-noite durante o festival de comércio eletrônico 11-11 do Tmall da Alibaba, a distribuição de dinheiro virtual na Gala do Festival da Primavera e outros grandes eventos online, um grande número de solicitações pode falhar quando o volume de solicitações externas excede a capacidade de processamento do sistema. Se o sistema não tiver medidas de proteção adequadas, quando muitas solicitações acumuladas atingirem o tempo limite e não puderem ser restauradas automaticamente, o sistema entrará em colapso e sua capacidade de serviço será considerada 0 para serviços externos. Isso, por sua vez, pode afetar negativamente e substancialmente a experiência do usuário

Transações distribuídas

Transações distribuídas

No modo de processamento de transações convencional, os processos de negócios entre múltiplos sistemas ou componentes de aplicativos estão acoplados a uma grande transação, resultando em um longo tempo de resposta e uma longa cadeia de negócios, afetando assim a disponibilidade do sistema. Após introduzir as mensagens de transações distribuídas da Fila de Mensagens, você pode separar os negócios de links principais que precisam ser processados sincronicamente dos negócios de links secundários que podem ser processados assincronicamente, dividindo uma grande transação em uma pequena transação para reduzir a interação entre sistemas.
Dessa forma, você pode garantir a consistência dos dados entre sistemas distribuídos e desacoplar os sistemas de negócios (carrinho de compras, pontos, etc.) uns dos outros, para realizar um design arquitetural ótimo.

Computação em tempo real

Computação em tempo real

Os dados geram valor durante o "fluxo". A análise de dados convencional baseia-se principalmente no modelo de computação em lote, que não consegue realizar análise de dados em tempo real. Ao combinar a Fila de Mensagens da Alibaba Cloud com um mecanismo de computação principal (como Spark, Storm, EMR, ARMS e BeamRunner), você pode realizar convenientemente a análise de dados de negócios em tempo real

Sincronização de cache em larga escala

Sincronização de cache em larga escala

Para sessões paralelas de grandes atividades ou clientes de aplicativos em larga escala, é aplicado um design de cache em larga escala para reduzir o tempo de resposta das solicitações (RT) e melhorar a experiência do cliente. No caso da promoção 11-11 do Tmall, uma ampla variedade de produtos é apresentada aos clientes nos aplicativos Shoutao, Tmall e várias lojas especializadas, e o preço de cada produto flutua em tempo real conforme a promoção avança. Um grande número de acessos simultâneos à página do banco de dados de produtos resulta em um tempo de resposta longo, e a largura de banda do cache centralizado se torna um gargalo, levando ao fracasso em atender às demandas de acesso ao preço dos produtos. O design de múltiplos caches para lojas especializadas usa a Fila de Mensagens para realizar a sincronização entre vários caches, permitindo que os clientes acessem o preço do produto

IM

IM

Dentro da Alibaba, tanto o TradeManager (um aplicativo para comunicação instantânea de negócios) quanto o DingTalk (um aplicativo para comunicação corporativa) usam a Fila de Mensagens para seus serviços de mensagens. Um grande número de mensagens é gerado durante cada interação ocorrida em bate-papos 1-a-1, bate-papos em grupo e notificações do DingTalk

Suporte atualizado para você

Consulta individual de pré-venda, suporte técnico 24/7, resposta mais rápida, e mais chamados.

Consulta individual de pré-venda

Consultoria de especialistas em nuvem. Saiba mais

Suporte técnico 24/7

Tempo de serviço estendido de 10 horas, 5 dias por semana para 24/7. Saiba mais

Seis chamados grátis por trimestre

O número de chamados grátis dobrou de 3 para 6 por trimestre. Saiba mais

Resposta mais rápida

Encurte o tempo de resposta pós-venda de 36 horas para 18 horas. Saiba mais
phone Fale Conosco
Oi, eu sou o assistente de IA da Alibaba Cloud!
Posso ajudar com perguntas e soluções.