Kiến Trúc TMĐT Serverless Với Cloudflare Workers, D1 & Durable Objects

🇬🇧 Read the English version of this article on tanhdev.com

Tóm tắt cốt lõi (Answer-First): Vận hành một hệ thống thương mại điện tử không cần máy chủ (Zero-Ops Serverless E-Commerce) trên mạng lưới biên của Cloudflare mang lại khả năng mở rộng tức thì với chi phí nhàn rỗi bằng 0 ($0 Idle Cost). Kiến trúc này kết hợp hoàn hảo giữa 4 công nghệ biên tiên tiến:

1. Cloudflare Workers (V8 Isolates): Đóng vai trò API Gateway và tầng tính toán không trạng thái (Stateless Compute), khởi động lạnh dưới 5ms (nhanh gấp 50 lần AWS Lambda) tại hơn 330 trung tâm dữ liệu toàn cầu.
2. Cloudflare D1 (Serverless SQLite): Cơ sở dữ liệu quan hệ ACID phân tán, nhân bản bản sao đọc (Read Replicas) tới sát người dùng với độ trễ truy vấn < 10ms, áp dụng mô hình Database-per-Tenant để vượt qua giới hạn dung lượng 10GB.
3. Durable Objects (Actor Model): Quản lý trạng thái phân tán nhất quán mạnh (Strong Consistency) cho giỏ hàng và khóa giữ hàng tồn kho (Stock Reservation). Nhờ mô hình thực thi đơn luồng (Single-Threaded Execution Loop), Durable Objects triệt tiêu hoàn toàn race condition và bán lố (overselling) mà không cần cụm Redis đắt đỏ.
4. Cloudflare KV & R2: Bộ nhớ đệm danh mục sản phẩm và kho lưu trữ hình ảnh tĩnh với chi phí truyền dữ liệu ra ngoài bằng 0 (Zero Egress Fees).

1. Giấc Mơ “Zero-Ops” Và Sự Thay Đổi Cục Diện Của Điện Toán Biên (Edge Computing)

Trong kiến trúc thương mại điện tử truyền thống (dù là Magento monolith hay Kubernetes microservices), các kỹ sư luôn phải đối mặt với bài toán dung hòa giữa chi phí và khả năng chịu tải:

• Chi phí nhàn rỗi (Idle Resource Waste): Vào ban đêm hoặc những ngày thường lượng truy cập thấp, bạn vẫn phải trả tiền cho các cụm máy chủ ảo (EC2 instances), bộ cân bằng tải (ALB), và cụm Redis ElastiCache luôn bật 24/7.
• Thời gian khởi động lạnh (Cold Starts): Các giải pháp Serverless thế hệ đầu (như AWS Lambda chạy trong VPC kết nối Aurora PostgreSQL) thường mất từ 800ms đến 3,000ms để khởi tạo container và thiết lập kết nối mạng, gây ra độ trễ giật cục khó chịu cho khách hàng.
• Điểm nghẽn vị trí địa lý (Geographical Chokepoint): Khi máy chủ trung tâm đặt tại Singapore hoặc Tokyo, người dùng ở Hà Nội, Sydney hay London đều phải chịu độ trễ mạng vòng đi-về (Network RTT) từ 60ms đến 250ms cho mỗi thao tác chạm trên ứng dụng.

Hạ tầng biên Cloudflare Workers định nghĩa lại hoàn toàn bài toán này bằng việc chạy mã nguồn trực tiếp trên các V8 Engine Isolates nhúng sâu trong hàng trăm điểm hiện diện (Point of Presence - PoP) của Cloudflare trên toàn thế giới:

timeline
    title Tiến Hóa Kiến Trúc Hạ Tầng Thương Mại Điện Tử
    2010 : Bare-Metal Monolith : Máy chủ vật lý, MySQL đơn lẻ, Varnish Cache
    2018 : Container & Kubernetes : AWS EKS, RDS Aurora, Redis Cluster, DevOps nặng nề
    2022 : Serverless Gen 1 : AWS Lambda, API Gateway, DynamoDB (Cold start cao)
    2026 : Edge-Native Zero-Ops : Cloudflare Workers, D1 SQLite, Durable Objects, Zero-Egress R2

