Для чего нужны очереди сообщений?

Очереди сообщений используются для организации асинхронного взаимодействия между компонентами или сервисами в распределённых системах. Основные цели и преимущества:

• Декуплирование компонентов: отправитель и получатель не зависят друг от друга напрямую, что повышает устойчивость и масштабируемость.
• Буферизация нагрузки: очередь позволяет сглаживать пики нагрузки, обрабатывая сообщения по мере возможности.
• Повышение надёжности: сообщения сохраняются в очереди до успешной обработки, что снижает риск потери данных.
• Асинхронная обработка: позволяет выполнять задачи в фоне, не блокируя основной поток.

Пример использования в Node.js с 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');