19 - Webhooks - Nhận dữ liệu thời gian thực

Điều hướng

Mục lục: 🏠 Wiki N8N - Trang chủ Bài trước: 18-Execute Workflow Node - Thiết kế Sub-workflows Bài tiếp theo: 20-Xử lý mảng Arrays Batching và Phân trang Pagination

🎣 Webhooks — Nhận dữ liệu thời gian thực

Tổng quan

Webhook là cơ chế để các ứng dụng bên ngoài chủ động gửi dữ liệu vào n8n ngay khi có sự kiện xảy ra — thay vì n8n phải liên tục hỏi “có gì mới không?“. Đây là cách nhanh nhất và hiệu quả nhất để xây dựng automation phản ứng real-time.

---

🔄 Polling vs Webhook

sequenceDiagram
    participant N as n8n
    participant A as Ứng dụng ngoài

    rect rgb(255, 200, 200)
        Note over N,A: ❌ Polling (kém hiệu quả)
        loop Mỗi 5 phút
            N->>A: Có gì mới không?
            A-->>N: Không
        end
        N->>A: Có gì mới không?
        A-->>N: Có! Đây là dữ liệu
    end

    rect rgb(200, 255, 200)
        Note over N,A: ✅ Webhook (thời gian thực)
        A->>N: Có sự kiện! Đây là dữ liệu
        Note over N: Xử lý ngay lập tức
    end

---

⚙️ Thiết lập Webhook trong n8n

Bước 1: Thêm Webhook Node

1. Tạo workflow mới
2. Thêm node Webhook làm trigger
3. Chọn HTTP Method (thường là POST)
4. Copy Webhook URL được tạo ra

Bước 2: Đăng ký với ứng dụng ngoài

Dán URL webhook vào phần cài đặt của ứng dụng bên ngoài (Stripe, GitHub, Lark, Typeform…) để chúng biết nơi gửi dữ liệu.

Bước 3: Test Webhook

• Nhấn Listen for Test Event trong n8n
• Trigger sự kiện từ ứng dụng ngoài
• n8n sẽ nhận và hiển thị dữ liệu để bạn kiểm tra

---

📥 Cấu trúc dữ liệu Webhook nhận được

Khi webhook nhận request, n8n cung cấp:

Trường	Mô tả	Ví dụ
$json.body	Nội dung body của request	{ "event": "payment.success", "amount": 100 }
$json.headers	HTTP Headers của request	{ "content-type": "application/json" }
$json.query	Query parameters trên URL	{ "token": "abc123" }
$json.params	Path parameters	{ "id": "user-123" }

---

🔒 Bảo mật Webhook

Webhook URL là công khai

Bất kỳ ai có URL webhook đều có thể gửi request vào workflow của bạn. Luôn xác thực nguồn gửi!

Các cách xác thực:

1. Verify bằng Secret Token

// Trong Code Node sau Webhook
const token = $json.headers["x-webhook-secret"];
if (token !== "your_secret_token") {
  throw new Error("Unauthorized webhook request!");
}

2. Verify bằng Signature (HMAC)

Nhiều dịch vụ (Stripe, GitHub) ký mỗi request bằng HMAC signature. Bạn cần verify signature này trước khi xử lý.

---

🌐 Ví dụ: Webhook nhận thông báo thanh toán Stripe

graph LR
    A["💳 Stripe\n(payment.succeeded)"] -->|POST webhook| B["🎣 n8n Webhook"]
    B --> C["🔒 Verify Stripe\nSignature"]
    C -->|Valid| D["📊 Cập nhật DB\n(đơn hàng)"]
    D --> E["📧 Gửi email\ncảm ơn KH"]
    D --> F["🤖 Thông báo\nSlack team"]
    C -->|Invalid| G["🚫 Từ chối\n& Log lỗi"]

---

🔁 Respond to Webhook

n8n cho phép bạn gửi phản hồi ngay lập tức về ứng dụng đã gửi webhook:

• Immediately: Phản hồi ngay 200 OK mà không cần chờ workflow hoàn thành
• When Last Node Finishes: Phản hồi sau khi toàn bộ workflow chạy xong, có thể trả về data
• Using Respond to Webhook Node: Tự chỉ định nội dung phản hồi (status code, body, headers)

---

Điều hướng

Bài trước: 18-Execute Workflow Node - Thiết kế Sub-workflows Bài tiếp theo: 20-Xử lý mảng Arrays Batching và Phân trang Pagination