Chapitre 5. Principes de base du traitement piloté par les événements
La plupart des microservices pilotés par les événements suivent, au minimum, les trois mêmes étapes :
-
Consomme un événement à partir d'un flux d'événements d'entrée.
-
Traite cet événement.
-
Produire tous les événements de sortie nécessaires.
Il existe également des microservices pilotés par les événements qui tirent leur événement d'entrée d'une interaction demande-réponse synchrone, ce qui est davantage abordé au chapitre 13. Ce chapitre ne couvre que les microservices qui tirent leurs événements de flux d'événements.
Dans les microservices axés sur les événements et alimentés par des flux, l'instance du microservice créera un client producteur et un client consommateur et s'inscrira auprès de tout groupe de consommateurs nécessaire, le cas échéant. Le microservice démarre une boucle pour interroger le client consommateur sur les nouveaux événements, les traiter au fur et à mesure qu'ils arrivent et émettre les événements de sortie nécessaires. Ce flux de travail est illustré dans le pseudocode suivant. (Ta mise en œuvre variera bien sûr en fonction de ton langage, du cadre de traitement des flux, du choix du courtier d'événements et d'autres facteurs techniques).
ConsumerconsumerClient=newconsumerClient(consumerGroupName,...);ProducerproducerClient=newproducerClient ...