Kapitel 5. Grundlagen der ereignisgesteuerten Verarbeitung
Diese Arbeit wurde mithilfe von KI übersetzt. Wir freuen uns über dein Feedback und deine Kommentare: translation-feedback@oreilly.com
Die meisten ereignisgesteuerten Microservices folgen mindestens denselben drei Schritten:
-
Konsumiere ein Ereignis aus einem Eingangs-Ereignisstrom.
-
Verarbeite dieses Ereignis.
-
Erzeuge alle notwendigen Ausgabeereignisse.
Es gibt auch ereignisgesteuerte Microservices, die ihr Eingangsereignis aus einer synchronen Anfrage-Antwort-Interaktion ableiten, was in Kapitel 13 näher erläutert wird. Dieses Kapitel behandelt nur Microservices, die ihre Ereignisse aus Ereignisströmen beziehen.
Bei ereignisgesteuerten Microservices mit Stream-Sourcing erstellt die Microservice-Instanz einen Producer-Client und einen Consumer-Client und registriert sich ggf. bei den erforderlichen Consumer-Gruppen. Der Microservice startet eine Schleife, um den Consumer-Client nach neuen Ereignissen abzufragen, diese zu verarbeiten und alle erforderlichen Ausgabeereignisse zu senden. Dieser Arbeitsablauf ist im folgenden Pseudocode dargestellt. (Deine Implementierung hängt natürlich von deiner Sprache, deinem Stream-Processing-Framework, der Auswahl des Event-Brokers und anderen technischen Faktoren ab).
ConsumerconsumerClient=newconsumerClient(consumerGroupName,...);ProducerproducerClient=newproducerClient(...);while(true){InputEventevent=consumerClient.pollOneEvent(inputEventStream);OutputEvent ...