SAGA Pattern - Distributed Transaction Deep Dive

Core Idea

Saga = chuỗi các transaction local + rollback (compensation) nếu có lỗi

Dùng khi:

• Microservices
• Không dùng được ACID transaction (cross-service)
• Cần eventual consistency

Problem cần giải

Trong monolith:

BEGIN TRANSACTION
→ Update A
→ Update B
COMMIT / ROLLBACK

ACID đảm bảo consistency

Trong microservices:

Service A → Service B → Service C

Không có global transaction

Nếu B fail → A đã commit rồi

Solution: Saga

Thay vì rollback DB transaction →

Dùng compensation actions

Saga Flow (Example)

Order system

1. Create Order (Order Service)
2. Reserve Inventory (Inventory Service)
3. Charge Payment (Payment Service)

Nếu Payment fail:

→ Compensate:
   - Release Inventory
   - Cancel Order

Không rollback DB

Roll forward bằng undo actions

2 Types of Saga

Choreography (Event-driven)

Concept

• Không có central coordinator
• Services communicate bằng events

Ưu điểm

• Loose coupling
• Scalable
• Không single point of failure

Nhược điểm

• Hard to debug
• Event flow phức tạp
• Difficult to track state

Orchestration (Centralized)

Concept

• Có Saga Orchestrator
• Điều phối các bước

Ưu điểm

• Dễ control flow
• Dễ debug
• Clear logic

Nhược điểm

• Central dependency
• Potential bottleneck

So sánh nhanh

Compensation (Key Concept)

Compensation là gì?

• Action để undo business effect

Ví dụ

Lưu ý

• Không phải rollback DB
• Là business-level undo

Challenges

Partial failure

• Một bước fail → cần rollback đúng thứ tự

Idempotency

• Event có thể xử lý nhiều lần → cần idempotent handlers

Ordering

• Event có thể out-of-order

Debugging

• Khó trace flow

Saga vs 2PC

Microservices → dùng Saga

Monolith / DB → dùng ACID / 2PC

Use Cases

• Order processing
• Payment systems
• Booking systems
• Inventory management

Implementation Tools

• Kafka (event-driven saga)
• RabbitMQ
• Orchestrator service
• Temporal / Cadence
• AWS Step Functions

One-liner

Saga = distributed transaction without rollback, using compensation