Wondershare EdrawMind
Galleria mappe mentale Coda di messaggi Alibaba Cloud
- 9
Coda di messaggi Alibaba Cloud
Un riepilogo dettagliato di Alibaba Cloud Message Queue RocketMQ, Cloud Message Queue RocketMQ, Cloud Message Queue RabbitMQ, Cloud Message Queue Kafka e Cloud Message Queue MQTT.
Modificato alle 2024-01-20 09:44:44
- Breve storia del tempo
Questa è una mappa mentale su una breve storia del tempo. "Una breve storia del tempo" è un'opera scientifica popolare con un'influenza di vasta portata. Non solo introduce i concetti di base della cosmologia e della relatività, ma discute anche dei buchi neri e dell'espansione dell'universo. questioni scientifiche all’avanguardia come l’inflazione e la teoria delle stringhe.
- Il coraggio di essere odiato
Dopo aver letto "Il coraggio di essere antipatico", "Il coraggio di essere antipatico" è un libro filosofico che vale la pena leggere. Può aiutare le persone a comprendere meglio se stesse, a comprendere gli altri e a trovare modi per ottenere la vera felicità.
- Appunti di lettura di Il coraggio di non piacere.
"Il coraggio di essere antipatico" non solo analizza le cause profonde di vari problemi nella vita, ma fornisce anche contromisure corrispondenti per aiutare i lettori a comprendere meglio se stessi e le relazioni interpersonali e come applicare la teoria psicologica di Adler nella vita quotidiana.
Coda di messaggi Alibaba Cloud
- Breve storia del tempo
Questa è una mappa mentale su una breve storia del tempo. "Una breve storia del tempo" è un'opera scientifica popolare con un'influenza di vasta portata. Non solo introduce i concetti di base della cosmologia e della relatività, ma discute anche dei buchi neri e dell'espansione dell'universo. questioni scientifiche all’avanguardia come l’inflazione e la teoria delle stringhe.
- Il coraggio di essere odiato
Dopo aver letto "Il coraggio di essere antipatico", "Il coraggio di essere antipatico" è un libro filosofico che vale la pena leggere. Può aiutare le persone a comprendere meglio se stesse, a comprendere gli altri e a trovare modi per ottenere la vera felicità.
- Appunti di lettura di Il coraggio di non piacere.
"Il coraggio di essere antipatico" non solo analizza le cause profonde di vari problemi nella vita, ma fornisce anche contromisure corrispondenti per aiutare i lettori a comprendere meglio se stessi e le relazioni interpersonali e come applicare la teoria psicologica di Adler nella vita quotidiana.
- Consigliato per te
- Profilo
Coda di messaggi Alibaba Cloud
Coda di messaggi cloud RocketMQ
Posizionamento del prodotto
La versione Cloud Message Queue RocketMQ è un tipico prodotto middleware con un'architettura distribuita, che utilizza la comunicazione asincrona e un modello di trasmissione dei messaggi di pubblicazione-sottoscrizione.
Il prodotto presenta i vantaggi della comunicazione asincrona, della semplice topologia del sistema e dell'accoppiamento debole a monte e a valle. Viene utilizzato principalmente in scenari di disaccoppiamento asincrono, riduzione dei picchi di traffico e riempimento delle valli.
Per i collegamenti sincroni, negli scenari in cui i risultati delle chiamate devono essere restituiti in tempo reale, si consiglia di utilizzare la soluzione di chiamata RPC.
Modello di dominio della versione RocketMQ della coda di messaggi
Come mostrato nella figura, il ciclo di vita dei messaggi nella versione Cloud Message Queue RocketMQ è principalmente suddiviso in tre parti: produzione dei messaggi, archiviazione dei messaggi e consumo dei messaggi.
produzione di messaggi
Il produttore è un'entità in esecuzione utilizzata per generare messaggi nella versione Cloud Message Queue RocketMQ. È generalmente integrato a monte del collegamento della chiamata aziendale. I produttori sono leggeri, anonimi e senza identità.
Archiviazione dei messaggi
Argomento: un contenitore di raggruppamento per la trasmissione e l'archiviazione dei messaggi in Cloud Message Queue RocketMQ L'argomento è composto internamente da più code L'archiviazione e l'espansione orizzontale dei messaggi vengono effettivamente implementate tramite code all'interno dell'argomento.
Coda (MessageQueue): l'effettivo contenitore di unità per la trasmissione e l'archiviazione dei messaggi in RocketMQ Cloud Message Queue, che è analogo alle partizioni in Kafka. Coda di messaggi cloud RocketMQ utilizza una struttura di coda infinita con caratteristiche di streaming per archiviare i messaggi e i messaggi hanno caratteristiche di archiviazione sequenziali nella coda.
Messaggio: l'unità di trasmissione più piccola della versione RocketMQ di Cloud Message Queue. I messaggi sono immutabili e diventano immutabili dopo l'invio iniziale e il completamento dell'archiviazione.
Consumo di messaggi
ConsumerGroup: un gruppo di identità del consumatore indipendente definito nel modello di pubblicazione-sottoscrizione di Cloud Message Queue RocketMQ, utilizzato per gestire in modo uniforme più consumatori (Consumatori) in esecuzione in basso. Più consumatori dello stesso gruppo di consumatori devono mantenere coerenti la propria logica e configurazione di consumo e condividere congiuntamente i messaggi sottoscritti dal gruppo di consumatori per ottenere un’espansione orizzontale delle capacità di consumo.
Consumatore: l'entità in esecuzione della versione RocketMQ di Cloud Message Queue che consuma i messaggi. È generalmente integrata a valle del collegamento della chiamata aziendale. I consumatori devono essere assegnati a un gruppo di consumatori.
Sottoscrizione: configurazione delle regole per il filtraggio dei messaggi, i nuovi tentativi e l'avanzamento del consumo nel modello di pubblicazione e sottoscrizione di Cloud Message Queue RocketMQ. Le relazioni di sottoscrizione vengono gestite con la granularità dei gruppi di consumatori Definendo le relazioni di sottoscrizione, i gruppi di consumatori controllano il modo in cui i consumatori del gruppo di consumatori specificato implementano il filtraggio dei messaggi, i nuovi tentativi di consumo, il ripristino dell'avanzamento del consumo, ecc.
Introduzione ai metodi di comunicazione
Secondo l’idea dell’architettura di sistema distribuito, i sistemi complessi sono suddivisi in più sottomoduli indipendenti, come i moduli di microservizi. A questo punto, è necessario considerare la comunicazione remota tra i sottomoduli. Le modalità di comunicazione tipiche sono suddivise nei due tipi seguenti, una è la chiamata remota RPC sincrona; l'altro è il metodo di comunicazione asincrono basato sull'agente middleware.
Modello di chiamata RPC sincrona
Nel modello di chiamata RPC sincrona, la comunicazione della chiamata viene condotta direttamente tra diversi sistemi. Ogni richiesta viene inviata direttamente dal chiamante al chiamato, quindi il chiamato è tenuto a restituire immediatamente il risultato della risposta al chiamante per determinare se il risultato della chiamata è corretto. riuscito.
Modello di comunicazione asincrona
Nella modalità di comunicazione del messaggio asincrono, i sottosistemi sono collegati direttamente senza accoppiamento forte. Il chiamante deve solo convertire la richiesta in un evento asincrono (messaggio) e inviarlo all'agente intermedio. Se la trasmissione ha esito positivo, la chiamata al collegamento asincrono lo è considerato completato e il restante L'agente intermedio funzionante sarà responsabile di notificare in modo affidabile l'evento al sistema chiamante a valle per garantire che l'esecuzione dell'attività sia completata. L'agente intermedio è generalmente un middleware di messaggi.
I vantaggi della comunicazione asincrona sono i seguenti:
La topologia del sistema è semplice
Poiché il chiamante e il chiamato comunicano con l'agente intermedio in modo unificato, il sistema ha una struttura a stella ed è facile da mantenere e gestire.
Debole accoppiamento a monte e a valle
I sistemi a monte e a valle sono debolmente accoppiati, la struttura è più flessibile e l’agente intermedio è responsabile del buffering e del recupero asincrono. I sistemi a monte e a valle possono essere aggiornati e modificati in modo indipendente senza influenzarsi a vicenda.
Rasatura dei picchi di capacità e riempimento delle valli
I proxy intermedi basati su messaggi spesso hanno forti capacità di buffering e modellamento del traffico, quindi non sovraccaricheranno il downstream quando arrivano i picchi di traffico aziendale.
Introduzione al modello di trasmissione dei messaggi
I principali modelli di trasmissione del middleware dei messaggi sono principalmente il modello punto-punto e il modello pubblicazione-sottoscrizione.
modello peer-to-peer
Il modello punto-punto è anche chiamato modello a coda e presenta le seguenti caratteristiche:
Anonimato del consumo: l'unica identità per la comunicazione dei messaggi upstream e downstream è la coda I consumatori downstream non possono dichiarare identità indipendenti quando ottengono messaggi dalla coda.
Comunicazione uno a uno: in base alle caratteristiche dell'anonimato del consumo, anche se sono presenti più consumatori a valle, non hanno identità indipendenti, pertanto ogni messaggio nella coda condivisa verrà elaborato da un solo consumatore. Pertanto, il modello punto a punto può raggiungere solo la comunicazione uno a uno.
modello di pubblicazione-sottoscrizione
Il modello di pubblicazione-sottoscrizione ha le seguenti caratteristiche:
Indipendenza del consumo: rispetto al metodo di consumo anonimo del modello a coda, tutti i consumatori nel modello pubblicazione-sottoscrizione hanno un'identità, generalmente chiamata gruppo di abbonamento (relazione di abbonamento diversi sono indipendenti l'uno dall'altro e non influiscono). l'un l'altro.
Comunicazione uno-a-molti: in base alla progettazione dell'identità indipendente, i messaggi all'interno dello stesso argomento possono essere elaborati da più gruppi di sottoscrizione e ciascun gruppo di sottoscrizione può ricevere l'intero numero di messaggi. Pertanto, il modello pubblicazione-sottoscrizione può ottenere una comunicazione uno-a-molti.
Confronto dei modelli di trasmissione
Il modello punto a punto e il modello pubblicazione-sottoscrizione presentano ciascuno i propri vantaggi. Il modello punto a punto è più semplice, mentre il modello pubblicazione-sottoscrizione è più scalabile.
Il modello di trasmissione utilizzato da Cloud Message Queue RocketMQ è un modello di pubblicazione-sottoscrizione, quindi ha anche le caratteristiche di un modello di pubblicazione-sottoscrizione.
Coda di messaggi cloud Kafka
Vantaggi del prodotto
Fornisci servizi completamente gestiti per Apache Kafka open source per risolvere i punti critici dei prodotti open source. Con la versione Cloud Message Queue Kafka, devi concentrarti solo sullo sviluppo del business senza distribuzione, funzionamento e manutenzione. Rispetto ad Apache Kafka open source, la versione Cloud Message Queue Kafka è più economica, più elastica e più affidabile.
Ecologia delle applicazioni
Ha un ricco ecosistema di applicazioni, che comprende principalmente i seguenti aspetti:
Campo dei big data: analisi del comportamento del sito web, aggregazione dei log, monitoraggio delle applicazioni, elaborazione dei dati in streaming, analisi dei dati online e offline e altri campi.
Integrazione dei dati: importa messaggi in data warehouse offline come MaxCompute, OSS, RDS, Hadoop e HBase.
Integrazione dell'elaborazione dei dati: integrazione con StreamCompute, E-MapReduce, Spark, Storm e altri motori.
Architettura del prodotto
Versione Kafka di Cloud Message Queue
struttura del sistema
Produttore
Invia messaggi a Kafka Broker della versione Kafka di Cloud Message Queue tramite la modalità push. I messaggi inviati possono essere visite a pagine di siti Web, registri del server o informazioni sulle risorse di sistema relative alla CPU e alla memoria.
Kafka Broker
Il server utilizzato per archiviare i messaggi. Kafka Broker supporta l'espansione orizzontale. Maggiore è il numero di nodi Kafka Broker, maggiore sarà la velocità effettiva del cluster Kafka Cloud Message Queue.
Gruppo
Sottoscrivi e consuma messaggi dal Broker versione Cloud Message Queue Kafka tramite la modalità pull.
Guardiano dello zoo
Gestisci la configurazione del cluster, eleggi le partizioni leader ed esegui il bilanciamento del carico quando il gruppo cambia.
Versione Kafka di Cloud Message Queue
Il modello di pubblicazione/sottoscrizione della versione Kafka di Cloud Message Queue
La relazione corrispondente tra Gruppo e Argomento è N:N, ovvero un Gruppo può sottoscrivere più Argomenti contemporaneamente e un Argomento può anche essere sottoscritto da più Gruppi contemporaneamente.
Sebbene un argomento possa essere sottoscritto da più gruppi contemporaneamente, i messaggi dell'argomento possono essere utilizzati solo da qualsiasi consumatore nello stesso gruppo.
Vantaggi del prodotto
Pronto fuori dalla scatola
Compatibile con l'open source:
Cloud Message Queue Kafka Edition è compatibile al 100% con Apache Kafka open source. Puoi utilizzare direttamente il client Apache Kafka open source per comunicare con Cloud Message Queue Kafka Edition. La versione Kafka di Cloud Message Queue supporta attualmente le versioni open source 0.10.x~2.6.x.
Migrazione senza interruzioni:
La versione Cloud Message Queue Kafka si basa sull'ecosistema Apache Kafka open source esistente ed è possibile migrare nel cloud senza alcuna modifica del codice.
Nessun funzionamento e manutenzione, facile da osservare
HouseKeeping (componente di ispezione dell'integrità): utilizzato per l'ispezione in fase di esecuzione dei collegamenti principali della versione Kafka di Cloud Message Queue. Eseguirà una scansione e una diagnosi complete del cluster ogni minuto e può emettere allarmi per lo stato non integro. Allo stesso tempo, ogni giorno verrà rilasciato un rapporto di ispezione generale al personale operativo e di manutenzione di Alibaba Cloud per facilitare il monitoraggio dello stato di salute del sistema della versione Kafka di Cloud Message Queue.
Monitoraggio e allarmi aziendali: ciascun gruppo di consumatori può impostare il monitoraggio e gli allarmi per l'accumulo di messaggi per aiutarti a trovare i problemi in tempo.
OpenAPI: la versione Cloud Message Queue Kafka fornisce un set completo di gestione e controllo OpenAPI per implementare una serie di funzioni di gestione delle risorse e di funzionamento e manutenzione.
Ricco ecosistema di dati
Fornisce componenti di elaborazione dati completamente gestiti e senza operazioni, supporta la programmazione flessibile delle funzioni ed elabora i dati in modo semplice e flessibile.
Supporta il connettore per connettere enormi prodotti cloud e prodotti ecologici per big data autocostruiti per realizzare facilmente l'integrazione e il calcolo dei dati.
Disponibile nel formato extra large
Ottimizza profondamente il kernel per risolvere il collo di bottiglia delle prestazioni delle partizioni a mille livelli della versione open source e supportare le prestazioni delle partizioni a diecimila livelli senza perdite.
Supporta l'espansione di secondo livello.
Supporta la scrittura di traffico fino a 2 GB.
Alta disponibilità
Il team di ricerca e sviluppo dei prodotti di messaggistica e di ottimizzazione delle prestazioni di Alibaba Cloud ha ulteriormente ottimizzato i punti critici dei prodotti open source per fornirti servizi migliori.
Persistenza dei dati: un team di professionisti garantisce una maggiore disponibilità e la persistenza dei messaggi viene inserita nella coda dei messaggi. L'affidabilità dei dati è elevata e la disponibilità del servizio è elevata.
Capacità di throughput elevata: anche quando si accumulano messaggi di grandi dimensioni, è sempre possibile mantenerli
Funzionalità di velocità effettiva elevata del cluster della versione Kafka di Cloud Message Queue.
Decine di migliaia di argomenti: supporta la lettura e la scrittura simultanea di decine di migliaia di argomenti, mantenendoli sempre aggiornati
Garanzia SLA elevata
Supporta garanzie di ottimizzazione della scrittura in scenari estremi come aggiornamento in scala di grigi, aggiornamento/dati freddi, ecc.
Il sistema completamente automatico di ispezione, funzionamento e manutenzione garantisce una disponibilità del servizio del 99,9% e un'affidabilità dei dati del 99,999999%.
La sicurezza dei dati
Fornisce funzioni come meccanismi di autenticazione e autorizzazione, decentralizzazione degli utenti e protezione della sicurezza a livello aziendale.
Gestione delle autorizzazioni: supporta completamente account Alibaba Cloud e utenti RAM, liste nere e bianche, STS e altre funzioni e realizza servizi di autorizzazione per account Alibaba Cloud e utenti RAM, nonché account incrociati tra imprese.
Sicurezza di accesso: basato sul sistema di account Alibaba Cloud, il meccanismo SASL viene utilizzato per autenticare le identità degli utenti e SSL viene utilizzato per crittografare il canale di trasmissione per garantire che i dati non vengano rubati o manomessi durante il processo di trasmissione, garantendo la sicurezza di i tuoi dati.
Alibaba Cloud VPC: oltre all'accesso alla rete pubblica, la versione Kafka di Cloud Message Queue supporta anche la rete privata VPC. Puoi controllare completamente la tua rete privata, ad esempio selezionando intervalli di indirizzi IP, configurando tabelle di routing e gateway, ecc. Puoi utilizzare le risorse Alibaba Cloud come server cloud, versioni RDS del database cloud e bilanciamento del carico nella tua rete privata definita.
Ottimizzazione del motore open source
Rispetto all'open source Apache Kafka, il potente motore di elaborazione supporta decine di migliaia di argomenti con elevata lettura e scrittura simultanea, scalabilità di secondo livello e archiviazione cloud affidabile, fornendo una scelta molto conveniente e fornendo anche componenti di ispezione sanitaria, aziendali funzioni di monitoraggio e allarme, aiutandoti a scoprire e affrontare i problemi in modo tempestivo ed efficace.
Scenari applicativi
Monitoraggio dell'attività del sito web
La versione Cloud Message Queue Kafka del modello di pubblicazione/iscrizione consente di raccogliere dati sull'attività del sito Web (come registrazione, accesso, ricarica, pagamento, acquisto) in tempo reale, pubblicare messaggi su argomenti diversi in base ai tipi di dati aziendali e quindi utilizzare dati reali consegna in tempo reale dei messaggi di sottoscrizione, utilizzare il flusso di messaggi per l'elaborazione in tempo reale, il monitoraggio in tempo reale o caricarlo su sistemi di data warehouse offline come Hadoop e MaxCompute per l'elaborazione offline.
La versione Kafka di Cloud Message Queue presenta i seguenti vantaggi per il monitoraggio delle attività del sito Web:
Throughput elevato: le informazioni comportamentali generate dagli utenti del sito Web sono relativamente grandi e richiedono un throughput elevato per supportarle.
Espansione elastica: l’attività del sito web porta a un aumento dei dati comportamentali e la piattaforma cloud può espandersi rapidamente su richiesta.
Analisi dei big data: può essere collegato a motori di elaborazione dati in tempo reale come Storm e Spark, nonché a sistemi di data warehouse offline come Hadoop.
Aggregazione dei registri
La versione Kafka di Cloud Message Queue può ottenere una maggiore persistenza dei dati e tempi di risposta end-to-end più brevi pur garantendo prestazioni elevate. Questa caratteristica di Cloud Message Queue Kafka lo rende adatto come centro di raccolta log. Cloud Message Queue Kafka Edition ignora i dettagli dei file e può astrarre i dati di registro di più host o applicazioni in flussi di messaggi di log o eventi e inviarli in modo asincrono al cluster Cloud Message Queue Kafka Edition, ottenendo così un RT molto basso. Il client della versione Kafka di Cloud Message Queue può inviare messaggi in batch e comprimerli, quasi senza alcun sovraccarico in termini di prestazioni per i produttori. I consumatori possono utilizzare sistemi di archiviazione di magazzino offline come Hadoop e MaxCompute e sistemi di analisi online in tempo reale come Strom e Spark per eseguire analisi statistiche sui log.
La versione Kafka di Cloud Message Queue presenta i seguenti vantaggi per l'aggregazione dei dati:
Disaccoppiamento di applicazione e analisi: costruisce un ponte tra il sistema applicativo e il sistema di analisi e disaccoppia l'associazione tra loro.
Elevata scalabilità: ha un'elevata scalabilità, ovvero quando la quantità di dati aumenta, può essere rapidamente espanso orizzontalmente aggiungendo nodi.
Sistema di analisi online o offline: supporta il sistema di analisi online in tempo reale e il sistema di analisi offline simile a Hadoop.
elaborazione dati
In molti campi, come l'analisi dell'andamento del mercato azionario, la misurazione e il controllo dei dati meteorologici e l'analisi del comportamento degli utenti dei siti Web, a causa della generazione di dati rapida, in tempo reale e di grandi volumi, è difficile raccogliere questi dati in modo unificato e memorizzarli in un database per l'elaborazione. Di conseguenza, l'architettura tradizionale di elaborazione dei dati non può soddisfare le esigenze. A differenza dell’architettura tradizionale,
L'emergere della versione Kafka della coda di messaggi cloud e di motori di elaborazione dati come Storm, Samza e Spark mira a risolvere meglio i problemi incontrati nell'elaborazione di questo tipo di dati. Il modello di elaborazione dei dati può realizzare l'elaborazione dei dati durante il flusso di dati processo. Acquisire ed elaborare in tempo reale, eseguire calcoli e analisi in base ai requisiti aziendali e infine salvare o distribuire i risultati ai componenti richiesti.
La versione Kafka di Cloud Message Queue presenta i seguenti vantaggi per l'elaborazione dei dati:
Flusso di dati: acquisisci ed elabora i dati in tempo reale durante il flusso di dati ed esegui calcoli e analisi in base alle esigenze aziendali.
Elevata scalabilità: a causa dell'elevata velocità di generazione dei dati e della grande quantità di dati, è richiesta un'elevata scalabilità.
Motore di elaborazione dati: può essere collegato a Storm, Samza, Spark, EMR, Blink, StreamCompute e altri prodotti Alibaba Cloud open source.
Hub di trasferimento dati
Negli ultimi 10 anni circa sono emersi sistemi speciali come l'archiviazione KV (HBase), la ricerca (Elasticsearch), l'elaborazione di streaming (Storm, Spark, Samza) e i database di serie temporali (OpenTSDB). Questi sistemi sono stati creati con un unico obiettivo in mente e la loro semplicità rende più semplice ed economica la realizzazione di sistemi distribuiti su hardware di base. Spesso, lo stesso set di dati deve essere inserito in più sistemi specializzati. Ad esempio, quando i registri delle applicazioni vengono utilizzati per l'analisi dei registri offline, è indispensabile anche la ricerca di singoli record di registro. È ovviamente poco pratico creare flussi di lavoro indipendenti per raccogliere ciascun tipo di dati e quindi importarli nei propri sistemi dedicati La versione Kafka della coda funge da hub di trasferimento dati e gli stessi dati possono essere importati in diversi sistemi dedicati.
La versione Kafka di Cloud Message Queue presenta i seguenti vantaggi come hub di trasferimento dati:
Archiviazione ad alta capacità: in grado di archiviare dati ad alta capacità su hardware commerciale per ottenere un sistema distribuito scalabile orizzontalmente.
Modello di consumo uno-a-molti: modello di pubblicazione/sottoscrizione, che supporta il consumo dello stesso set di dati più volte contemporaneamente.
Supporta sia l'elaborazione in tempo reale che batch: supporta la persistenza dei dati locali e la cache delle pagine e può trasmettere simultaneamente messaggi a consumatori in tempo reale e batch senza perdita di prestazioni.
Coda di messaggi cloud RabbitMQ
Confronto open source
Confrontando Cloud Message Queue RabbitMQ Edition e RabbitMQ open source sotto tre aspetti: prestazioni, stabilità e funzionalità, Cloud Message Queue RabbitMQ Edition presenta più vantaggi.
caratteristiche del prodotto
Compatibile con RabbitMQ open source, fornisce supporto completo per il funzionamento e la manutenzione e supporta più tipi di messaggi.
Restrizioni d'uso
Sono previste restrizioni su cluster, chiamate di interfaccia e caratteri. Quando si utilizza la versione RabbitMQ di Cloud Message Queuing, fare attenzione a non superare i limiti corrispondenti per evitare eccezioni del programma.
Vantaggi del prodotto
Flessibile e facile da usare
Pronto fuori dalla scatola
Pienamente compatibile con i protocolli standard, pienamente compatibile con la comunità open source RabbitMQ e migrato rapidamente nel cloud.
Servizio completamente gestito
Il servizio versione Cloud Message Queue RabbitMQ è un servizio di messaggistica cloud che non richiede implementazione, funzionamento e manutenzione. Facendo affidamento sul team professionale automatizzato di operazioni e manutenzione di Alibaba Cloud, vengono eseguite ispezioni multidimensionali dei collegamenti principali al secondo e minuto livello, vengono forniti report completi di diagnosi sanitaria e vengono eseguiti allarmi e ripristini tempestivi per stati non integri per garantire la disponibilità del servizio e l'attività continuità.
Alta disponibilità
Fornire uno SLA chiaro per garantire un'elevata disponibilità in più zone di disponibilità Anche se l'intera sala computer non è disponibile, i servizi di messaggistica possono comunque essere forniti normalmente.
Distribuzione distribuita in cluster, i nodi di servizio sono senza stato e non hanno un singolo punto. Anche se un singolo nodo non è disponibile, richiedere il Failover ad altri nodi per garantire la normale fornitura dei servizi di messaggistica.
Miglioramento delle funzioni
Messaggio ritardato
Supporta messaggi ritardati, ottenendo una precisione di secondo livello e nessuna restrizione first-in, first-out.
È semplice e facile da usare. Devi solo impostare un parametro nel codice per risolvere i punti critici della coda senza ritardo RabbitMQ open source.
Supporto ad alta precisione, il più breve può essere accurato fino al secondo livello e il più lungo può durare 1 giorno.
Alte prestazioni, le prestazioni sono coerenti con i messaggi ordinari.
Copie multiple di ridondanza dei dati garantiscono il recupero dei messaggi.
riprovare il messaggio
Tentativi per un minuto, fino a 16 tentativi.
I messaggi che superano il numero massimo di tentativi entrano nella coda dei messaggi non recapitati possono essere interrogati ed esportati.
Scambio di lettere morte
Lo scambio messaggi non recapitabili avanzato non solo supporta i messaggi con risposte negative, ma supporta anche i messaggi che non riescono a essere ritentati per entrare automaticamente nello scambio messaggi non recapitabili per garantire che i messaggi non vadano persi.
Prestazioni eccellenti
Limite superiore delle prestazioni della piattaforma
Supporta milioni di code, l'espansione orizzontale comporta una crescita lineare delle prestazioni e non esiste alcun limite di concorrenza sulle prestazioni.
Espansione a coda singola
Risolvi il collo di bottiglia delle prestazioni della coda singola RabbitMQ, supporta l'espansione orizzontale della coda singola e non hai limiti di concorrenza sulle prestazioni.
Scalatura elastica
Ha una forte scalabilità, miglioramento lineare delle prestazioni, espansione e contrazione elastica in base alle esigenze aziendali ed è trasparente per gli utenti.
Accumulo massiccio
In caso di accumulo massiccio di messaggi vengono sempre mantenute prestazioni elevate senza incidere sui normali servizi del cluster.
I produttori e i consumatori di messaggi sono isolati per soddisfare la grande concorrenza dei produttori e il consumo stabile da parte dei consumatori.
Sicuro e affidabile
Granularità dei permessi
Controllo capillare delle autorizzazioni per istanze, Vhost, code ed Exchange e controllo dell'accesso di sicurezza per ogni richiesta di messaggio.
Conti principali e secondari
Integrazione completa con master e account secondari RAM di Alibaba Cloud, liste nere e bianche, STS e altre funzioni.
Trasmissione crittografata
Supporta il protocollo di crittografia della trasmissione TLS.
Scenari applicativi
Disaccoppiamento asincrono
Può essere utilizzato per la comunicazione tra diversi microservizi dopo che una singola applicazione è stata disassemblata in microservizi. Il vantaggio del disaccoppiamento delle applicazioni è che le iterazioni di diverse applicazioni non dipendono più l'una dall'altra, mentre il vantaggio della comunicazione asincrona è che i dati non devono più essere elaborati immediatamente. Il disaccoppiamento asincrono può ridurre efficacemente la lunghezza del collegamento dati e migliorare l'efficienza dell'elaborazione dei dati.
Rasatura del picco e riempimento della valle
Quando eventi su larga scala portano impulsi di traffico elevati, la mancata protezione di conseguenza può facilmente portare al sovraccarico del sistema o addirittura al blocco. Restrizioni eccessive possono portare a un gran numero di richieste non riuscite, influenzando l'esperienza dell'utente.
La versione RabbitMQ di Cloud Message Queue può tagliare i picchi e riempire le valli. Le sue capacità di elaborazione dei messaggi ad alte prestazioni sono in grado di gestire gli impulsi del traffico senza essere sopraffatti, garantendo la disponibilità del sistema e migliorando al tempo stesso l'esperienza dell'utente attraverso una tecnologia di risposta alle richieste rapida ed efficace. La sua massiccia capacità di accumulo di messaggi garantisce che le attività a valle funzionino in modo fluido e stabile entro un livello sicuro ed evitino l'impatto dei picchi di traffico.
Sincronizzazione della cache distribuita
Un numero elevato di accessi simultanei al database può comportare tempi di risposta della pagina lunghi. Una cache distribuita è creata attraverso la versione Cloud Message Queue RabbitMQ per supportare la notifica in tempo reale delle modifiche ai dati, riducendo efficacemente i tempi di risposta della pagina e soddisfacendo un gran numero di requisiti di accesso per le modifiche.
Coda di messaggi cloud MQTT
Si tratta di un middleware di messaggistica leggero lanciato da Alibaba Cloud per i settori dell'Internet mobile e dell'Internet delle cose. Se tra i microservizi viene generalmente utilizzato il middleware tradizionale delle code di messaggi, la versione MQTT di Cloud Message Queue adatta all'Internet delle cose realizza il passaggio dei messaggi tra la fine e il cloud e la vera interconnessione di tutto. Questo articolo presenta il modello di invio e ricezione dei messaggi, i vantaggi del prodotto e gli scenari applicativi della versione MQTT di Cloud Message Queue.
Idea fondamentale
Argomento
: argomento del messaggio, tipo di messaggio di primo livello, a cui il produttore invia messaggi.
produttore
: noto anche come editore del messaggio, responsabile della produzione e dell'invio di messaggi all'argomento.
consumatore
: chiamato anche sottoscrittore di messaggi, responsabile della ricezione e del consumo di messaggi dall'argomento.
informazione
: I dati inviati dal produttore al Topic e infine trasmessi al consumatore.
regola
La versione MQTT di Cloud Message Queue è una risorsa che consente l'interoperabilità dei dati con altri prodotti Alibaba Cloud.
Modello di messaggistica
Comprende principalmente i seguenti due modelli di invio e ricezione di messaggi:
Modello di interazione tra terminale e servizio cloud
La versione MQTT di Cloud Message Queue collega il terminale e il cloud per ottenere una comunicazione bidirezionale tra il dispositivo e il cloud. Il dispositivo può comunicare direttamente con le applicazioni aziendali cloud tramite la versione MQTT di Cloud Message Queue e può anche ottenere l'interoperabilità tra prodotti dei dati dei messaggi con altri prodotti Alibaba Cloud.
Gli scenari applicativi tipici di questo modello riguardano la segnalazione dei dati sullo stato dei dispositivi intelligenti o l'emissione di istruzioni per le applicazioni di controllo cloud.
Terminale e modello di interazione terminale
Questo modello è adatto per la comunicazione di dati tra app o dispositivi mobili Gli scenari tipici sono due utenti che chattano direttamente con i messaggi nello scenario di comunicazione IM e l'app che controlla i dispositivi intelligenti nello scenario del dispositivo intelligente. In questo modello, i produttori e i consumatori dei messaggi sono distribuiti sui dispositivi terminali e collegati al prodotto in versione MQTT della coda di messaggi cloud tramite il protocollo MQTT.
Sulla base dei due modelli di invio e ricezione dei messaggi precedenti, gli sviluppatori che utilizzano la versione MQTT di Cloud Message Queue possono essere suddivisi in due categorie: terminale e cloud.
Vantaggi del prodotto
Migrazione senza interruzioni
Compatibile con qualsiasi SDK che supporti il protocollo MQTT 3.1.1, supporti il protocollo WebSocket e copre la maggior parte delle piattaforme e dei linguaggi di sviluppo mobile.
alte prestazioni
Supporta connessioni online di decine di milioni di dispositivi, milioni di messaggi simultanei, trilioni di trasferimenti e push a livello di millisecondo, nessun collo di bottiglia in un unico punto ed espansione orizzontale illimitata tra i componenti.
Sicuro e affidabile
Supporta il controllo delle autorizzazioni a livello di dispositivo, il servizio token temporaneo e il protocollo di trasmissione sicura versione TLS 1.2 per garantire che i dati dell'utente siano sicuri e affidabili.
Interoperabilità naturale
Lo scambio di messaggi tra la versione Cloud Message Queue MQTT e la versione Cloud Message Queue RocketMQ consente la comunicazione bidirezionale tra il dispositivo e il cloud, rendendolo più efficiente e affidabile.
Scenari applicativi
Dispone di funzionalità di supporto multiprotocollo, multilingue e multipiattaforma ed è ampiamente utilizzato nei settori dell'Internet mobile e dell'Internet delle cose, coprendo una varietà di scenari applicativi come la trasmissione live mobile, l'Internet dei veicoli, i pagamenti finanziari, ristorazione intelligente e chat istantanea.
Servizio di messaggistica MNS
Message Service MNS (Message Service) è un servizio di messaggistica distribuita efficiente, affidabile, sicuro, conveniente ed elasticamente scalabile. Il servizio di messaggistica MNS può aiutare gli sviluppatori a trasferire liberamente dati e messaggi di notifica tra componenti distribuiti dell'applicazione, costruendo così un sistema liberamente accoppiato. Il servizio di messaggistica MNS supporta il modello di coda e il modello di argomento.
modello di coda
Il modello di coda fornisce un modello di consumo uno a uno ad alta affidabilità e concorrenza elevata, ovvero ogni messaggio nella coda può essere consumato solo da un determinato consumatore.
La coda è come un ristorante di sushi girevole. Ci sono più chef di sushi (produttori) nel ristorante di sushi che preparano sushi squisito. Ogni pezzo di sushi è unico. I clienti (consumatori) possono prendere il sushi che preferiscono dal nastro trasportatore per mangiarlo (consumo).
Vantaggi del prodotto
Semplice e facile da usare
Non sono necessarie operazioni e manutenzione, non è necessario creare autonomamente il servizio di messaggistica.
Facile accesso, interfaccia HTTP RESTful standard.
Supporto SDK per più linguaggi, inclusi C, Java, C#, Python, PHP, Go, ecc., e continua ad essere arricchito.
Stabile e affidabile
Tre copie del messaggio, alta affidabilità.
Elevata disponibilità del servizio.
Il meccanismo unico garantisce che sia sempre scrivibile.
Sicurezza
Protezione di sicurezza multilivello e prevenzione degli attacchi DDoS.
Meccanismo di isolamento multiutente, ogni utente è dotato di uno spazio dei nomi indipendente.
Supporta la concessione di permessi di accesso diversi a diversi utenti RAM.
Supporta l'accesso HTTPS e VPC.
Prestazioni su larga scala e ad alta scalabilità
Il numero di code e la capacità di archiviazione delle code sono altamente scalabili.
La scala del servizio viene automaticamente ampliata e trasparente per gli utenti.
Fornire servizi in più regioni del mondo.
Veloce e stabile
Veloce e diretto, bastano solo 3 secondi per connettersi agli utenti.
Canale esclusivo Triple Play.
La sala computer con linea dedicata supporta grandi capacità ed elevata concorrenza.
Il tasso di arrivo è elevato ed è collegato in tempo reale alla piattaforma di portabilità del numero del Ministero dell'Industria e dell'Informazione.
Garanzia di funzionamento e manutenzione di livello carrier, monitoraggio in tempo reale e commutazione automatica.
Servizio tecnico intimo
Arricchire continuamente la condivisione di casi di best practice.
Supporto per ordini di lavoro 24 ore su 24, 7 giorni su 7.
Supporto in loco personalizzabile disponibile.