ApsaraMQ for RocketMQ ist eine professionelle Nachrichten-Middleware und ein Kernprodukt für unternehmensweite Internetarchitekturen. Der Dienst unterstützt zuverlässige, nachrichtenbasierte asynchrone Kommunikation zwischen Microservices, verteilten Systemen und serverless-Anwendungen. Mit diesem Dienst können Sie einfach skalierbare verteilte Systeme mit loser Kopplung und hoher Verfügbarkeit erstellen.
ApsaraMQ for RocketMQ ist seit über 11 Jahren in die Infrastruktur der Alibaba Group integriert und unterstützt seit neun Jahren das E-Commerce-Großereignis 11-11 von Alibaba. Der Dienst bietet niedrige Latenz, hohe Parallelität, hohe Verfügbarkeit, hohe Zuverlässigkeit sowie leistungsstarke Nachrichtenstapel-Funktionen und bewältigt Datenströme im Billionenbereich. Mit MQ können Sie Daten zwischen Anwendungskomponenten jeder Größe frei übertragen.
Vorteile

-
Hohe Leistung und niedrige Latenz
Message Queue unterstützt 10 Millionen Abfragen pro Sekunde (QPS) und einen Nachrichtendurchsatz im Billionenbereich – ohne Parallelitäts- oder Leistungsobergrenzen.

-
Hohe Zuverlässigkeit
Message Queue unterstützt synchrones Double-Write, dreifache Datenredundanz über mehrere Server und schnelle Datenkopie-Umschalttechnologie, um eine Datenzuverlässigkeit von bis zu 99,99999999 % zu gewährleisten.

-
Hohe Skalierbarkeit
Message Queue unterstützt Warteschlangen mit zehntausenden Nachrichten. Die Anzahl der Warteschlangen kann elastisch skaliert werden und die Clustergröße passt sich automatisch an. Dieser Vorgang ist für Benutzer vollständig transparent.

