Xây dựng một hệ thống phân tán chịu tải lớn hàng triệu yêu cầu đồng thời (High Concurrency & High Traffic) đòi hỏi kiến trúc sư phần mềm phải kết hợp hài hòa giữa Asynchronous Event-Driven, bộ đệm phân tán đa tầng (Multi-tier Caching) và chiến lược phân vùng cơ sở dữ liệu.

1. Tổng Quan Về Kiến Trúc Event-Driven Architecture

Thay vì thực hiện các lời gọi HTTP RESTful đồng bộ (Synchronous Blocking) giữa các service với nhau gây ra hiện tượng nghẽn cổ chai (Bottleneck) và hiệu ứng dây chuyền (Cascading Failure), kiến trúc Event-Driven sử dụng Apache Kafka làm xương sống điều phối.

2. Chiến Lược Caching Đa Tầng (Multi-Tier Caching)

Để giảm thiểu tải đọc đè nặng lên cơ sở dữ liệu quan hệ (PostgreSQL / MySQL), chúng tôi áp dụng mô hình Caching 3 tầng:

• Lớp 1 (L1 Cache): In-Memory Local Cache (Go FreeCache / Caffeine) với TTL 1 - 5 giây.
• Lớp 2 (L2 Cache): Cụm Redis Cluster phân vùng theo hash slot với Read-Replicas.
• Lớp 3 (L3 Cache): Cloudflare Edge Caching cho các API Responses tĩnh.

3. Mã Nguồn Minh Họa Xử Lý Sự Kiện Bằng Golang

Dưới đây là đoạn mã nguồn minh họa Worker Consumer tiêu thụ thông điệp từ Kafka với cơ chế Worker Pool và Graceful Shutdown chuẩn Production:

package main

import (
    "context"
    "fmt"
    "log"
    "os"
    "os/signal"
    "syscall"
    "time"
)

type OrderEvent struct {
    ID        string    `json:"id"`
    UserID    string    `json:"user_id"`
    Amount    float64   `json:"amount"`
    CreatedAt time.Time `json:"created_at"`
}

func processOrder(ctx context.Context, order OrderEvent) error {
    select {
    case <-ctx.Done():
        return ctx.Err()
    default:
        fmt.Printf("[ShowTech Worker] Đang xử lý đơn hàng: %s, Giá trị: $%.2f\n", order.ID, order.Amount)
        time.Sleep(50 * time.Millisecond)
        return nil
    }
}

func main() {
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()

    stopChan := make(chan os.Signal, 1)
    signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)

    go func() {
        <-stopChan
        fmt.Println("\n[ShowTech] Nhận tín hiệu dừng, tiến hành Graceful Shutdown...")
        cancel()
    }()

    fmt.Println("🚀 ShowTech Event Processor đã sẵn sàng nhận tải!")
    <-ctx.Done()
    log.Println("Đã giải phóng tài nguyên an toàn.")
}

4. Cơ Chế Circuit Breaker & Bulkhead Isolation

Khi một dịch vụ thứ cấp phản hồi chậm hoặc bị treo, cơ chế Circuit Breaker (như Sonyflake / Hystrix) sẽ lập tức kích hoạt để tránh cạn kiệt Connection Pool của toàn hệ thống.

5. Kết Luận

Kiến trúc hệ thống quy mô lớn là bài toán đánh đổi liên tục giữa Độ trễ, Độ nhất quán và Độ sẵn sàng. Hãy theo dõi sát sao chỉ số P99 Latency và Error Budget qua hệ thống Prometheus & Grafana!