2. Bản Vẽ Thiết Kế Hệ Thống TMĐT Edge-Native Hoàn Chỉnh

Toàn bộ chu trình từ lúc duyệt sản phẩm, thêm vào giỏ hàng, khóa tồn kho, cho tới thanh toán Stripe đều được thực thi tại rìa mạng lưới (Edge):

flowchart TB
    UserApp["Khách Hàng (Web / Mobile App)"] --> CFEdge["Cloudflare Global Anycast Edge (330+ Cities)"]

    subgraph EdgeComputePlane ["Tầng Tính Toán Biên (V8 Isolates)"]
        PagesFrontend["Cloudflare Pages<br/>(Astro / Next.js SSG)"]
        APIGateway["Cloudflare Workers<br/>(API Gateway & Routing)"]
    end

    CFEdge --> PagesFrontend
    CFEdge --> APIGateway

    subgraph StorageDataPlane ["Tầng Lưu Trữ & Trạng Thái Phân Tán (Edge Data Plane)"]
        CatalogKV[("Workers KV<br/>Catalog Cache (Sub-2ms)")]
        ProductR2[("Cloudflare R2<br/>Product Images (Zero Egress)")]
        D1Database[("Cloudflare D1<br/>Serverless SQLite DB")]
        DurableObj{{"Durable Objects Cluster<br/>(Single-Threaded Actor Model)"}}
        Queues[("Cloudflare Queues<br/>Async Event Pipeline")]
    end

    APIGateway -->|1. Đọc Catalog cực nhanh| CatalogKV
    APIGateway -->|2. Tải Media hình ảnh| ProductR2
    APIGateway -->|3. Truy vấn User & Order History| D1Database
    APIGateway -->|4. Khóa Tồn Kho & Giỏ Hàng| DurableObj
    
    DurableObj -->|5. Ghi nhận Đơn Hàng chính thức| D1Database
    APIGateway -.->|6. Bắn Sự Kiện Xử Lý Ngầm| Queues
    
    subgraph ExternalThirdParty ["Tích Hợp SaaS Bên Thứ Ba"]
        StripeAPI["Stripe Payments API<br/>(SubtleCrypto Webhooks)"]
        CarrierAPI["3PL Logistics Webhook"]
    end

    APIGateway -->|Xác thực Thanh Toán| StripeAPI
    Queues --> CarrierAPI

    classDef comp fill:#e1f5fe,stroke:#0288d1,stroke-width:2px;
    classDef data fill:#e8f8f5,stroke:#27ae60,stroke-width:2px;
    classDef ext fill:#fff3e0,stroke:#f57c00,stroke-width:2px;

    class PagesFrontend,APIGateway comp;
    class CatalogKV,ProductR2,D1Database,DurableObj,Queues data;
    class StripeAPI,CarrierAPI ext;

3. Thiết Kế Cơ Sở Dữ Liệu D1 SQLite Với Drizzle ORM

Cloudflare D1 là một cơ sở dữ liệu quan hệ SQLite phân tán. Nó cung cấp tính toàn vẹn ACID, cho phép đọc cục bộ tại mọi điểm biên với độ trễ < 10ms thông qua cơ chế tự động nhân bản (Read Replication). Tuy nhiên, D1 áp dụng giới hạn cứng: Dung lượng tối đa 10 GB cho mỗi database.

3.1. Chiến Lược Kiến Trúc: Database-Per-Tenant

Để mở rộng vượt qua giới hạn 10 GB trong các mô hình B2B SaaS hoặc sàn thương mại điện tử đa nhà bán hàng (Multi-vendor), chúng tôi áp dụng mô hình Mỗi Tenant Một Database (Database-per-Tenant). Cloudflare cho phép tạo tối đa 50,000 database D1 trên mỗi tài khoản mà không phát sinh thêm chi phí cố định.

3.2. Mã Nguồn Lược Đồ D1 Bằng Drizzle ORM (src/db/schema.ts)

import { sqliteTable, text, integer, real } from 'drizzle-orm/sqlite-core';

