RabbitMQ 메시지 큐 실전 활용

Exchange 타입

• Direct: 정확한 라우팅 키 매칭
• Fanout: 모든 큐에 브로드캐스트
• Topic: 패턴 매칭 (*.error, order.#)

Node.js에서 사용

import amqp from "amqplib";
const conn = await amqp.connect("amqp://localhost");
const ch = await conn.createChannel();

await ch.assertQueue("tasks", { durable: true });
ch.sendToQueue("tasks", Buffer.from(JSON.stringify(task)), {
  persistent: true,
});

ch.consume("tasks", (msg) => {
  const task = JSON.parse(msg.content.toString());
  processTask(task);
  ch.ack(msg);
});