Concetti di messaggistica

La messaggistica asincrona consente ai servizi di comunicare senza chiamarsi direttamente. Un producer deposita un messaggio e un consumer lo preleva in un secondo momento. In questo modo i servizi sono disaccoppiati, i picchi di carico vengono attenuati e il sistema rimane resiliente quando un consumer è temporaneamente indisponibile.

MassTransit è un framework .NET che si basa su message broker come RabbitMQ o Azure Service Bus. Gestisce serializzazione, routing, retry e altro, così è possibile concentrarsi sui messaggi e sugli handler invece che sulla gestione del broker.

Esistono due intenti importanti per i messaggi. Un comando indica a uno specifico servizio di eseguire un'azione ("ChargePayment"). Un evento annuncia che qualcosa è accaduto ("OrderPlaced") a chiunque sia interessato. I comandi hanno un solo handler, mentre gli eventi possono averne molti.

Un comando è un semplice tipo di messaggio, con un nome imperativo. Lo invii a un solo consumer.

Un evento ha un nome al passato e viene pubblicato a tutti i subscriber interessati.

Una queue conserva i messaggi finché un consumer non li elabora. È un meccanismo point-to-point: ogni messaggio viene consegnato esattamente a un consumer, consentendo il bilanciamento del carico tra più istanze (competing consumer).

I broker come RabbitMQ instradano i messaggi tramite gli exchange. Un producer pubblica su un exchange, che distribuisce il messaggio a tutte le queue associate. È così che un evento raggiunge molti subscriber.

MassTransit associa automaticamente i tipi di messaggio a exchange e queue. Send indirizza il messaggio a una queue (comando); Publish lo indirizza a un exchange, così la queue di ogni consumer sottoscritto riceve una copia (evento).

Il servizio degli ordini pubblica OrderPlaced e prosegue. Nel frattempo, un servizio email e un servizio di analisi lo consumano ciascuno per conto proprio. Aggiungere un nuovo subscriber non richiede modifiche al producer.

I broker offrono in genere una consegna almeno una volta: dopo un errore, un messaggio può essere consegnato di nuovo. I consumer devono quindi essere idempotenti, così elaborare due volte lo stesso messaggio è sicuro.

Scelga il messaging quando il lavoro può essere eseguito in modo asincrono, quando è necessario disaccoppiare i servizi o per assorbire i picchi. Se serve una risposta immediata a una richiesta, una chiamata API diretta può essere comunque più semplice.

Verifichi i concetti del messaging.

La messaggistica asincrona disaccoppia i servizi tramite un broker. MassTransit astrae broker come RabbitMQ. I comandi (imperativi, con un solo handler) vengono inviati a una queue; gli eventi (al passato, con molti handler) vengono pubblicati su un exchange, che li distribuisce ai subscriber. Poiché la consegna avviene almeno una volta, è necessario rendere idempotenti i consumer.