// Bảng tài khoản khách hàng
export const customers = sqliteTable('customers', {
  id: text('id').primaryKey(), // UUIDv7
  email: text('email').notNull().unique(),
  fullName: text('full_name').notNull(),
  createdAt: integer('created_at', { mode: 'timestamp' }).notNull(),
});

// Bảng sản phẩm
export const products = sqliteTable('products', {
  id: text('id').primaryKey(),
  sku: text('sku').notNull().unique(),
  title: text('title').notNull(),
  priceCents: integer('price_cents').notNull(), // Lưu đơn vị Cent để tránh lỗi số thực
  inventoryCount: integer('inventory_count').notNull().default(0),
  updatedAt: integer('updated_at', { mode: 'timestamp' }).notNull(),
});

// Bảng đơn hàng
export const orders = sqliteTable('orders', {
  id: text('id').primaryKey(),
  customerId: text('customer_id').references(() => customers.id),
  totalCents: integer('total_cents').notNull(),
  paymentStatus: text('payment_status', { enum: ['PENDING', 'PAID', 'FAILED', 'REFUNDED'] }).notNull().default('PENDING'),
  fulfillmentStatus: text('fulfillment_status', { enum: ['UNFULFILLED', 'SHIPPED', 'DELIVERED'] }).notNull().default('UNFULFILLED'),
  createdAt: integer('created_at', { mode: 'timestamp' }).notNull(),
});

// Bảng chi tiết dòng đơn hàng
export const orderItems = sqliteTable('order_items', {
  id: text('id').primaryKey(),
  orderId: text('order_id').references(() => orders.id).notNull(),
  productId: text('product_id').references(() => products.id).notNull(),
  quantity: integer('quantity').notNull(),
  unitPriceCents: integer('unit_price_cents').notNull(),
});

4. Xử Lý Tranh Chấp Tồn Kho Bằng Durable Objects (Không Cần Redis)

Trong các đợt mở bán chớp nhoáng (Flash Sale), hàng trăm khách hàng có thể cùng nhấn nút thanh toán cho sản phẩm duy nhất còn lại trong kho. Trong kiến trúc đám mây truyền thống, bạn buộc phải dựng cụm Redis Cluster và sử dụng thuật toán Redlock hoặc Distributed Semaphore.

Trên Cloudflare, Durable Objects (DO) cung cấp giải pháp thanh lịch hơn gấp nhiều lần dựa trên Mô Hình Actor Đơn Luồng (Single-Threaded Actor Model).

4.1. Cơ Chế Điều Phối Đơn Luồng Của Durable Objects

Mỗi sản phẩm có một instance Durable Object duy nhất trên toàn cầu (được ánh xạ bằng ID INVENTORY_DO.idFromName(sku)). Khi có 1,000 yêu cầu giữ hàng đến từ khắp nơi trên thế giới, hệ thống mạng của Cloudflare tự động định tuyến toàn bộ 1,000 request này về chính xác một tiến trình DO duy nhất. Tại đây, các request được xếp hàng đợi và xử lý tuần tự từng lệnh một trong bộ nhớ RAM, loại bỏ 100% khả năng xảy ra race condition.

sequenceDiagram
    autonumber
    participant U1 as Khách Hàng A (Tokyo)
    participant U2 as Khách Hàng B (London)
    participant Worker as Cloudflare Worker Edge
    participant DO as Inventory Durable Object (Duy Nhất)
    participant D1 as D1 Database

    U1->>Worker: POST /checkout (SKU-PS5, Qty: 1)
    U2->>Worker: POST /checkout (SKU-PS5, Qty: 1)
    
    par Định Tuyến Về Cùng 1 Actor
        Worker->>DO: fetch("/reserve", {qty: 1, orderId: "ORD-A"})
        Worker->>DO: fetch("/reserve", {qty: 1, orderId: "ORD-B"})
    end

    activate DO
    Note over DO: Xử lý Đơn Luồng: Lệnh của Khách A vào trước
    DO->>DO: Tồn kho hiện tại: 1 -> Trừ 1 = 0
    DO->>DO: Lưu giữ chỗ tạm trong RAM & State Storage (TTL: 10 phút)
    DO-->>Worker: HTTP 200 OK (Giữ hàng thành công cho Khách A)
    
    Note over DO: Lệnh của Khách B vào sau
    DO->>DO: Tồn kho hiện tại: 0 < 1
    DO-->>Worker: HTTP 409 Conflict ("Hết hàng")
    deactivate DO

    Worker-->>U1: 200 OK -> Chuyển sang bước thanh toán thẻ
    Worker-->>U2: 409 Conflict -> Thông báo sản phẩm vừa hết

