El Proyecto | Sobre nosotros | Contribuir | Donaciones | Licencia
HOME Mis cursos Finalizados
◄ Anterior
◄

Mensajería Asíncrona

Siguiente ►
►

La mensajería asíncrona es un componente crucial en la arquitectura de microservicios. Permite que los servicios se comuniquen entre sí sin necesidad de esperar una respuesta inmediata, lo que mejora la escalabilidad y la resiliencia del sistema.

Conceptos Clave

  1. Comunicación Asíncrona

  • Definición: La comunicación asíncrona permite que los servicios envíen mensajes y continúen con su procesamiento sin esperar una respuesta inmediata.
  • Ventajas:
    • Desacoplamiento: Los servicios no dependen de la disponibilidad inmediata de otros servicios.
    • Escalabilidad: Facilita la gestión de cargas de trabajo variables.
    • Resiliencia: Mejora la tolerancia a fallos, ya que los mensajes pueden ser reintentados en caso de errores.

  1. Mensajería

  • Colas de Mensajes: Sistemas que almacenan mensajes hasta que el receptor esté listo para procesarlos (ej. RabbitMQ, Amazon SQS).
  • Topics: Sistemas de publicación/suscripción donde los mensajes se envían a múltiples suscriptores (ej. Apache Kafka).

  1. Patrones de Comunicación

  • Fire-and-Forget: El emisor envía un mensaje y no espera una respuesta.
  • Request-Reply: El emisor envía un mensaje y espera una respuesta, pero de manera asíncrona.
  • Publish-Subscribe: Un emisor publica mensajes a un canal, y múltiples receptores pueden suscribirse para recibir esos mensajes.

Ejemplo Práctico: Implementación con RabbitMQ

Instalación de RabbitMQ

Para instalar RabbitMQ, sigue estos pasos:

  1. Docker:

    docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

  2. Acceso a la Interfaz de Administración:

    • URL: http://localhost:15672
    • Usuario: guest
    • Contraseña: guest

Configuración del Productor y Consumidor

Productor (Producer)

import pika

# Conexión a RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# Declaración de la cola
channel.queue_declare(queue='hello')

# Envío de un mensaje
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')
print(" [x] Sent 'Hello World!'")

# Cierre de la conexión
connection.close()

Consumidor (Consumer)

import pika

# Conexión a RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

# Declaración de la cola
channel.queue_declare(queue='hello')

# Definición de la función de callback
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")

# Configuración del consumidor
channel.basic_consume(queue='hello',
                      on_message_callback=callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

Explicación del Código

  1. Productor:

    • Conexión: Se establece una conexión con RabbitMQ.
    • Declaración de la Cola: Se asegura que la cola hello exista.
    • Envío de Mensaje: Se publica un mensaje en la cola hello.

  2. Consumidor:

    • Conexión: Se establece una conexión con RabbitMQ.
    • Declaración de la Cola: Se asegura que la cola hello exista.
    • Callback: Función que se ejecuta cuando se recibe un mensaje.
    • Consumo de Mensajes: Se configura el consumidor para recibir mensajes de la cola hello.

Ejercicio Práctico

Ejercicio 1: Implementar un Sistema de Notificaciones

Descripción: Implementa un sistema de notificaciones donde un servicio de pedidos envía una notificación a un servicio de notificaciones cada vez que se crea un nuevo pedido.

  1. Productor: Servicio de pedidos que envía un mensaje con los detalles del pedido.
  2. Consumidor: Servicio de notificaciones que recibe y procesa el mensaje.

Solución

Productor (Servicio de Pedidos)

import pika

def send_order_notification(order_id, order_details):
    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
    channel = connection.channel()
    channel.queue_declare(queue='order_notifications')
    message = f"Order ID: {order_id}, Details: {order_details}"
    channel.basic_publish(exchange='',
                          routing_key='order_notifications',
                          body=message)
    print(f" [x] Sent {message}")
    connection.close()

# Ejemplo de uso
send_order_notification(123, "Product: Book, Quantity: 1")

Consumidor (Servicio de Notificaciones)

import pika

def callback(ch, method, properties, body):
    print(f" [x] Received {body}")
    # Aquí se procesaría la notificación, por ejemplo, enviando un email

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='order_notifications')
channel.basic_consume(queue='order_notifications',
                      on_message_callback=callback,
                      auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

Retroalimentación y Consejos

  • Errores Comunes:
    • Conexión Fallida: Asegúrate de que RabbitMQ esté en ejecución y accesible.
    • Cola No Declarada: Asegúrate de que tanto el productor como el consumidor declaren la misma cola.
  • Consejos:
    • Persistencia de Mensajes: Configura la cola y los mensajes como persistentes para evitar la pérdida de datos en caso de fallos.
    • Escalabilidad: Considera el uso de múltiples consumidores para procesar mensajes en paralelo.

Conclusión

La mensajería asíncrona es una técnica poderosa para construir sistemas de microservicios escalables y resilientes. Al utilizar colas de mensajes y patrones de comunicación asíncrona, los servicios pueden interactuar de manera eficiente sin depender de la disponibilidad inmediata de otros servicios. En el siguiente módulo, exploraremos los diferentes protocolos de comunicación utilizados en microservicios, como gRPC y GraphQL.

◄ Anterior
◄
Siguiente ►
►
El Proyecto | Sobre nosotros | Contribuir | Donaciones | Licencia
© Copyright 2024. Todos los derechos reservados