RabbitMQ에서 메시지를 어떻게 생성(produce)하고 소비(consume)합니까(기본 사용법)?

Question

Accepted Answer

RabbitMQ의 기본 사용법은 메시지를 exchange/queue로 **발행(publish)**하고 **소비(consume)**하는 것 — 일반적으로 client 라이브러리(AMQP 프로토콜 사용)를 통해 — 입니다. 기본 produce/consume 흐름을 이해하는 것이 실무적 출발점입니다.

## 메시지 생성(발행)

```js
// connection 연결, channel 생성, queue 선언, 발행
const channel = await connection.createChannel();
await channel.assertQueue('tasks', { durable: true });   // queue가 존재하는지 보장
channel.sendToQueue('tasks',
  Buffer.from(JSON.stringify({ task: 'send-email' })),
  { persistent: true }                                    // persistent 메시지 (재시작 후 살아남음)
);
// → 메시지를 발행 (여기서는 기본 exchange를 통해 queue로 직접)
```

## 메시지 소비

```js
await channel.assertQueue('tasks', { durable: true });
channel.prefetch(1);   // 한 번에 하나씩 처리 (공정한 dispatch)
channel.consume('tasks', (msg) => {
  const data = JSON.parse(msg.content.toString());
  // 작업 처리...
  channel.ack(msg);     // 처리 후 ACKNOWLEDGE (신뢰성 있음)
}, { noAck: false });   // manual ack (신뢰성 있음)
```

## 핵심 실무 포인트

```text
✓ CLIENT 라이브러리 사용 (Node는 amqplib, Python은 pika, Java client 등)
✓ CHANNEL → 작업을 위한 경량 connection (connection은 재사용, channel을 사용)
✓ DURABLE queue + PERSISTENT 메시지 → broker 재시작 후 살아남음 (durability)
✓ MANUAL ack → 신뢰성 있는 처리; PREFETCH → 공정한 작업 분배
✓ 에러, 재연결 처리; 라우팅을 위해 exchange/binding 사용 (기본 exchange를 넘어)
```

## 왜 중요한가

기본 produce/consume 사용법을 이해하는 것은 가치가 있습니다. 이는 **RabbitMQ 사용의 실무적 출발점**이므로 필요한 실전 지식입니다.

메시지를 발행하고 소비하는 방법을 아는 것은 애플리케이션에서 RabbitMQ를 사용하는 기본 기술입니다.

**메시지 생성** — connection 연결, channel 생성, queue 선언, 메시지 발행(durability를 위한 persistence와 함께) — 을 이해하는 것은 기본 쓰기 작업입니다.

**메시지 소비** — queue 선언, prefetch 설정, 메시지 소비, 처리, 처리 후 **acknowledge**(신뢰성을 위한 manual ack) — 를 이해하는 것은 중요한 신뢰성 관행을 포함하는 기본 읽기 작업입니다.

**핵심 실무 포인트** — client 라이브러리(amqplib, pika 등) 사용, **channel** 사용(작업을 위한 경량 connection, connection 재사용), 재시작을 견디기 위한 **durable queue + persistent 메시지**, 신뢰성 있는 처리를 위한 **manual ack**과 공정한 작업 분배를 위한 **prefetch**, 에러/재연결 처리와 라우팅을 위한 exchange/binding 사용 — 은 실제 RabbitMQ 사용을 위한 실무적 고려사항을 반영합니다.

이 실무 포인트들(channel, durability, manual ack, prefetch)은 개념적 지식(queue, acknowledgment, durability)을 실제 코드와 연결하며 신뢰성 있는 RabbitMQ 애플리케이션 구축을 반영합니다.

메시지를 생성하고 소비하는 것은 애플리케이션에서 RabbitMQ를 사용하는 기본 실무 기술이며, 기본 흐름과 실무 포인트(channel, durability, manual ack, prefetch)를 이해하는 것이 필요한 실전 지식이므로, RabbitMQ의 기본 produce/consume 사용법을 이해하는 것은 가치 있고 실무적으로 관련 있는 지식입니다. RabbitMQ 사용의 실무적 출발점으로, 개념을 코드와 연결하며(durable queue, persistent 메시지, manual ack의 신뢰성 관행과 함께), 실제로 RabbitMQ로 애플리케이션을 구축하는 누구에게나 필요합니다.