Hogyan biztosítható az adatok összhangja különböző mikroszolgáltatásokon keresztül végrehajtott tranzakciók során?

Az adatok összhangjának biztosítása különböző mikroszolgáltatások közötti tranzakciók során összetett feladat, mivel a hagyományos elosztott tranzakciók (pl. kétfázisú commit) gyakran nem alkalmasak a teljesítmény és a hibatűrés miatt.

Fő megközelítések:

• Sagas: a tranzakciót egy sor helyi tranzakcióra bontani, hibák esetén kompenzációs műveleteket alkalmazni. Minden szolgáltatás végrehajtja a részét és eseményt publikál, amelyre a következő szolgáltatás reagál.

• Idempotencia és ismételhetőség: a műveleteknek biztonságosnak kell lenniük ismételt végrehajtás esetén is, hogy elkerüljük az inkonzisztenciákat.

• Események és sorok használata: üzenetcsere a szolgáltatások között az állapot koordinálására.

Példa C#-ban (egyszerűsített) — saga megvalósítás események segítségével:

public class OrderSaga
{
    public async Task HandleOrderCreated(OrderCreatedEvent evt)
    {
        await ReserveInventory(evt.OrderId, evt.Items);
        await ProcessPayment(evt.OrderId, evt.PaymentDetails);
        // stb.
    }

    private async Task ReserveInventory(Guid orderId, List<Item> items) { /* ... */ }
    private async Task ProcessPayment(Guid orderId, PaymentDetails payment) { /* ... */ }
}

Így minden művelet külön tranzakció, és a konzisztencia a saga logikája és a kompenzációs műveletek révén érhető el.