4.2. Mã Nguồn TypeScript: Inventory Durable Object Hoàn Chỉnh

// src/objects/InventoryDurableObject.ts
export class InventoryDurableObject implements DurableObject {
  private state: DurableObjectState;
  private stock: number = 0;
  private initialized: boolean = false;

  constructor(state: DurableObjectState) {
    this.state = state;
  }

  private async initialize(initialStock: number) {
    if (!this.initialized) {
      const storedStock = await this.state.storage.get<number>('stock');
      if (storedStock !== undefined) {
        this.stock = storedStock;
      } else {
        this.stock = initialStock;
        await this.state.storage.put('stock', initialStock);
      }
      this.initialized = true;
    }
  }

  async fetch(request: Request): Promise<Response> {
    const url = new URL(request.url);

    if (url.pathname === '/init') {
      const { stock } = await request.json<{ stock: number }>();
      await this.initialize(stock);
      return new Response(JSON.stringify({ status: 'INITIALIZED', stock: this.stock }));
    }

    if (url.pathname === '/reserve') {
      const { quantity, reservationId, ttlMinutes } = await request.json<{
        quantity: number;
        reservationId: string;
        ttlMinutes: number;
      }>();

      await this.initialize(0);

      // Kiểm tra tính hợp lệ của tồn kho ngay trong RAM (Đơn luồng tuyệt đối)
      if (this.stock >= quantity) {
        this.stock -= quantity;
        
        // Lưu trạng thái bền vững
        await this.state.storage.put('stock', this.stock);
        await this.state.storage.put(`res:${reservationId}`, quantity);

        // Thiết lập Alarm tự động hoàn kho nếu khách hàng không thanh toán trong thời hạn
        const currentAlarm = await this.state.storage.getAlarm();
        if (currentAlarm === null) {
          const expireTime = Date.now() + (ttlMinutes || 10) * 60 * 1000;
          await this.state.storage.setAlarm(expireTime);
        }

        return new Response(JSON.stringify({ success: true, remainingStock: this.stock }), { status: 200 });
      }

      return new Response(JSON.stringify({ success: false, message: 'Hết hàng tồn kho' }), { status: 409 });
    }

    if (url.pathname === '/commit') {
      // Xác nhận trừ kho vĩnh viễn sau khi thanh toán Stripe thành công
      const { reservationId } = await request.json<{ reservationId: string }>();
      await this.state.storage.delete(`res:${reservationId}`);
      return new Response(JSON.stringify({ status: 'COMMITTED' }));
    }

    return new Response('Not Found', { status: 404 });
  }

  // Alarm Handler: Tự động chạy khi hết hạn giữ chỗ (Tương đương Redis Key Expiration)
  async alarm(): Promise<void> {
    const reservations = await this.state.storage.list({ prefix: 'res:' });
    for (const [key, qty] of reservations.entries()) {
      // Hoàn lại số lượng tồn kho
      this.stock += Number(qty);
      await this.state.storage.delete(key);
    }
    await this.state.storage.put('stock', this.stock);
  }
}

5. Xử Lý Thanh Toán Stripe Và Webhook Qua WebCrypto Tại Biên

Môi trường thực thi của Cloudflare Workers là V8 Isolates, không phải Node.js truyền thống. Do đó, các thư viện sử dụng các module C++ gốc (Native C++ Addons) hoặc module crypto cũ của Node sẽ không hoạt động.

Chúng tôi sử dụng chuẩn mở WebCrypto (crypto.subtle) tích hợp sẵn của trình duyệt để xác minh chữ ký Webhook của Stripe với độ trễ cực thấp:

// src/handlers/stripeWebhook.ts
import Stripe from 'stripe';

