Cum se implementează pattern-ul Saga pentru gestionarea tranzacțiilor distribuite în arhitectura microserviciilor?

Modelul Saga este utilizat pentru gestionarea tranzacțiilor distribuite într-o arhitectură de microservicii, unde tranzacțiile tradiționale ACID nu sunt posibile din cauza distribuției datelor și serviciilor.

Ideea este ca o operațiune de afaceri mare să fie împărțită într-o serie de tranzacții locale în diferite servicii. Fiecare tranzacție locală este însoțită de o operațiune de compensare care anulează efectul acesteia în cazul unei erori la orice pas.

Implementarea în Go se bazează de obicei pe un orchestrator sau pe o coregrafie:

• Orchestrator: un serviciu centralizat care gestionează secvența pașilor și apelează tranzacțiile locale, gestionează erorile și pornește tranzacțiile de compensare.
• Coregrafie: fiecare serviciu publică evenimente despre realizarea unui pas, alte servicii reacționează la acestea, efectuând propriile pași sau acțiuni de compensare.

Exemplu de orchestrare simplificată în Go:

func RunSaga() error {
    if err := ServiceA.DoStep(); err != nil {
        return err
    }
    if err := ServiceB.DoStep(); err != nil {
        ServiceA.Compensate() // revertirea primului pas
        return err
    }
    if err := ServiceC.DoStep(); err != nil {
        ServiceB.Compensate()
        ServiceA.Compensate()
        return err
    }
    return nil
}

În sistemele reale, se utilizează cozi de mesaje (Kafka, RabbitMQ) pentru transmiterea evenimentelor și gestionarea stării saga, precum și stocarea stării saga într-o bază de date pentru reziliență la defecțiuni.