📨 Bài 2: Message Queue Là Gì?

KHÔNG CÓ Message Queue (Đồng bộ):
┌──────────┐  HTTP Request   ┌──────────┐
│ Service A │───────────────▶│ Service B │
│ (đợi...) │◀───────────────│ (xử lý)  │
└──────────┘  HTTP Response  └──────────┘
→ Service A bị BLOCK cho đến khi B xử lý xong!

CÓ Message Queue (Bất đồng bộ):
┌──────────┐   Gửi msg   ┌─────────┐   Nhận msg   ┌──────────┐
│ Service A │────────────▶│  Queue  │─────────────▶│ Service B │
│ (tiếp tục│              │ 📨📨📨  │              │ (xử lý)  │
│  làm việc)│              └─────────┘              └──────────┘
└──────────┘
→ Service A gửi xong là TIẾP TỤC làm việc khác!

// Đồng bộ: Client phải ĐỢI mỗi bước hoàn thành
app.post('/order', async (req, res) => {
    // Bước 1: Lưu đơn hàng (200ms)
    const order = await saveOrder(req.body);

    // Bước 2: Trừ kho (300ms)
    await updateInventory(order.items);

    // Bước 3: Tính phí ship (500ms)
    await calculateShipping(order);

    // Bước 4: Gửi email (2000ms)
    await sendConfirmationEmail(order);

    // Tổng: ~3000ms → User phải đợi 3 giây!
    res.json({ status: 'success', orderId: order.id });
});

// Bất đồng bộ: Chỉ lưu order + gửi vào queue
app.post('/order', async (req, res) => {
    // Bước 1: Lưu đơn hàng (200ms)
    const order = await saveOrder(req.body);

    // Bước 2: Gửi message vào queue (5ms)
    await messageQueue.publish('order-processing', {
        orderId: order.id,
        items: order.items,
        userId: req.user.id
    });

    // Tổng: ~205ms → User nhận response ngay!
    res.json({ status: 'success', orderId: order.id });
});

// Consumer 1: Xử lý kho (chạy background)
messageQueue.consume('order-processing', async (msg) => {
    await updateInventory(msg.items);
    await messageQueue.publish('shipping-calc', msg);
});

// Consumer 2: Tính ship (chạy background)
messageQueue.consume('shipping-calc', async (msg) => {
    await calculateShipping(msg);
    await messageQueue.publish('send-email', msg);
});

// Consumer 3: Gửi email (chạy background)
messageQueue.consume('send-email', async (msg) => {
    await sendConfirmationEmail(msg);
});

// Pseudo Message Queue (để hiểu nguyên lý)
class SimpleQueue {
    constructor() {
        this.queues = {};    // Lưu trữ messages
        this.consumers = {}; // Lưu trữ consumers
    }

    // Producer gửi message
    publish(queueName, message) {
        if (!this.queues[queueName]) {
            this.queues[queueName] = [];
        }
        this.queues[queueName].push(message);
        console.log(`📨 Sent to [${queueName}]:`, message);
        this._processQueue(queueName);
    }

    // Consumer đăng ký nhận message
    subscribe(queueName, handler) {
        this.consumers[queueName] = handler;
        console.log(`👂 Subscribed to [${queueName}]`);
    }

    // Xử lý queue
    async _processQueue(queueName) {
        const handler = this.consumers[queueName];
        if (!handler) return;

        while (this.queues[queueName]?.length > 0) {
            const msg = this.queues[queueName].shift(); // FIFO
            try {
                await handler(msg);
                console.log(`✅ ACK [${queueName}]`);
            } catch (err) {
                console.log(`❌ NACK [${queueName}]:`, err.message);
                // Trong thực tế: retry hoặc đưa vào dead letter queue
            }
        }
    }
}

// Sử dụng
const mq = new SimpleQueue();

// Consumer đăng ký
mq.subscribe('email-queue', async (msg) => {
    console.log(`📧 Sending email to: ${msg.to}`);
    // Giả lập gửi email
    await new Promise(r => setTimeout(r, 1000));
});

// Producer gửi messages
mq.publish('email-queue', { to: 'user@gmail.com', subject: 'Welcome!' });
mq.publish('email-queue', { to: 'admin@gmail.com', subject: 'New user' });