What are message queues used for?

Message queues are used to organize asynchronous interaction between components or services in distributed systems. The main goals and advantages:

• Decoupling components: the sender and receiver do not depend on each other directly, which increases resilience and scalability.
• Load buffering: the queue helps smooth out load spikes by processing messages as capacity allows.
• Increased reliability: messages are stored in the queue until successfully processed, reducing the risk of data loss.
• Asynchronous processing: allows tasks to be performed in the background without blocking the main thread.

Example of usage in Node.js with RabbitMQ:

const amqp = require('amqplib');

async function sendMessage(queue, msg) {
  const connection = await amqp.connect('amqp://localhost');
  const channel = await connection.createChannel();
  await channel.assertQueue(queue);
  channel.sendToQueue(queue, Buffer.from(msg));
  setTimeout(() => {
    connection.close();
  }, 500);
}

sendMessage('task_queue', 'Hello World');