Construir microservicios basados en eventos

Capítulo 5. Fundamentos del procesamiento dirigido por eventos

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

La mayoría de los microservicios basados en eventos siguen, como mínimo, los mismos tres pasos:

1. Consume un evento de un flujo de eventos de entrada.

2. Procesa ese evento.

3. Produce los eventos de salida necesarios.

También hay microservicios dirigidos por eventos que obtienen su evento de entrada de una interacción síncrona de solicitud-respuesta, de lo que se habla más en el Capítulo 13. Este capítulo sólo cubre los microservicios que obtienen sus eventos de flujos de eventos.

En los microservicios basados en eventos de flujo, la instancia del microservicio creará un cliente productor y un cliente consumidor y se registrará en los grupos consumidores necesarios, si procede. El microservicio inicia un bucle para sondear al cliente consumidor en busca de nuevos eventos, procesándolos a medida que llegan y emitiendo los eventos de salida necesarios. Este flujo de trabajo se muestra en el siguiente pseudocódigo. (Por supuesto, tu implementación variará en función de tu lenguaje, marco de procesamiento de flujos, selección del corredor de eventos y otros factores técnicos).

Consumer consumerClient = new consumerClient(consumerGroupName, ...);
Producer producerClient = new producerClient(...);

while(true) {
    InputEvent event = consumerClient.pollOneEvent(inputEventStream);
    OutputEvent output = processEvent ...