Jak je implementován vzor Saga pro správu distribuovaných transakcí v architektuře mikroservisů?

Vzor Saga se používá k řízení distribuovaných transakcí v architektuře mikroservisů, kde tradiční transakce ACID nejsou možné kvůli rozdělení dat a služeb.

Myšlenka spočívá v tom, že velká obchodní operace je rozdělena na sérii místních transakcí v různých službách. Každá místní transakce je doprovázena kompenzační operací, která zruší její efekt v případě chyby v jakémkoli kroku.

Implementace v Go je obvykle postavena kolem orchestrátora nebo choreografie:

• Orchestrátor: centralizovaná služba, která řídí sekvenci kroků a volá místní transakce, zpracovává chyby a spouští kompenzační transakce.
• Choreografie: každá služba publikuje události o provedení kroku, na které reagují ostatní služby, provádějí své kroky nebo kompenzační akce.

Příklad zjednodušené orchestrace v Go:

func RunSaga() error {
    if err := ServiceA.DoStep(); err != nil {
        return err
    }
    if err := ServiceB.DoStep(); err != nil {
        ServiceA.Compensate() // vrácení prvního kroku
        return err
    }
    if err := ServiceC.DoStep(); err != nil {
        ServiceB.Compensate()
        ServiceA.Compensate()
        return err
    }
    return nil
}

Ve skutečných systémech se používají fronty zpráv (Kafka, RabbitMQ) k přenosu událostí a správě stavu sagy, stejně jako ukládání stavu sagy do databáze pro odolnost vůči chybám.