Was ist ein Ereignisverbraucher?

Eine ereignisgesteuerte Architektur ist ein Softwaredesignmuster, das es Systemen ermöglicht, Ereignisse in Echtzeit zu erkennen, zu verarbeiten, darauf zu reagieren und Informationen über Ereignisse weiterzugeben. Der größte Vorteil von EDA-Systemen ist ihre Fähigkeit, Daten sofort zu kommunizieren, wenn ein Ereignis eintritt, sodass Event Consumers sofort handeln können.

Einer der wichtigsten Aspekte von ereignisgesteuerten Architekturen ist, dass die Systeme, die Ereignisse generieren und auf sie reagieren, entkoppelt oder lose gekoppelt sind. Ein System, das Ereignisse nutzt, ist beispielsweise nicht von den Systemen abhängig, die Ereignisse erzeugen, und muss nicht wissen, woher die Informationen stammen. Das bedeutet, dass der Ausfall eines Services keine Probleme oder Unterbrechungen anderer Services verursacht.

Asynchrones Messaging ist ein weiteres wichtiges Merkmal von EDA. Anstatt mit einem „Anfrage- und Antwortmodell“ zu kommunizieren, bei dem Systeme auf eine Antwort warten müssen, bevor sie Maßnahmen ergreifen, kommunizieren die Komponenten in der ereignisgesteuerten Architektur asynchron und werden aktiv, ohne auf eine Meldung von anderen Komponenten zu warten. So können EDA-Systeme bei der schnellen Verarbeitung großer Datenmengen in Echtzeit hervorragende Leistungen erbringen, da Komponenten auf Ereignisse reagieren und Daten sofort verarbeiten können.

Ein Ereignisverbraucher ist eines von mehreren Schlüsselelementen einer ereignisgesteuerten Architektur. EDA-Komponenten beinhalten Folgendes:

• Ereignisse: Ereignisse sind ein Signal dafür, dass etwas passiert ist oder ein Status sich geändert hat.
• Ereignisproduzenten: Ereignisproduzenten sind Systeme wie IoT-Geräte, Nutzerschnittstellen, Datenbanken, externe APIs, Workflow-Engines, Cloudservices, Anwendungsüberwachungssysteme und andere Technologien, die Ereignisse generieren und kommunizieren.
• Ereignismeldungen: Ereignismeldungen oder Ereignisbenachrichtigungen enthalten Informationen zu einem Ereignis. Sie befinden sich in der Regel in JSON- oder YAML-Dateien.
• Ereignisverbraucher: Ereignisverbraucher, auch Ereignisabonnenten genannt, „hören“ sich Ereignisse an oder erhalten Informationen zu Ereignissen und initiieren Aktionen, die auf den erhaltenen Informationen basieren. Ereignisverbraucher können Aufgaben ausführen, wie z. B. Sicherheitsteams über potenzielle Sicherheitsverstöße zu informieren, Bestände zu aktualisieren, Bestätigungs-E-Mails an Kunden zu senden oder einen Workflow auszulösen.
• Ereignisrouter: Ereignisrouter ermöglichen asynchrones Messaging und lose gekoppelte Architekturen, indem sie als Vermittler zwischen Produzenten und Verbrauchern fungieren. Router können Ereignisbusse, Nachrichtenwarteschlangen, Ereignisbroker oder Ereignisstreams sein, die Ereignisdaten von Produzenten empfangen und sie an Verbraucher weitergeben, die bestimmte Ereigniskanäle abonniert haben.
• Ereignisprozessoren: Ereignisprozessoren verwalten die Ereignisdaten, die sie von Ereignisverbrauchern empfangen, und wenden Regeln an, die neue Ereignisse initiieren, Aufgaben starten oder Aktionen ausführen. Ereignisprozessoren leiten, filtern und transformieren auch Ereignisdaten.

Jedes Unternehmen, jeder Geschäftsbetrieb und jeder Geschäftsprozess wird von Ereignissen gesteuert und beeinflusst. Je schneller Unternehmen benachrichtigt werden und auf Ereignisse reagieren können, desto größer sind die Effizienzsteigerungen, die Produktivität und die Wettbewerbsfähigkeit. Mit Ereignisverbrauchern und ereignisgesteuerten Architekturen werden Unternehmen sofort über Ereignisse benachrichtigt und können sofort Maßnahmen ergreifen, die ihnen und ihren Kunden zugute kommen.

Ereignisgesteuerte Architekturen ermöglichen Unternehmen Folgendes:

