📖 English Edition (Bản tiếng Anh)

Điều kiện tiên quyết: Xem lại Phần 5 — Bóc Tách Dữ Liệu Magento 2: Làm Phẳng EAV để nắm vững quy trình bóc tách dữ liệu.

Di Trú Cơ Sở Dữ Liệu Magento: Chọn Shared DB, Debezium CDC Hay Event Bus?

Tóm tắt cốt lõi: Mặc dù việc kết nối trực tiếp các microservice mới vào cơ sở dữ liệu MySQL hiện tại của Magento (Mô hình Shared Database) mang lại cảm giác triển khai nhanh chóng ban đầu, nó lại tạo ra sự ràng buộc mã nguồn nghiêm trọng, nguy cơ xung đột khóa bảng chéo và vi phạm nguyên tắc cách ly của microservices. Tiêu chuẩn kiến trúc sản xuất 2027 bắt buộc sử dụng Debezium 3.0+ Change Data Capture (CDC) truyền tải các biến động dữ liệu qua Redpanda/Kafka về cơ sở dữ liệu riêng của từng dịch vụ. Kiến trúc này giải phóng hoàn toàn sự phụ thuộc cấu trúc bảng, đảm bảo độ trễ đồng bộ dưới 50ms và duy trì tính nhất quán ghi kép qua mẫu Transactional Outbox.

Khi phân tách một ứng dụng thương mại điện tử nguyên khối, chiến lược đồng bộ hóa cơ sở dữ liệu sẽ định đoạt việc dự án thành công êm đẹp hay biến thành một thảm họa phân tán làm sai lệch dữ liệu tài chính.

Các đội ngũ kỹ sư thường chọn con đường tắt: cấu hình cho dịch vụ Go Catalog mới trỏ trực tiếp vào các bảng MySQL của Magento. Chỉ sau vài tuần, các tiến trình indexer của Magento bắt đầu xung đột khóa với pool kết nối của Go, các bản vá cập nhật bảng làm hỏng truy vấn của microservice, và doanh nghiệp rơi vào tình thế “tiến thoái lưỡng nan”.

1. Bản Đồ Kiến Trúc: Shared DB vs Debezium CDC Mesh

flowchart TD
    subgraph Antipattern ["1. Phản Mẫu Shared Database (Rủi Ro Cực Cao)"]
        MagentoPHP1["Magento Monolith"] --> MySQL_Shared["Cơ Sở Dữ Liệu MySQL Dùng Chung Duy Nhất"]
        GoCatalog1["Go Catalog Service"] --> MySQL_Shared
        GoCart1["Go Cart Service"] --> MySQL_Shared
        MySQL_Shared --> Deadlock["Ràng Buộc Cấu Trúc Bảng & Khóa Chéo Hệ Thống"]
    end

    subgraph Recommended_CDC ["2. Kiến Trúc Debezium 3.0+ CDC (Tiêu Chuẩn Doanh Nghiệp)"]
        MagentoPHP2["Magento Monolith"] --> MySQL_Source["Magento MySQL 8.4 (Bật Binlog)"]
        MySQL_Source --> Debezium["Động Cơ CDC Debezium 3.0+"]
        Debezium --> Redpanda["Luồng Sự Kiện Redpanda / Kafka"]
        
        Redpanda --> Worker1["Worker Đồng Bộ Catalog"]
        Redpanda --> Worker2["Worker Đồng Bộ Tồn Kho"]
        
        Worker1 --> CatalogDB["PostgreSQL Riêng Của Catalog"]
        Worker2 --> InventoryDB["Redis / PostgreSQL Riêng Của Tồn Kho"]
    end

2. Mẫu Transactional Outbox Trong Dịch Vụ Go

Khi các microservice Go cập nhật trạng thái nghiệp vụ, chúng phải phát sự kiện sang Kafka mà không được để xảy ra tình trạng dữ liệu đã lưu nhưng sự kiện bị thất lạc (Split-Brain). Mẫu Transactional Outbox đảm bảo việc lưu dữ liệu nghiệp vụ và ghi nhận sự kiện được thực thi trọn vẹn trong một giao dịch cơ sở dữ liệu cục bộ duy nhất:

sequenceDiagram
    autonumber
    participant App as "Dịch Vụ Đơn Hàng (Go)"
    participant DB as "PostgreSQL Cục Bộ"
    participant Relay as "Tiến Trình Outbox Relay / Debezium"
    participant Kafka as "Luồng Kafka / Redpanda"

    App->>DB: Bắt Đầu Giao Dịch (BEGIN)
    App->>DB: INSERT INTO orders (...)
    App->>DB: INSERT INTO outbox_events (event_id, payload, status='PENDING')
    App->>DB: Xác Nhận Giao Dịch (COMMIT)
    
    Note over DB: Dữ liệu đã lưu nguyên tử! Không bao giờ mất sự kiện.
    Relay->>DB: Đọc các sự kiện có status='PENDING'
    Relay->>Kafka: Phát sự kiện tới Topic 'commerce.orders.v1'
    Relay->>DB: Cập nhật status='PUBLISHED'

3. Cấu Hình Debezium Connector Chuẩn Doanh Nghiệp

{
  "name": "magento-cdc-connector",
  "config": {
    "connector.class": "io.debezium.connector.mysql.MySqlConnector",
    "tasks.max": "1",
    "database.hostname": "aurora-mysql.internal.net",
    "database.port": "3306",
    "database.user": "debezium_cdc",
    "database.password": "${env:CDC_PASSWORD}",
    "database.server.id": "184054",
    "topic.prefix": "magento_cdc",
    "table.include.list": "magento2.sales_order,magento2.sales_order_item,magento2.cataloginventory_stock_item",
    "schema.history.internal.kafka.bootstrap.servers": "redpanda.internal.net:9092",
    "schema.history.internal.kafka.topic": "schema-changes.magento",
    "decimal.handling.mode": "double",
    "tombstones.on.delete": "true"
  }
}

4. Ma Trận Đánh Giá 16 Tiêu Chí Đồng Bộ Dữ Liệu

❓ Câu Hỏi Thường Gặp (FAQ)

🔗 Bước Tiếp Theo: Khám phá Phần 7 — Laravel vs Golang: Nên Phát Triển Tính Năng Mới Bằng Ngôn Ngữ Nào?.