Message Queues with RabbitMQ: Decoupling Your Services

Message queues enable asynchronous communication between services. RabbitMQ is one of the most popular message brokers.

## Why Message Queues?

- Decouple services
- Handle traffic spikes
- Improve reliability
- Enable async processing

## Key Concepts

- **Producer**: Sends messages
- **Queue**: Stores messages
- **Consumer**: Receives messages
- **Exchange**: Routes messages to queues

## Node.js Example

```javascript
const amqp = require('amqplib/callback_api');

// Producer
amqp.connect('amqp://localhost', (err, conn) => {
 conn.createChannel((err, ch) => {
   ch.assertQueue('tasks');
   ch.sendToQueue('tasks', Buffer.from('Hello'));
 });
});

// Consumer
amqp.connect('amqp://localhost', (err, conn) => {
 conn.createChannel((err, ch) => {
   ch.assertQueue('tasks');
   ch.consume('tasks', (msg) => {
     console.log(msg.content.toString());
     ch.ack(msg);
   });
 });
});
```

## Exchange Types

```javascript
// Direct: exact routing key match
ch.assertExchange('logs', 'direct', { durable: true });

// Topic: wildcard routing
ch.assertExchange('logs', 'topic', { durable: true });
ch.bindQueue(q.queue, 'logs', '*.error');

// Fanout: broadcast to all queues
ch.assertExchange('logs', 'fanout', { durable: true });
```

## Best Practices

1. Use durable queues and persistent messages
2. Set prefetch count for fair dispatch
3. Handle dead-letter queues
4. Monitor queue depth
5. Use acknowledgments properly

## Conclusion

RabbitMQ improves system resilience by decoupling services. Start with simple queues and evolve to complex routing as needed.