• Daten in Echtzeit verarbeiten . In EDA bedeutet asynchrones Messaging, dass Komponenten Ereignisse kommunizieren und verarbeiten können, sobald sie auftreten, ohne auf Antworten warten zu müssen.
• Schnelle Reaktion auf reale Ereignisse. Die ereignisgesteuerte Architektur verbessert die Reaktionsfähigkeit, indem bei Ereignissen automatisch und sofort Aktionen ausgeführt werden.
• Einfache Skalierung. Da EDA-Komponenten entkoppelt oder lose gekoppelt sind, können einzelne Komponenten unabhängig voneinander skaliert werden, wie die Workloads es verlangen.
• Geringere Ausfallzeiten. EDA erhöht die Ausfallsicherheit und Fehlertoleranz, da andere Komponenten oft auch dann funktionieren, wenn bei einem Service oder System Probleme auftreten.
• Integration und Interoperabilität. Die entkoppelte oder lose gekoppelte ereignisbasierte Kommunikation erleichtert es verschiedenen Systemen, zusammenzuarbeiten und Informationen auszutauschen.
• Geschwindigkeit erhöhen . EDA kann Ihre Systeme beschleunigen, da verschiedene Komponenten nicht aufeinander warten müssen.

Es gibt zwei primäre Modelle für die Veröffentlichung und Nutzung von Ereignissen.

Veröffentlichen/abonnieren (Pub/Sub)

In diesem Modell, das auch als Event-Messaging-Modell bezeichnet wird, abonnieren Ereignisnutzer verschiedene Themen und entscheiden sich, Informationen zu bestimmten Ereignissen zu erhalten. Wenn ein Ereignisproduzent ein Ereignis veröffentlicht, werden die Informationen an einen Ereignisbroker gesendet, der sie bei Bedarf übersetzt oder umwandelt, die Daten in die Warteschlange stellt und speichert und Nachrichten an Ereignisverbraucher sendet. Nachdem Nachrichten von Verbrauchern empfangen wurden, werden sie vom Broker gelöscht.

Zu den bekannten Pub-/Sub-Services gehören Apache Kafka, Confluent, Amazon Simple Notification Service (SNS), Amazon Simple Queue Service (SQS), Azure Web Pub/Sub und GCP Pub/Sub.

Event-Streaming-Modell

Bei diesem Ansatz abonnieren Ereignisverbraucher Nachrichten zu Streamingereignissen, die von Ereignisproduzenten an Broker gesendet werden. Im Gegensatz zu Pub/Sub sind Nachrichten persistent, d. h. sie werden für einen bestimmten Zeitraum gespeichert und aufbewahrt. Das bedeutet, dass Verbraucher jederzeit in einen Stream hineingehen und rückwirkend auf Ereignismeldungen zugreifen können. Verbraucher können auch so konfiguriert werden, dass sie nur bestimmte Ereignisse aus dem Stream empfangen, anstatt wie bei Pub/Sub alle veröffentlichten Nachrichten zu empfangen. Das Event-Streaming-Modell ermöglicht auch die Verarbeitung komplexer Ereignisse, bei der Verbraucher Aktionen anhand von Informationen in einer Reihe von Ereignissen erfassen und initiieren.

Zu den Unternehmen, die Event-Streaming anbieten, gehören AWS EventBridge, AWS Kinesis, Azure Stream Analytics, GCP Dataflow und Apache Beam.

Ereignisverbraucher erfassen eine Vielzahl von Ereignisdaten und reagieren darauf.

• E-Commerce: Die ereignisgesteuerte Architektur ist eine Säule von E-Commerce-Systemen, in denen unmittelbare Reaktionen auf Kundenaktionen für ein nahtloses Erlebnis unerlässlich sind.
• Cybersicherheit: Ereignisverbraucher können Sicherheitsereignisse in Echtzeit verarbeiten, um Sicherheitsteams Warnungen zu übermitteln, schädliche Dateien zu blockieren oder verdächtigen Traffic in Quarantäne zu stellen.
• Microservices: EDA ist aufgrund seiner entkoppelten Kommunikation, Modularität, Skalierbarkeit und Fehlertoleranz eine ideale Architektur für die Kommunikation zwischen Microservices.
• Datenanalysen: Viele Ereignisverbraucher verarbeiten und analysieren Echtzeitdaten, um Muster aufzudecken und Erkenntnisse aus riesigen Datenmengen zu gewinnen. Betrugserkennungssysteme sind ein gängiges Beispiel für eine EDA-Technologie, die Anomalien bei Finanztransaktionen erkennen soll.
• Überwachung: EDA-Systeme sind ideal, um den Zustand von Systemressourcen zu überwachen und Systemadministratoren zu benachrichtigen, wenn prädiktive Wartung oder dringende Maßnahmen erforderlich sind.
• Internet der Dinge (Internet of Things, IoT): Die riesigen Datenmengen, die von IoT-Geräten erzeugt werden, können einfach in EDA-Systemen eingespeist und von diesen überwacht werden. Das ermöglicht Echtzeitüberwachung und -analysen.
• Aktienmarkt: Ereignisverbraucher in der Handelsbranche sind für automatisierte Handelsstrategien von entscheidender Bedeutung, die Kauf-/Verkaufsaufträge auf der Grundlage sich schnell ändernder Bedingungen und Ereignisse innerhalb der Börse ausführen.
• Workflow: EDA-Systeme ermöglichen automatisierte Workflows, indem sie Prozesse und Aufgaben basierend auf einer Vielzahl von Ereignissen auslösen.