Kako se implementira obrazac Saga za upravljanje distribuiranim transakcijama u mikroservisnoj arhitekturi?

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

Идеја је да се велика пословна операција подели на серију локалних трансакција у различитим сервисима. Свaka локална трансакција прати компензацијска операција која поништа њен ефекат у случају грешке у било ком кораку.

Реализација у 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) за пренос догађаја и управљање стањем саге, као и чување стања саге у бази података за отпорност на кварове.