C# Academy · Lezione

Saga e workflow

Coordini processi di lunga durata.

Saga e workflow è una lezione C# Academy gratuita su CoddyKit. Questa è la lezione 3 di 4. Puoi leggere la lezione completa qui gratuitamente — poi esercitati direttamente nel browser con un editor di codice integrato e un tutor IA disponibile 24/7. Fa parte del percorso di apprendimento C# Academy, e i tuoi progressi si sincronizzano tra il web e l'app CoddyKit. Il corso C# Academy include 4 lezioni in totale.

Coordinamento di workflow lunghi

Alcuni processi aziendali si estendono su più messaggi e passaggi nel tempo: effettuare un ordine, addebitare il pagamento, riservare le scorte e spedire. Una saga coordina un workflow di lunga durata e ne tiene traccia dello stato tra i vari messaggi.

Che cos'è una saga?

Una saga è un consumer con stato. Mette in correlazione i messaggi correlati, conserva lo stato corrente del workflow e reagisce agli eventi passando da uno stato all'altro fino al completamento del processo.

Saga basate su macchine a stati

MassTransit modella le saga come macchine a stati utilizzando MassTransitStateMachine. È possibile definire in modo dichiarativo stati, eventi e transizioni.

dotnet add package MassTransit
// state machine sagas are built in

Lo stato della saga

Lo stato è una classe che implementa SagaStateMachineInstance. Contiene un CorrelationId oltre a tutti i dati necessari da ricordare tra un passaggio e l'altro.

public class OrderState : SagaStateMachineInstance
{
    public Guid CorrelationId { get; set; }
    public string CurrentState { get; set; }
    public decimal Amount { get; set; }
}

Dichiarazione di stati ed eventi

All'interno della macchina a stati si dichiarano proprietà State e proprietà Event che vengono associate ai tipi di messaggio.

public class OrderSaga : MassTransitStateMachine<OrderState>
{
    public State AwaitingPayment { get; private set; }
    public State Completed { get; private set; }
    public Event<OrderPlaced> OrderPlaced { get; private set; }
    public Event<PaymentReceived> PaymentReceived { get; private set; }
}

Correlazione

Ogni evento deve essere messo in correlazione con l'istanza della saga corretta, generalmente tramite un identificativo condiviso come OrderId. In questo modo i messaggi in arrivo vengono instradati al workflow corretto ancora in corso.

Event(() => PaymentReceived, e =>
    e.CorrelateById(m => m.Message.OrderId));

Definizione delle transizioni

Il costruttore collega il comportamento: l'evento iniziale crea l'istanza, memorizza i dati e passa allo stato successivo.

Initially(
    When(OrderPlaced)
        .Then(ctx => ctx.Saga.Amount = ctx.Message.Amount)
        .TransitionTo(AwaitingPayment));

Reazione in uno stato

Utilizzi During per gestire gli eventi validi solo in uno stato specifico, quindi pubblichi i messaggi successivi e passi allo stato seguente.

During(AwaitingPayment,
    When(PaymentReceived)
        .Publish(ctx => new OrderConfirmed(ctx.Saga.CorrelationId))
        .TransitionTo(Completed)
        .Finalize());

Persistenza dello stato della saga

Lo stato della saga deve sopravvivere ai riavvii, quindi viene memorizzato in un repository: Entity Framework, MongoDB, Redis o altri. MassTransit carica e salva l'istanza attorno a ogni messaggio.

x.AddSagaStateMachine<OrderSaga, OrderState>()
    .EntityFrameworkRepository(r =>
    {
        r.ExistingDbContext<OrderDbContext>();
    });

Timeout con pianificazioni

Le saga possono pianificare un timeout (ad esempio, annullare l'operazione se il pagamento non viene ricevuto entro 30 minuti) utilizzando un Schedule, quindi gestire l'evento di timeout per eseguire la compensazione.

Compensazione

Se un passaggio successivo non riesce, una saga può eseguire azioni compensative per annullare quelle precedenti (rimborsare un addebito, liberare le scorte), mantenendo coerente il processo complessivo senza transazioni distribuite.

Verifica rapida

Verifichi le saga e i workflow.

Riepilogo

Una saga coordina workflow di lunga durata come consumer con stato e correlato. MassTransit utilizza MassTransitStateMachine con uno stato SagaStateMachineInstance, membri State/Event dichiarati, correlazione tramite identificativo e transizioni con Initially/During. Lo stato viene persistito in un repository, i timeout utilizzano pianificazioni e la compensazione annulla i passaggi precedenti in caso di errore.

Domande Frequenti

La lezione «Saga e workflow» è gratuita?

Sì — il testo completo di «Saga e workflow» è gratuito qui sul web. Per esercitarvi in modo interattivo (un editor di codice integrato e un tutor IA 24/7) e sbloccare il resto del corso C# Academy, passa a CoddyKit PRO. Il corso C# Academy include 4 lezioni in totale.

Cosa imparerò in «Saga e workflow»?

Coordini processi di lunga durata. Eserciti C# Academy con codice pratico che esegui direttamente nel browser, e un tutor IA 24/7 risponde alle tue domande mentre lavori sulla lezione.

Ho bisogno di esperienza per iniziare C# Academy?

Non è richiesta alcuna esperienza precedente. C# Academy su CoddyKit è strutturato per principianti e studenti avanzati, quindi puoi iniziare da qui o dall'inizio e procedere al tuo ritmo. Questa è la lezione 3 di 4.

Quanto tempo richiede la lezione «Saga e workflow»?

La maggior parte delle lezioni CoddyKit richiede circa 5–10 minuti. Ogni lezione è breve e interattiva, quindi fai progressi costanti e riprendi esattamente da dove hai lasciato su web e app.

Posso scrivere ed eseguire codice in questa lezione C# Academy?

Sì. Ogni lezione C# Academy include un editor di codice integrato, quindi scrivi ed esegui codice reale direttamente nel tuo browser e ricevi feedback istantaneo dall'IA — nessuna configurazione locale necessaria.

Tutte le lezioni di questo corso

← Torna a C# Academy