Conceptos de mensajería

La mensajería asíncrona permite que los servicios se comuniquen sin llamarse directamente. Un productor publica un mensaje y un consumidor lo recoge más tarde. Esto desacopla los servicios, suaviza los picos de carga y mantiene la resiliencia del sistema cuando un consumidor no está disponible temporalmente.

MassTransit es un framework de .NET que se sitúa sobre brokers de mensajes como RabbitMQ o Azure Service Bus. Gestiona la serialización, el enrutamiento, los reintentos y mucho más, para que pueda centrarse en los mensajes y los controladores, no en la infraestructura del broker.

Hay dos intenciones de mensaje importantes. Un comando indica a un servicio específico que haga algo ("ChargePayment"). Un evento anuncia que algo ha ocurrido ("OrderPlaced") a quien le interese. Los comandos tienen un único controlador; los eventos pueden tener varios.

Un comando es un tipo de mensaje sencillo, con un nombre imperativo. Envíelo a un único consumidor.

Un evento se nombra en tiempo pasado y se publica para todos los suscriptores interesados.

Una cola conserva los mensajes hasta que un consumidor los procesa. Es un mecanismo punto a punto: cada mensaje se entrega exactamente a un consumidor, lo que permite distribuir la carga entre varias instancias de consumidores (consumidores en competencia).

Los brokers como RabbitMQ realizan el enrutamiento mediante exchanges. Un productor publica en un exchange, que distribuye el mensaje entre todas las colas vinculadas. Así es como un evento llega a muchos suscriptores.

MassTransit asigna automáticamente los tipos de mensaje a exchanges y colas. Send se dirige a una cola (comando); Publish se dirige a un exchange, de modo que la cola de cada consumidor suscrito recibe una copia (evento).

El servicio de pedidos publica OrderPlaced y continúa con su trabajo. De forma independiente, un servicio de correo electrónico y otro de análisis lo consumen. Añadir un nuevo suscriptor no requiere ningún cambio en el productor.

Los brokers suelen ofrecer una entrega al menos una vez: un mensaje puede volver a entregarse después de un fallo. Por ello, los consumidores deben ser idempotentes, de modo que procesar dos veces el mismo mensaje sea seguro.

Recurra a la mensajería cuando el trabajo pueda realizarse de forma asíncrona, cuando necesite desacoplar servicios o para absorber picos de carga. Para obtener una respuesta inmediata a una solicitud, una llamada directa a una API puede seguir siendo más sencilla.

Compruebe los conceptos de mensajería.

La mensajería asíncrona desacopla los servicios mediante un broker. MassTransit abstrae brokers como RabbitMQ. Los comandos (imperativos, con un único controlador) se envían a una cola; los eventos (en tiempo pasado, con varios controladores) se publican en un exchange que los distribuye entre los suscriptores. Espere una entrega al menos una vez, por lo que debe hacer que los consumidores sean idempotentes.