-
Zugriffskontrolle
Message Queue steuert die Berechtigungen zum Senden und Empfangen jeder Nachricht über das Nachrichtenthema und die Consumer-ID und gewährleistet so die Nachrichtensicherheit.
Funktionen
-
Hohe Leistung und niedrige Latenz
ApsaraMQ for RocketMQ gewährleistet hohe Leistung auch bei massiven Nachrichten-Warteschlangen, ohne den Cluster-Betrieb zu beeinträchtigen. Dies ist besonders wichtig bei der Lastverschiebung (Flood Storage).
Aus jahrelanger Erfahrung mit dem jährlichen 11-11-E-Commerce-Event von Alibaba hat das technische Team von Alibaba Cloud Methoden entwickelt, um Schwankungen der Antwortzeiten bei Anfragen zu beheben, die durch Systemüberlastung aufgrund extrem hoher Parallelität verursacht werden. Bei den Billionen von Nachrichten, die während des 11-11-Events 2017 gesendet wurden, lag die erfasste Latenz von 99,6 % der Schreibvorgänge unter 1 ms und die von 99,996 % unter 10 ms.
Die Nachricht wird unmittelbar nach Eingang beim Server gesendet, wodurch eine zeitnahe Zustellung gewährleistet ist.
-
Hohe Verfügbarkeit, Zuverlässigkeit und Skalierbarkeit
ApsaraMQ for RocketMQ bietet hochverfügbare Nachrichten-Cloud-Dienste in mehreren Regionen weltweit. Die Rechenzentren und Hardware-Einrichtungen werden nach hohen Standards gemäß den IDC-Spezifikationen von Alibaba aufgebaut. Jede Region ist mit mehreren Rechenzentren ausgestattet. Der Nachrichtendienst kann Nachrichten auch dann zuverlässig an Anwendungen übermitteln, wenn ein gesamter Server ausfällt.
ApsaraMQ for RocketMQ unterstützt Multi-Aktiv-Bereitstellungslösungen innerhalb derselben Stadt in mehreren Finanzregionen, einschließlich China East 1 (Hangzhou), China East 2 (Shanghai), China South 1 (Shenzhen) und weiteren Regionen, zum Schutz kritischer Finanztransaktionssysteme.
-
Sichere Zugriffssteuerung
ApsaraMQ for RocketMQ unterstützt die Erstellung von Hauptkonten und Unterkonten, Blacklist- und Whitelist-Funktionen sowie die STS-Funktionen von Alibaba Cloud RAM.
ApsaraMQ for RocketMQ unterstützt kontoübergreifende Autorisierung sowie die Autorisierung über Hauptkonten und Unterkonten.
Geordnete Nachrichten werden in der Reihenfolge ihrer Veröffentlichung verarbeitet (First-In-First-Out). Der Nachrichtendienst unterstützt sowohl globale als auch partitionierte Nachrichtenreihenfolgen.
-
Themenmodell (Topic)
ApsaraMQ for RocketMQ unterstützt das Pub/Sub-Modell. In diesem Modell sendet der Ersteller die Nachricht an ein bestimmtes Topic. Ein oder mehrere Verbraucher können die Nachricht abonnieren.
ApsaraMQ for RocketMQ unterstützt Cluster-Verbrauch und Broadcast-Verbrauch. Abonnenten mit derselben Consumer-ID gehören zum selben Cluster. Im Cluster-Verbrauchsmodus muss jede Nachricht nur von einem beliebigen Abonnenten im Cluster verarbeitet werden. Im Broadcast-Modus wird jede Nachricht an alle Abonnenten im Cluster gesendet, sodass jeder Abonnent die Nachricht mindestens einmal erhält.
-
Vielfältige Nachrichtentypen
Standardnachrichten werden für die asynchrone Entkopplung von Geschäftsprozessen zwischen Systemen, Lastverschiebung, Protokollierung, großflächige Cache-Synchronisierung zwischen Hosts sowie Echtzeit-Computing und -Analyse verwendet.
Geordnete Nachrichten werden sowohl in der richtigen Reihenfolge veröffentlicht als auch verarbeitet und in global geordnete sowie partitioniert geordnete Nachrichten unterteilt.
ApsaraMQ for RocketMQ bietet eine verteilte Transaktionsfunktion nach dem X/Open-XA-Standard, um die Transaktionskonsistenz sicherzustellen.
Nachdem eine Nachricht an den Message-Queue-Server gesendet wurde, übermittelt der Server die Nachricht zu einem festgelegten Zeitpunkt (z. B. am 1. Januar 2016 um 15:00:00 Uhr) nach dem Sendezeitpunkt (aktuelle Zeit).
Nachdem eine Nachricht an den Message-Queue-Server gesendet wurde, übermittelt der Server die Nachricht nach einer festgelegten Verzögerungszeit (z. B. 30 Minuten später) ab dem Sendezeitpunkt (aktuelle Zeit).
-
Systematische Wartungstools
ApsaraMQ for RocketMQ bietet ein umfassendes Set an Wartungstools, mit denen Sie Systemprobleme schnell erkennen und beheben können.
Abfrage von Nachrichten nach Topic, Nachrichten-ID oder Nachrichtenschlüssel auf dem Message-Queue-Server.
ApsaraMQ for RocketMQ erfasst vollständige Daten über den gesamten Prozess – einschließlich des Nachrichtenflusses vom Ersteller zum Message-Queue-Server und weiter zum Endbenutzer –, aggregiert und analysiert diese Daten und erstellt eine visuelle Nachverfolgung der gesamten Nachrichtenübermittlungskette.
ApsaraMQ for RocketMQ kann bereits verarbeitete Nachrichten zu einem bestimmten Zeitpunkt erneut abspielen und dient damit als leistungsfähiges Werkzeug zur Fehlerbehebung.
Sie können für jede Kunden-ID Überwachungs- und Alarmregeln basierend auf der Verzögerungszeit beim Nachrichtenverbrauch und der Warteschlangenmenge festlegen, um Probleme rechtzeitig zu erkennen.
ApsaraMQ for RocketMQ bietet ein vollständiges Set standardisierter HTTP-RESTful-Open-APIs für Steuerungszwecke, mit denen Sie Ressourcenverwaltungs- und Wartungsfunktionen ausführen und den Zugriff vereinfachen können.
Kundenszenarien
-
Entkopplung
-
Lastverlagerung (Flood Storage)
-
Verteilte Transaktionen
-
Echtzeit-Computing
-
Großskalige Cache-Synchronisierung
-
IM
Entkopplung
Eine lose Kopplung zwischen Systemen verbessert die Skalierbarkeit und Zuverlässigkeit und ist die optimale Designlösung für moderne Anwendungen. Mit Message Queue können Sie Nachrichten zwischen beliebig vielen Anwendungskomponenten (Systemen) senden, speichern und empfangen – ohne Nachrichtenverlust. Dies vereinfacht den Betrieb von Cloud-Anwendungskomponenten und bietet höhere Kosteneffizienz.
Lastverlagerung (Flood Storage)
Bei Großveranstaltungen wie den Transaktionsspitzen um Mitternacht während des Tmall 11-11 E-Commerce-Festivals von Alibaba, der Online-Aktion mit roten Umschlägen zum Frühlingsfest und anderen großen Online-Events können zahlreiche Anfragen fehlschlagen, wenn das externe Anfragevolumen die Verarbeitungskapazität des Systems übersteigt. Verfügt das System nicht über geeignete Schutzmaßnahmen und häufen sich zu viele abgelaufene Anfragen an, die nicht automatisch wiederhergestellt werden können, bricht das System zusammen und seine Dienstleistungsfähigkeit für externe Dienste sinkt auf null. Dies kann die Benutzererfahrung erheblich beeinträchtigen.
Verteilte Transaktionen
Im herkömmlichen Transaktionsverarbeitungsmodus sind Geschäftsprozesse zwischen mehreren Systemen oder Anwendungskomponenten in einer großen Transaktion gekoppelt, was zu langen Antwortzeiten und langen Geschäftsabläufen führt und die Systemverfügbarkeit beeinträchtigt. Mit den verteilten Transaktionsnachrichten von Message Queue können Sie Kerngeschäftsprozesse, die synchron verarbeitet werden müssen, von Nebengeschäftsprozessen trennen, die asynchron verarbeitet werden können. Dadurch wird eine große Transaktion in kleinere aufgeteilt und die Interaktion zwischen den Systemen reduziert.
Auf diese Weise stellen Sie die Datenkonsistenz zwischen verteilten Systemen sicher und entkoppeln Geschäftssysteme (Warenkorb, Punkteprogramm u. a.) voneinander, um eine optimale Architektur zu erzielen.
Echtzeit-Computing
Daten erzeugen Wert im „Fluss“. Die herkömmliche Datenanalyse basiert meist auf dem Batch-Computing-Modell, das keine Echtzeit-Datenanalyse ermöglicht. Durch die Kombination von Alibaba Cloud Message Queue mit einer gängigen Computing-Engine (wie Spark, Storm, E-MapReduce (EMR), Application Real-Time Monitoring Service (ARMS) und BeamRunner) können Sie bequem Echtzeit-Analysen Ihrer Geschäftsdaten durchführen.
Großskalige Cache-Synchronisierung
Für parallele Sitzungen bei Großveranstaltungen oder App-Clients mit hohem Traffic wird ein skalierbares Cache-Design eingesetzt, um die Antwortzeit (RT) zu verkürzen und die Benutzererfahrung zu verbessern. Während der Tmall 11-11 Aktion werden Kunden in der Shoutao-App, der Tmall-App und verschiedenen Fachshops eine Vielzahl von Produkten präsentiert, deren Preise sich in Echtzeit ändern. Zahlreiche gleichzeitige Zugriffe auf die Produktdatenbank führen zu langen Antwortzeiten, und die Bandbreite des zentralisierten Caches wird zum Engpass, sodass die Preisanfragen nicht mehr bedient werden können. Das Multi-Cache-Design für Fachshops nutzt Message Queue zur Synchronisierung zwischen mehreren Caches, damit Kunden jederzeit auf aktuelle Produktpreise zugreifen können.
IM
Innerhalb von Alibaba nutzen sowohl TradeManager (eine App für die Echtzeit-Handelskommunikation) als auch DingTalk (eine App für die Bürokommunikation) Message Queue für ihre Nachrichtendienste. Bei jeder Interaktion in Einzelchats, Gruppenchats und DingTalk-Benachrichtigungen werden zahlreiche Nachrichten generiert.
Verbesserter Support für Sie
Persönliche Vorverkaufsberatung, technischer Support rund um die Uhr, schnellere Antworten und mehr Tickets.
Persönliche Vorverkaufsberatung
Technischer Support rund um die Uhr
6 kostenlose Tickets pro Quartal