export async function handleStripeWebhook(request: Request, env: Env): Promise<Response> {
  const signature = request.headers.get('stripe-signature');
  if (!signature) {
    return new Response('Missing stripe signature header', { status: 400 });
  }

  // Đọc body dưới dạng text thô (BẮT BUỘC để kiểm tra chữ ký mã hóa)
  const rawBody = await request.text();

  const stripe = new Stripe(env.STRIPE_SECRET_KEY, {
    httpClient: Stripe.createFetchHttpClient(), // Sử dụng Fetch client của Edge
  });

  // Sử dụng SubtleCrypto có sẵn trong V8 runtime
  const cryptoProvider = Stripe.createSubtleCryptoProvider();

  let event: Stripe.Event;
  try {
    event = await stripe.webhooks.constructEventAsync(
      rawBody,
      signature,
      env.STRIPE_WEBHOOK_SECRET,
      undefined,
      cryptoProvider
    );
  } catch (err: any) {
    return new Response(`Webhook Error: ${err.message}`, { status: 400 });
  }

  // Xử lý sự kiện thanh toán thành công
  if (event.type === 'checkout.session.completed') {
    const session = event.data.object as Stripe.Checkout.Session;
    const orderId = session.metadata?.orderId;
    const sku = session.metadata?.sku;

    if (orderId && sku) {
      // 1. Gọi Durable Object để chốt kho vĩnh viễn (Commit)
      const doId = env.INVENTORY_DO.idFromName(sku);
      const inventoryObj = env.INVENTORY_DO.get(doId);
      await inventoryObj.fetch('http://do/commit', {
        method: 'POST',
        body: JSON.stringify({ reservationId: orderId }),
      });

      // 2. Cập nhật trạng thái đơn hàng sang PAID trên D1
      await env.DB.prepare('UPDATE orders SET payment_status = ? WHERE id = ?')
        .bind('PAID', orderId)
        .run();
    }
  }

  return new Response(JSON.stringify({ received: true }), { status: 200 });
}

6. Bảng So Sánh Toàn Diện: Cloudflare Edge Stack vs. AWS Serverless vs. K8s Monolith

7. Kết Luận & Khi Nào Nên Lựa Chọn Cloudflare Cho E-Commerce?

Kiến trúc TMĐT Edge-Native trên Cloudflare không phải là viên đạn bạc cho mọi mô hình kinh doanh, nhưng nó là giải pháp tối thượng cho các trường hợp cụ thể:

Khi nào BẮT BUỘC nên chọn Cloudflare Edge:

1. Bán sản phẩm số (Digital Goods / SaaS / Khóa học): Nơi dữ liệu danh mục gọn nhẹ, không cần quản lý kho hàng vật lý cồng kềnh, và người mua phân bổ khắp toàn cầu.
2. Các thương hiệu D2C chạy Flash Sale ngắn hạn: Nơi traffic bình thường rất thấp nhưng có thể vọt lên 50,000 người cùng lúc khi có KOL livestream. Chi phí nhàn rỗi bằng 0 và Durable Objects triệt tiêu hoàn toàn nỗi lo sập server.
3. Mô hình Headless Commerce kết hợp Shopify: Sử dụng Cloudflare Workers làm tầng tính toán logic trung gian (BFF) để cá nhân hóa giá và khuyến mãi siêu tốc trước khi đẩy về giỏ hàng Shopify.

Khi nào NÊN TRÁNH:

• Doanh nghiệp bán lẻ có hàng triệu SKU phức tạp với các liên kết JOIN đa bảng chồng chéo vượt quá dung lượng 10 GB của D1.
• Hệ thống phụ thuộc nặng nề vào các plugin có sẵn của WooCommerce hoặc hệ sinh thái module của Magento.

🔗 Tài Liệu & Chuyên Đề Chuyên Sâu Liên Quan:

• Di Chuyển Từ Magento Sang Microservices: Playbook 3 Giai Đoạn Zero-Downtime
• Thiết Kế Hệ Sinh Thái 21 Microservices Với Golang & DDD
• MySQL Horizontal Scaling: Vitess, GORM Sharding & Distributed Transactions
• Mastering Event-Driven Architecture với Dapr & Golang

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