Как се реализира патърнът Saga за управление на разпределени транзакции в микросервизни архитектури?

Шаблонът Saga се използва за управление на разпределени транзакции в архитектура с микросервизи, където традиционните транзакции ACID не са възможни поради разпределението на данните и услугите.

Идеята е голяма бизнес операция да бъде разделена на серия от локални транзакции в различни услуги. Всяка локална транзакция е придружена от компенсаторна операция, която отменя нейния ефект в случай на грешка на някой етап.

Реализацията в Go обикновено се базира около оркестратор или хореография:

• Оркестратор: централизирана услуга, която управлява последователността на стъпките и извиква локалните транзакции, обработва грешки и стартира компенсаторни транзакции.
• Хореография: всяка услуга публикува събития за изпълнението на стъпка, други услуги реагират на тях, изпълнявайки свои стъпки или компенсаторни действия.

Пример за опростена оркестрация на Go:

func RunSaga() error {
    if err := ServiceA.DoStep(); err != nil {
        return err
    }
    if err := ServiceB.DoStep(); err != nil {
        ServiceA.Compensate() // отменя първата стъпка
        return err
    }
    if err := ServiceC.DoStep(); err != nil {
        ServiceB.Compensate()
        ServiceA.Compensate()
        return err
    }
    return nil
}

В реалните системи се използват опашки за съобщения (Kafka, RabbitMQ) за предаване на събития и управление на състоянието на сагата, както и съхраняване на състоянието ѝ в база данни за устойчивост към сривове.