Kiến Trúc Event-Driven Với RabbitMQ và Node.js: Xử Lý Tác Vụ Bất Đồng Bộ

Trong các ứng dụng quy mô lớn, việc bắt người dùng chờ đợi một request đồng bộ hoàn thành các tác vụ nặng (như gửi email, resize hàng loạt ảnh hay xuất file báo cáo Excel) sẽ làm trải nghiệm người dùng giảm sút nghiêm trọng.

1. Giải pháp: Hàng đợi thông điệp (Message Queue)#

Với kiến trúc Event-Driven, web server chỉ cần tiếp nhận request của khách hàng, đẩy một payload nhỏ vào Message Queue (RabbitMQ) và phản hồi ngay 202 Accepted. Một hoặc nhiều Worker phía sau sẽ tiêu thụ (consume) thông điệp và xử lý ngầm trong nền.

import amqp from 'amqplib';
 
export async function publishOrderEvent(orderData: any) {
  const connection = await amqp.connect(process.env.RABBITMQ_URL || 'amqp://localhost');