Galeria de mapas mentais Fila de mensagens do Alibaba Cloud
Um resumo detalhado do Alibaba Cloud Message Queue RocketMQ, Cloud Message RocketMQ, Cloud Message Queue RabbitMQ, Cloud Message Queue Kafka e Cloud Message Queue MQTT.
Editado em 2024-01-20 09:44:44이것은 (III) 저산소증-유도 인자 프롤릴 하이드 록 실라 제 억제제에 대한 마인드 맵이며, 주요 함량은 다음을 포함한다 : 저산소증-유도 인자 프롤릴 하이드 록 실라 제 억제제 (HIF-PHI)는 신장 빈혈의 치료를위한 새로운 소형 분자 경구 약물이다. 1. HIF-PHI 복용량 선택 및 조정. Rosalasstat의 초기 용량, 2. HIF-PHI 사용 중 모니터링, 3. 부작용 및 예방 조치.
이것은 Kuka Industrial Robots의 개발 및 Kuka Industrial Robot의 모션 제어 지침에 대한 마인드 맵입니다. 주요 내용에는 쿠카 산업 로봇의 역사, 쿠카 산업 로봇의 특성, 쿠카 산업 로봇의 응용 분야, 2. 포장 프로세스에서 쿠카 로봇은 빠르고 일관된 포장 작업을 달성하고 포장 효율성을 높이며 인건비를 줄입니다. 2. 인건비 감소 : 자동화는 운영자에 대한 의존성을 줄입니다. 3. 조립 품질 향상 : 정확한 제어는 인간 오류를 줄입니다.
408 컴퓨터 네트워크가 너무 어렵습니까? 두려워하지 마세요! 나는 피를 구토하고 지식 맥락을 명확히하는 데 도움이되는 매우 실용적인 마인드 맵을 분류했습니다. 컨텐츠는 매우 완전합니다. 네트워크 아키텍처에서 응용 프로그램 계층, TCP/IP 프로토콜, 서브넷 디비전 및 기타 핵심 포인트에 이르기까지 원칙을 철저히 이해하는 데 도움이 될 수 있습니다. 📈 명확한 논리 : Mindmas 보물, 당신은 드문 기회가 있습니다. 서둘러! 이 마인드 맵을 사용하여 408 컴퓨터 네트워크의 학습 경로에서 바람과 파도를 타고 성공적으로 해변을 얻으십시오! 도움이 필요한 친구들과 공유해야합니다!
이것은 (III) 저산소증-유도 인자 프롤릴 하이드 록 실라 제 억제제에 대한 마인드 맵이며, 주요 함량은 다음을 포함한다 : 저산소증-유도 인자 프롤릴 하이드 록 실라 제 억제제 (HIF-PHI)는 신장 빈혈의 치료를위한 새로운 소형 분자 경구 약물이다. 1. HIF-PHI 복용량 선택 및 조정. Rosalasstat의 초기 용량, 2. HIF-PHI 사용 중 모니터링, 3. 부작용 및 예방 조치.
이것은 Kuka Industrial Robots의 개발 및 Kuka Industrial Robot의 모션 제어 지침에 대한 마인드 맵입니다. 주요 내용에는 쿠카 산업 로봇의 역사, 쿠카 산업 로봇의 특성, 쿠카 산업 로봇의 응용 분야, 2. 포장 프로세스에서 쿠카 로봇은 빠르고 일관된 포장 작업을 달성하고 포장 효율성을 높이며 인건비를 줄입니다. 2. 인건비 감소 : 자동화는 운영자에 대한 의존성을 줄입니다. 3. 조립 품질 향상 : 정확한 제어는 인간 오류를 줄입니다.
408 컴퓨터 네트워크가 너무 어렵습니까? 두려워하지 마세요! 나는 피를 구토하고 지식 맥락을 명확히하는 데 도움이되는 매우 실용적인 마인드 맵을 분류했습니다. 컨텐츠는 매우 완전합니다. 네트워크 아키텍처에서 응용 프로그램 계층, TCP/IP 프로토콜, 서브넷 디비전 및 기타 핵심 포인트에 이르기까지 원칙을 철저히 이해하는 데 도움이 될 수 있습니다. 📈 명확한 논리 : Mindmas 보물, 당신은 드문 기회가 있습니다. 서둘러! 이 마인드 맵을 사용하여 408 컴퓨터 네트워크의 학습 경로에서 바람과 파도를 타고 성공적으로 해변을 얻으십시오! 도움이 필요한 친구들과 공유해야합니다!
Fila de mensagens do Alibaba Cloud
Fila de mensagens na nuvem RocketMQ
Posicionamento de produto
A versão Cloud Message Queue RocketMQ é um produto típico de middleware sob uma arquitetura distribuída, usando comunicação assíncrona e um modelo de transmissão de mensagens de publicação-assinatura.
O produto tem as vantagens de comunicação assíncrona, topologia de sistema simples e acoplamento fraco a montante e a jusante. É usado principalmente em cenários de desacoplamento assíncrono, redução de pico de tráfego e preenchimento de vale.
Para links síncronos, em cenários onde os resultados das chamadas precisam ser retornados em tempo real, recomenda-se utilizar a solução de chamadas RPC.
Modelo de domínio da versão RocketMQ da fila de mensagens
Conforme mostrado na figura, o ciclo de vida das mensagens na versão Cloud Message Queue RocketMQ é dividido principalmente em três partes: produção de mensagens, armazenamento de mensagens e consumo de mensagens.
produção de mensagens
Produtor é uma entidade em execução usada para gerar mensagens na versão Cloud Message Queue RocketMQ. Geralmente é integrado a montante do link de chamada comercial. Os produtores são leves, anônimos e sem identidade.
Armazenamento de mensagens
Tópico: Um contêiner de agrupamento para transmissão e armazenamento de mensagens no Cloud Message Queue RocketMQ O tópico é composto internamente por várias filas. O armazenamento e a expansão horizontal de mensagens são realmente implementados por meio de filas dentro do tópico.
Fila (MessageQueue): O contêiner de unidade real para transmissão e armazenamento de mensagens no RocketMQ Cloud Message Queue, que é análogo às partições no Kafka. Cloud Message Queue RocketMQ usa uma estrutura de fila infinita com características de streaming para armazenar mensagens, e as mensagens possuem características de armazenamento sequencial na fila.
Mensagem: A menor unidade de transmissão da versão RocketMQ do Cloud Message Queue. As mensagens são imutáveis e tornam-se imutáveis após o envio inicial e a conclusão do armazenamento.
Consumo de mensagens
ConsumerGroup: um grupo de identidade de consumidor independente definido no modelo de publicação-assinatura do Cloud Message Queue RocketMQ, usado para gerenciar uniformemente vários consumidores (Consumidores) em execução na parte inferior. Vários consumidores do mesmo grupo de consumidores devem manter sua lógica e configuração de consumo consistentes e compartilhar conjuntamente as mensagens assinadas pelo grupo de consumidores para alcançar a expansão horizontal das capacidades de consumo.
Consumidor: a entidade em execução da versão RocketMQ do Cloud Message Queue que consome mensagens. Geralmente é integrada a jusante do link de chamada comercial. Os consumidores devem ser atribuídos a um grupo de consumidores.
Assinatura: configuração de regras para filtragem de mensagens, novas tentativas e progresso de consumo no modelo de publicação e assinatura do Cloud Message Queue RocketMQ. Os relacionamentos de assinatura são gerenciados na granularidade dos grupos de consumidores. Ao definir os relacionamentos de assinatura, os grupos de consumidores controlam como os consumidores no grupo de consumidores especificado implementam a filtragem de mensagens, novas tentativas de consumo, recuperação do progresso do consumo, etc.
Introdução aos métodos de comunicação
Sob a ideia de arquitetura de sistema distribuído, sistemas complexos são divididos em vários submódulos independentes, como módulos de microsserviços. Neste momento, é necessário considerar a comunicação remota entre submódulos. Os modos de comunicação típicos são divididos nos dois tipos a seguir, um é a chamada remota RPC síncrona e o outro é o método de comunicação assíncrona baseado no agente de middleware.
Modelo de chamada RPC síncrona
No modelo de chamada RPC síncrona, a comunicação da chamada é conduzida diretamente entre diferentes sistemas. Cada solicitação é enviada diretamente do chamador para o chamador e, em seguida, o chamador é obrigado a retornar imediatamente o resultado da resposta ao chamador para determinar se o resultado da chamada é. bem-sucedido.
Modelo de comunicação assíncrona
No modo de comunicação de mensagem assíncrona, os subsistemas são conectados diretamente sem acoplamento forte. O chamador só precisa converter a solicitação em um evento assíncrono (mensagem) e enviá-la ao agente intermediário. Se a transmissão for bem-sucedida, a chamada do link assíncrono será realizada. considerado concluído, e o restante O agente intermediário de trabalho será responsável por notificar de forma confiável o evento ao sistema de chamada downstream para garantir que a execução da tarefa seja concluída. O agente intermediário geralmente é um middleware de mensagem.
As vantagens da comunicação assíncrona são as seguintes:
A topologia do sistema é simples
Como o chamador e o receptor se comunicam com o agente intermediário de maneira unificada, o sistema possui uma estrutura em estrela e é fácil de manter e gerenciar.
Acoplamento fraco a montante e a jusante
Os sistemas upstream e downstream são fracamente acoplados, a estrutura é mais flexível e o agente intermediário é responsável pelo buffer e pela recuperação assíncrona. Os sistemas upstream e downstream podem ser atualizados e alterados de forma independente, sem afetar um ao outro.
Capacidade de corte de pico e preenchimento de vale
Os proxies intermediários baseados em mensagens geralmente têm fortes recursos de buffer e modelagem de tráfego, de modo que não sobrecarregarão o downstream quando chegarem picos de tráfego de negócios.
Introdução ao modelo de transmissão de mensagens
Os principais modelos de transmissão de middleware de mensagens são principalmente o modelo ponto a ponto e o modelo de publicação-assinatura.
modelo ponto a ponto
O modelo ponto a ponto também é chamado de modelo de fila e possui as seguintes características:
Anonimato de consumo: A única identidade para comunicação upstream e downstream de mensagens é a fila. Os consumidores downstream não podem declarar identidades independentes ao obter mensagens da fila.
Comunicação um-para-um: Com base nas características do anonimato do consumo, mesmo que existam vários consumidores downstream, eles não possuem identidades próprias e independentes, portanto, cada mensagem na fila compartilhada será processada apenas por um consumidor. Portanto, o modelo ponto a ponto só pode alcançar comunicação um a um.
modelo publicar-assinar
O modelo publicar-assinar possui as seguintes características:
Independência de consumo: Em comparação com o método de consumo anônimo do modelo de fila, todos os consumidores no modelo publicar-assinar têm uma identidade, que geralmente é chamada de grupo de assinaturas (diferentes grupos de assinaturas são independentes uns dos outros e não afetam). uns aos outros.
Comunicação um-para-muitos: com base no design de identidade independente, as mensagens dentro do mesmo tópico podem ser processadas por vários grupos de assinaturas e cada grupo de assinaturas pode obter a quantidade total de mensagens. Portanto, o modelo publicar-assinar pode alcançar comunicação um-para-muitos.
Comparação de modelos de transmissão
O modelo ponto a ponto e o modelo publicar-assinar têm suas próprias vantagens. O modelo ponto a ponto é mais simples, enquanto o modelo publicar-assinar é mais escalonável.
O modelo de transmissão usado pelo Cloud Message Queue RocketMQ é um modelo de publicação-assinatura, portanto também possui as características de um modelo de publicação-assinatura.
Fila de mensagens na nuvem Kafka
Vantagens do produto
Forneça serviços totalmente gerenciados para Apache Kafka de código aberto para resolver os problemas dos produtos de código aberto. Com a versão Cloud Message Queue Kafka, você só precisa se concentrar no desenvolvimento de negócios sem implantação, operação e manutenção. Em comparação com o Apache Kafka de código aberto, a versão Cloud Message Queue Kafka tem custo mais baixo, é mais elástica e mais confiável.
Ecologia de aplicação
Possui um rico ecossistema de aplicativos, incluindo principalmente os seguintes aspectos:
Campo de big data: análise de comportamento de sites, agregação de logs, monitoramento de aplicativos, processamento de dados de streaming, análise de dados online e offline e outros campos.
Integração de dados: importe mensagens para data warehouses off-line, como MaxCompute, OSS, RDS, Hadoop e HBase.
Integração de processamento de dados: Integre com StreamCompute, E-MapReduce, Spark, Storm e outros mecanismos.
Arquitetura do produto
Versão do Cloud Message Queue Kafka
estrutura do sistema
Produtor
Envie mensagens para o Kafka Broker da versão Cloud Message Queue Kafka por meio do modo push. As mensagens enviadas podem ser visitas a páginas de sites, logs de servidores ou informações de recursos do sistema relacionadas à CPU e memória.
Corretor Kafka
O servidor usado para armazenar mensagens. Kafka Broker suporta expansão horizontal. Quanto maior o número de nós do Kafka Broker, maior será a taxa de transferência do cluster Cloud Message Queue Kafka.
Grupo
Assine e consuma mensagens do Cloud Message Queue Kafka versão Broker por meio do modo pull.
Funcionário do zoológico
Gerenciar a configuração do cluster, eleger partições líderes e realizar balanceamento de carga quando o Grupo mudar.
Versão do Cloud Message Queue Kafka
O modelo de publicação/assinatura da versão Cloud Message Queue Kafka
A relação correspondente entre Grupo e Tópico é N:N, ou seja, um Grupo pode assinar vários Tópicos ao mesmo tempo, e um Tópico também pode ser inscrito por vários Grupos ao mesmo tempo.
Embora um Tópico possa ser inscrito por vários Grupos ao mesmo tempo, as mensagens do Tópico só podem ser consumidas por qualquer Consumidor do mesmo Grupo.
Vantagens do produto
Pronto para usar
Compatível com código aberto:
Cloud Message Queue Kafka Edition é 100% compatível com o Apache Kafka de código aberto. Você pode usar diretamente o cliente Apache Kafka de código aberto para se comunicar com Cloud Message Queue Kafka Edition. A versão Cloud Message Queue Kafka atualmente suporta versões de código aberto 0.10.x ~ 2.6.x.
Migração perfeita:
A versão Cloud Message Queue Kafka é baseada no ecossistema Apache Kafka de código aberto existente e você pode migrar para a nuvem sem qualquer modificação de código.
Nenhuma operação e manutenção, fácil de observar
HouseKeeping (componente de inspeção de integridade): usado para inspeção em tempo de execução dos links principais da versão Cloud Message Queue Kafka. Ele realizará uma verificação abrangente e diagnóstico do cluster a cada minuto e pode emitir alarmes de status não íntegro. Ao mesmo tempo, um relatório geral de inspeção será emitido diariamente para o pessoal de operação e manutenção do Alibaba Cloud para facilitar o monitoramento do status de integridade do sistema da versão Cloud Message Queue Kafka.
Monitoramento e alarmes de negócios: Cada Grupo de Consumidores pode definir monitoramento e alarmes para o acúmulo de mensagens para ajudá-lo a encontrar problemas a tempo.
OpenAPI: a versão Cloud Message Queue Kafka fornece um conjunto completo de gerenciamento e controle OpenAPI para implementar uma série de funções de gerenciamento de recursos e operação e manutenção.
Ecossistema de dados rico
Fornece componentes de processamento de dados totalmente gerenciados e sem operação, suporta programação de funções flexível e processa dados de maneira fácil e flexível.
Conector de suporte para conectar produtos de nuvem massivos e produtos ecológicos de big data autoconstruídos para realizar facilmente integração e cálculo de dados.
Disponível em formato extra grande
Otimize profundamente o kernel para resolver o gargalo de desempenho das partições de mil níveis da versão de código aberto e suportar o desempenho de dez partições de mil níveis sem perdas.
Suporta expansão de segundo nível.
Suporta gravação de tráfego de até 2 GB.
Alta disponibilidade
A equipe de pesquisa e desenvolvimento de produtos de mensagens e otimização de desempenho do Alibaba Cloud otimizou ainda mais os pontos problemáticos dos produtos de código aberto para fornecer melhores serviços.
Persistência de dados: Uma equipe profissional garante maior disponibilidade e a persistência de mensagens é colocada na fila de mensagens. A confiabilidade dos dados é alta e a disponibilidade do serviço é alta.
Capacidade de alto rendimento: mesmo quando mensagens massivas se acumulam, ele sempre pode manter
Capacidades de alto rendimento do cluster da versão Cloud Message Queue Kafka.
Dezenas de milhares de tópicos: suporta alta leitura e escrita simultânea de dezenas de milhares de tópicos, sempre mantendo
Alta garantia de SLA
Suporta garantias de otimização de gravação em cenários extremos, como atualização em escala de cinza, atualização/dados frios, etc.
O sistema de inspeção e operação e manutenção totalmente automático garante uma disponibilidade de serviço de 99,9% e confiabilidade dos dados de 99,999999%.
Segurança de dados
Fornece funções como mecanismos de autenticação e autorização, descentralização de usuários e proteção de segurança em nível empresarial.
Gerenciamento de permissões: oferece suporte total a contas do Alibaba Cloud e usuários de RAM, listas negras e brancas, STS e outras funções, e realiza serviços de autorização para contas do Alibaba Cloud e usuários de RAM, bem como contas cruzadas entre empresas.
Segurança de acesso: Baseado no sistema de contas Alibaba Cloud, o mecanismo SASL é usado para autenticar identidades de usuários, e SSL é usado para criptografar o canal de transmissão para garantir que os dados não sejam roubados ou adulterados durante o processo de transmissão, garantindo a segurança de seus dados.
Alibaba Cloud VPC: Além do acesso à rede pública, a versão Cloud Message Queue Kafka também oferece suporte a VPC de rede privada. Você pode controlar totalmente sua própria rede privada, como selecionar intervalos de endereços IP, configurar tabelas de roteamento e gateways, etc. Você pode usar recursos do Alibaba Cloud, como servidores em nuvem, versões RDS de banco de dados em nuvem e balanceamento de carga em sua própria rede privada definida.
Otimização de mecanismo de código aberto
Comparado com o Apache Kafka de código aberto, o poderoso mecanismo de processamento suporta dezenas de milhares de tópicos com alta leitura e gravação simultânea, escalonamento de segundo nível e armazenamento em nuvem confiável, fornecendo uma escolha muito econômica e também fornece componentes de inspeção de saúde, negócios; funções de monitoramento e alarme, ajudando você a descobrir e lidar com problemas de maneira oportuna e eficaz.
Cenários de aplicação
Rastreamento de atividade do site
A versão Cloud Message Queue Kafka do modelo de publicação/assinatura permite coletar dados de atividade do site (como registro, login, recarga, pagamento, compra) em tempo real, publicar mensagens para diferentes tópicos de acordo com os tipos de dados de negócios e, em seguida, usar mensagens reais entrega em tempo real de mensagens de assinatura, use fluxo de mensagens para processamento em tempo real, monitoramento em tempo real ou carregue-o em sistemas de data warehouse offline, como Hadoop e MaxCompute para processamento offline.
A versão Cloud Message Queue Kafka tem as seguintes vantagens para rastreamento de atividades do site:
Alto rendimento: As informações comportamentais geradas pelos usuários do site são relativamente grandes e requerem alto rendimento para suportá-las.
Expansão elástica: a atividade do site leva a um aumento nos dados comportamentais e a plataforma em nuvem pode se expandir rapidamente sob demanda.
Análise de big data: pode ser conectado a mecanismos de processamento de dados em tempo real, como Storm e Spark, bem como a sistemas de data warehouse offline, como Hadoop.
Agregação de registros
A versão Cloud Message Queue Kafka pode obter maior persistência de dados e menor tempo de resposta ponta a ponta, ao mesmo tempo que apresenta alto desempenho. Essa característica do Cloud Message Queue Kafka o torna adequado como centro de coleta de logs. Cloud Message Queue Kafka Edition ignora os detalhes dos arquivos e pode abstrair os dados de log de vários hosts ou aplicativos em fluxos de mensagens de logs ou eventos e enviá-los de forma assíncrona para o cluster Cloud Message Queue Kafka Edition, alcançando assim um RT muito baixo. O cliente da versão Cloud Message Queue Kafka pode enviar mensagens em lotes e compactar mensagens, quase sem sobrecarga de desempenho para os produtores. Os consumidores podem usar armazenamento offline, como Hadoop e MaxCompute, e sistemas de análise online em tempo real, como Strom e Spark, para realizar análises estatísticas em logs.
A versão Cloud Message Queue Kafka tem as seguintes vantagens para agregação de dados:
Desacoplando aplicação e análise: Construa uma ponte entre o sistema de aplicação e o sistema de análise e desacople a associação entre eles.
Alta escalabilidade: Possui alta escalabilidade, ou seja, quando a quantidade de dados aumenta, pode ser rapidamente expandido horizontalmente adicionando nós.
Sistema de análise online ou offline: suporta sistema de análise online em tempo real e sistema de análise offline semelhante ao Hadoop.
processamento de dados
Em muitos campos, como análise de tendências do mercado de ações, medição e controle de dados meteorológicos e análise do comportamento do usuário de sites, devido à geração rápida, em tempo real e ao grande volume de dados, é difícil coletar esses dados de maneira unificada e armazená-los em um banco de dados para processamento. Como resultado, a arquitetura tradicional de processamento de dados não pode atender às necessidades. Ao contrário da arquitetura tradicional,
O surgimento da versão Kafka da fila de mensagens em nuvem e de mecanismos de processamento de dados como Storm, Samza e Spark visa resolver melhor os problemas encontrados no processamento desse tipo de dados. O modelo de processamento de dados pode realizar o processamento de dados durante o fluxo de dados. processe e processe em tempo real, execute cálculos e análises de acordo com os requisitos do negócio e, por fim, salve ou distribua os resultados nos componentes necessários.
A versão Cloud Message Queue Kafka tem as seguintes vantagens para processamento de dados:
Fluxo de dados: capture e processe dados em tempo real durante o fluxo de dados e execute cálculos e análises com base nas necessidades do negócio.
Alta escalabilidade: Devido à rápida velocidade de geração de dados e à grande quantidade de dados, é necessária alta escalabilidade.
Mecanismo de processamento de dados: pode ser conectado a Storm, Samza, Spark, EMR, Blink, StreamCompute e outros produtos Alibaba Cloud de código aberto.
Centro de transferência de dados
Nos últimos 10 anos, surgiram sistemas especiais como armazenamento KV (HBase), pesquisa (Elasticsearch), processamento de streaming (Storm, Spark, Samza) e bancos de dados de séries temporais (OpenTSDB). Esses sistemas foram criados com um único objetivo em mente e sua simplicidade torna mais fácil e econômico construir sistemas distribuídos em hardware comum. Freqüentemente, o mesmo conjunto de dados precisa ser injetado em vários sistemas especializados. Por exemplo, quando os logs do aplicativo são usados para análise de log offline, a pesquisa de registros de log individuais também é indispensável. Obviamente, é impraticável construir fluxos de trabalho independentes para coletar cada tipo de dados e depois importá-los para seus próprios sistemas dedicados. A versão fila Kafka serve como um hub de transferência de dados, e os mesmos dados podem ser importados para diferentes sistemas dedicados.
A versão Cloud Message Queue Kafka tem as seguintes vantagens como hub de transferência de dados:
Armazenamento de alta capacidade: Capaz de armazenar dados de alta capacidade em hardware comercial para obter um sistema distribuído horizontalmente escalável.
Modelo de consumo um para muitos: modelo de publicação/assinatura, que suporta o mesmo conjunto de dados para ser consumido várias vezes ao mesmo tempo.
Suporta processamento em tempo real e em lote: suporta persistência de dados locais e cache de página e pode transmitir mensagens simultaneamente para consumidores em tempo real e em lote sem perda de desempenho.
Fila de mensagens na nuvem RabbitMQ
Comparação de código aberto
Comparando o Cloud Message Queue RabbitMQ Edition e o RabbitMQ de código aberto em três aspectos: desempenho, estabilidade e funcionalidade, o Cloud Message Queue RabbitMQ Edition tem mais vantagens.
características do produto
Compatível com RabbitMQ de código aberto, fornece suporte completo de operação e manutenção e oferece suporte a vários tipos de mensagens.
Restrições de uso
Existem restrições para clusters, chamadas de interface e caracteres. Ao usar a versão Cloud Message Queuing RabbitMQ, tome cuidado para não exceder os limites correspondentes para evitar exceções do programa.
Vantagens do produto
Flexível e fácil de usar
Pronto para usar
Totalmente compatível com protocolos padrão, totalmente compatível com a comunidade de código aberto RabbitMQ e migrado rapidamente para a nuvem.
Serviço totalmente gerenciado
O serviço da versão Cloud Message Queue RabbitMQ é um serviço de mensagens em nuvem que não requer implantação, nem operação e manutenção. Contando com a equipe profissional de operação e manutenção automatizada da Alibaba Cloud, inspeções multidimensionais de links principais são realizadas em segundo e minuto nível, relatórios abrangentes de diagnóstico de saúde são fornecidos e alarmes e recuperação oportuna são executados para estados não saudáveis para garantir a disponibilidade do serviço e os negócios continuidade.
Alta disponibilidade
Forneça um SLA claro para garantir alta disponibilidade em diversas zonas de disponibilidade. Mesmo que toda a sala de computadores esteja indisponível, os serviços de mensagens ainda poderão ser fornecidos normalmente.
Implantação distribuída em cluster, os nós de serviço são sem estado e não possuem um ponto único. Mesmo que um único nó esteja indisponível, solicite Failover para outros nós para garantir o fornecimento normal de serviços de mensagens.
Aprimoramento de função
Mensagem atrasada
Suporta mensagens atrasadas, alcançando precisão de segundo nível e sem restrições de primeiro a entrar, primeiro a sair.
É simples e fácil de usar. Você só precisa definir um parâmetro no código para resolver os pontos problemáticos da fila sem atraso do RabbitMQ de código aberto.
Suporte de alta precisão, o mais curto pode ter precisão de segundo nível e o mais longo pode durar 1 dia.
Alto desempenho, o desempenho é consistente com mensagens comuns.
Múltiplas cópias de redundância de dados garantem a recuperação de mensagens.
nova tentativa de mensagem
Novas tentativas por um minuto, até 16 tentativas.
As mensagens que excedem o número máximo de novas tentativas entram na fila de mensagens não entregues. As mensagens não entregues podem ser consultadas e exportadas.
Troca de cartas mortas
O Exchange de mensagens mortas aprimorado não apenas oferece suporte a mensagens com respostas negativas, mas também suporta mensagens que não conseguem ser repetidas para entrar automaticamente no Exchange de mensagens mortas para garantir que as mensagens não sejam perdidas.
Superdesempenho
Limite superior de desempenho da plataforma
Suporta milhões de filas, a expansão horizontal traz crescimento linear no desempenho e não há limite de simultaneidade no desempenho.
Expansão de fila única
Resolva o gargalo de desempenho da fila única RabbitMQ, suporte a expansão horizontal da fila única e não tenha limite de simultaneidade no desempenho.
Escala elástica
Possui forte escalabilidade, aprimoramento de desempenho linear, expansão e contração elástica de acordo com as necessidades do negócio e é transparente para os usuários.
Acumulação massiva
No caso de acumulação massiva de mensagens, o alto desempenho é sempre mantido sem afetar os serviços normais do cluster.
Os produtores e consumidores de mensagens são isolados para atender à grande concorrência de produtores e ao consumo estável dos consumidores.
Seguro e confiável
Granularidade de permissão
Controle de permissão refinado para instâncias, Vhosts, Queues e Exchange, e controle de acesso de segurança para cada solicitação de mensagem.
Mestre e subcontas
Integração abrangente com contas mestre e subcontas do Alibaba Cloud RAM, listas negras e brancas, STS e outras funções.
Transmissão criptografada
Suporta protocolo de criptografia de transmissão TLS.
Cenários de aplicação
Desacoplamento assíncrono
Ele pode ser usado para comunicação entre diferentes microsserviços após um único aplicativo ser desmontado em microsserviços. O benefício do desacoplamento de aplicativos é que as iterações de diferentes aplicativos não dependem mais umas das outras, enquanto o benefício da comunicação assíncrona é que os dados não precisam mais ser processados imediatamente. O desacoplamento assíncrono pode efetivamente reduzir o comprimento do link de dados e melhorar a eficiência do processamento de dados.
Corte de pico e preenchimento de vale
Quando eventos em grande escala trazem altos pulsos de tráfego, a falha na proteção adequada pode facilmente levar à sobrecarga do sistema ou até mesmo a falhas. Restrições excessivas podem levar a um grande número de solicitações malsucedidas, afetando a experiência do usuário.
A versão Cloud Message Queue RabbitMQ pode cortar picos e preencher vales. Seus recursos de processamento de mensagens de alto desempenho podem lidar com pulsos de tráfego sem ficar sobrecarregados, garantindo a disponibilidade do sistema e melhorando a experiência do usuário por meio de uma tecnologia de resposta a solicitações rápida e eficaz. Sua enorme capacidade de acumulação de mensagens garante que os negócios downstream funcionem de maneira suave e estável dentro de um nível seguro e evita o impacto de picos de tráfego.
Sincronização de cache distribuído
Um grande número de acessos simultâneos ao banco de dados pode resultar em longos tempos de resposta da página. Um cache distribuído é construído por meio da versão Cloud Message Queue RabbitMQ para oferecer suporte à notificação em tempo real de alterações de dados, reduzindo efetivamente o tempo de resposta da página e atendendo a um grande número de requisitos de acesso para alterações.
Fila de mensagens na nuvem MQTT
É um middleware de mensagem leve lançado pela Alibaba Cloud para os campos de Internet móvel e Internet das Coisas. Se o middleware de fila de mensagens tradicional é geralmente usado entre microsserviços, então a versão MQTT do Cloud Message Queue adequada para a Internet das Coisas realiza a passagem de mensagens entre o fim e a nuvem e a verdadeira interconexão de tudo. Este artigo apresenta o modelo de envio e recebimento de mensagens, vantagens do produto e cenários de aplicação da versão Cloud Message Queue MQTT.
Ideia central
Tema
: tópico da mensagem, tipo de mensagem de primeiro nível, para o qual o produtor envia mensagens.
produtor
: Também conhecido como editor de mensagens, responsável por produzir e enviar mensagens ao Tópico.
consumidor
: Também chamado de assinante de mensagem, responsável por receber e consumir mensagens do Tópico.
Informação
: Os dados enviados pelo produtor ao Tópico e finalmente transmitidos ao consumidor.
regra
A versão Cloud Message Queue MQTT é um recurso que permite a interoperabilidade de dados com outros produtos Alibaba Cloud.
Modelo de mensagens
Inclui principalmente os dois modelos de envio e recebimento de mensagens a seguir:
Modelo de interação de terminal e serviço em nuvem
A versão Cloud Message Queue MQTT conecta o terminal e a nuvem para obter comunicação bidirecional entre o dispositivo e a nuvem. O dispositivo pode se comunicar diretamente com aplicativos de negócios em nuvem por meio da versão Cloud Message Queue MQTT e também pode obter interoperabilidade entre produtos de dados de mensagens com outros produtos Alibaba Cloud.
Cenários de aplicação típicos deste modelo são relatórios de dados de status de dispositivos inteligentes ou emissão de instruções para aplicações de controle em nuvem.
Modelo de interação terminal e terminal
Este modelo é adequado para comunicação de dados entre aplicativos ou dispositivos móveis. Os cenários típicos são dois usuários conversando diretamente por mensagens no cenário de comunicação IM e o aplicativo controlando dispositivos inteligentes no cenário de dispositivo inteligente. Neste modelo, os produtores e consumidores de mensagens são distribuídos em dispositivos terminais e conectados ao produto da versão MQTT da fila de mensagens em nuvem por meio do protocolo MQTT.
Com base nos dois modelos de envio e recebimento de mensagens acima, os desenvolvedores que usam a versão Cloud Message Queue MQTT podem ser divididos em duas categorias: terminal e nuvem.
Vantagens do produto
Migração perfeita
Compatível com qualquer SDK que suporte o protocolo MQTT 3.1.1, suporte ao protocolo WebSocket e cubra a maioria das plataformas e linguagens de desenvolvimento móvel.
alta performance
Ele suporta conexões on-line de dezenas de milhões de dispositivos, milhões de mensagens simultâneas, trilhões de transferências e design de arquitetura distribuída em nível de milissegundos, sem gargalos de ponto único e expansão horizontal ilimitada entre componentes;
Seguro e confiável
Suporta controle de permissão em nível de dispositivo, serviço de token temporário e protocolo de transmissão segura versão TLS 1.2 para garantir que os dados do usuário sejam seguros e confiáveis.
Interoperabilidade natural
A troca de mensagens entre a versão Cloud Message Queue MQTT e a versão Cloud Message Queue RocketMQ permite a comunicação bidirecional entre o dispositivo e a nuvem, tornando-a mais eficiente e confiável.
Cenários de aplicação
Possui recursos de suporte multiprotocolo, multilíngue e multiplataforma, e é amplamente utilizado nas áreas de Internet móvel e Internet das Coisas, cobrindo uma variedade de cenários de aplicação, como transmissão móvel ao vivo, Internet de Veículos, pagamento financeiro, catering inteligente e bate-papo instantâneo.
Serviço de mensagens MNS
Serviço de Mensagens MNS (Message Service) é um serviço de mensagens distribuídas eficiente, confiável, seguro, conveniente e elasticamente escalonável. O serviço de mensagens MNS pode ajudar os desenvolvedores a transferir livremente dados e mensagens de notificação entre componentes distribuídos do aplicativo, construindo assim um sistema fracamente acoplado. O serviço de mensagens MNS suporta modelo de fila e modelo de tópico.
modelo de fila
O modelo de fila fornece um modelo de consumo um para um de alta confiabilidade e alta simultaneidade, ou seja, cada mensagem na fila só pode ser consumida por um determinado consumidor.
A fila é como um restaurante giratório de sushi. Existem vários chefs de sushi (produtores) no restaurante de sushi fazendo sushi requintado. Cada pedaço de sushi é único. Os clientes (consumidores) podem retirar o sushi que desejarem da esteira para consumo.
Vantagens do produto
Simples e fácil de usar
Nenhuma operação e manutenção são necessárias, não há necessidade de criar você mesmo um serviço de mensagens.
Fácil acesso, interface HTTP RESTful padrão.
Suporte a vários idiomas SDK, incluindo C, Java, C#, Python, PHP, Go, etc., e continua a ser enriquecido.
Estável e confiável
Três cópias da mensagem, alta confiabilidade.
Alta disponibilidade de serviço.
Mecanismo exclusivo garante sempre gravável.
Segurança
Proteção de segurança multinível e prevenção de ataques DDoS.
Mecanismo de isolamento multiusuário, cada usuário é equipado com um namespace independente.
Suporta a concessão de diferentes permissões de acesso a diferentes usuários de RAM.
Suporta acesso HTTPS e VPC.
Desempenho em grande escala e alta escalabilidade
O número de filas e a capacidade de armazenamento de filas são altamente escalonáveis.
A escala de serviço é automaticamente ampliada e transparente para os usuários.
Fornece serviços em várias regiões ao redor do mundo.
Rápido e estável
Rápido e direto, leva apenas 3 segundos para se conectar aos usuários.
Canal exclusivo Triple Play.
A sala de informática de linha dedicada suporta grande capacidade e alta simultaneidade.
A taxa de chegada é elevada e está conectado à plataforma de portabilidade numérica do Ministério da Indústria e Tecnologia da Informação em tempo real.
Garantia de operação e manutenção de nível de operadora, monitoramento em tempo real e comutação automática.
Serviço técnico íntimo
Enriquecer continuamente a partilha de casos de melhores práticas.
Suporte para ordens de serviço 24 horas por dia, 7 dias por semana.
Suporte personalizável no local disponível.