¿Cómo produces y consumes mensajes en RabbitMQ (uso básico)?

Question

IT Interview Practice · Accepted Answer

El uso básico de RabbitMQ implica **publicar** mensajes a un exchange/cola y **consumirlos** — típicamente a través de una biblioteca cliente (usando el protocolo AMQP). Entender el flujo básico de producción/consumo es el punto de entrada práctico.

## Producción (publicación) de mensajes

```js
// connect, create a channel, declare a queue, publish
const channel = await connection.createChannel();
await channel.assertQueue('tasks', { durable: true });   // ensure the queue exists
channel.sendToQueue('tasks',
  Buffer.from(JSON.stringify({ task: 'send-email' })),
  { persistent: true }                                    // persistent message (survives restart)
);
// → publishes a message (here directly to a queue via the default exchange)
```

## Consumo de mensajes

```js
await channel.assertQueue('tasks', { durable: true });
channel.prefetch(1);   // process one at a time (fair dispatch)
channel.consume('tasks', (msg) => {
  const data = JSON.parse(msg.content.toString());
  // process the task...
  channel.ack(msg);     // ACKNOWLEDGE after processing (reliable)
}, { noAck: false });   // manual acks (reliable)
```

## Puntos prácticos clave

```text
✓ Use a CLIENT LIBRARY (amqplib for Node, pika for Python, Java client, etc.)
✓ CHANNELS → lightweight connections for operations (reuse the connection, use channels)
✓ DURABLE queues + PERSISTENT messages → survive broker restart (durability)
✓ MANUAL acks → reliable processing; PREFETCH → fair work distribution
✓ Handle errors, reconnection; use exchanges/bindings for routing (beyond the default exchange)
```

## Por qué es importante

Entender el uso básico de producción/consumo es valioso porque es el **punto de entrada práctico para usar RabbitMQ**, por lo que es conocimiento práctico necesario.

Saber cómo publicar y consumir mensajes es la habilidad fundamental para usar RabbitMQ en aplicaciones.

Entender **producción de mensajes** — conectarse, crear un canal, declarar una cola y publicar mensajes (con persistencia para durabilidad) — es la operación básica de escritura.

Entender **consumo de mensajes** — declarar la cola, establecer prefetch, consumir mensajes, procesarlos y **reconocerlos** después del procesamiento (con acks manuales para confiabilidad) — es la operación básica de lectura que incluye las prácticas importantes de confiabilidad.

Entender los **puntos prácticos clave** — usar una biblioteca cliente (amqplib, pika, etc.), usar **canales** (conexiones ligeras para operaciones, reutilizando la conexión), **colas duraderas más mensajes persistentes** para sobrevivir a reinicios, **acks manuales** para procesamiento confiable y **prefetch** para distribución justa del trabajo, y manejo de errores/reconexión y uso de exchanges/bindings para enrutamiento — refleja las consideraciones prácticas para uso real de RabbitMQ.

Estos puntos prácticos (canales, durabilidad, acks manuales, prefetch) conectan el conocimiento conceptual (colas, reconocimientos, durabilidad) al código actual y reflejan la construcción de aplicaciones RabbitMQ confiables.

Ya que producir y consumir mensajes es la habilidad práctica fundamental para usar RabbitMQ en aplicaciones, y ya que entender el flujo básico y los puntos prácticos (canales, durabilidad, acks manuales, prefetch) es conocimiento práctico necesario, entender el uso básico de producción/consumo de RabbitMQ es conocimiento valioso y prácticamente relevante — el punto de entrada práctico para usar RabbitMQ, conectando conceptos a código (con las prácticas de confiabilidad de colas duraderas, mensajes persistentes y acks manuales), y necesario para cualquiera que realmente construya aplicaciones con RabbitMQ.

Producción (publicación) de mensajes

Consumo de mensajes

Puntos prácticos clave

Por qué es importante

Preguntas relacionadas