Pastāstiet mums par savu pieredzi ar ziņojumu starpniekiem un to izmantošanu projektos

Node.js projektos ietvaros esmu strādājis ar ziņojumu starpniekiem, piemēram, RabbitMQ un Apache Kafka. Tie tiek izmantoti, lai organizētu asīnhronu ziņojumu apmaiņu starp sistēmas komponentiem, kas palielina mērogojamību un kļūdu izturību.

Piemēram, vienā projektā RabbitMQ tika izmantots fonu uzdevumu apstrādei: tīmekļa serveris sūtīja ziņojumus rindā, un atsevišķs darbinieks tos apstrādāja. Tas ļāva atvieglot galveno plūsmu un uzlabot lietojumprogrammas reakcijas ātrumu.

Piemērs, kā nosūtīt ziņojumu uz RabbitMQ Node.js ar bibliotēkas amqplib palīdzību:

const amqp = require('amqplib');

async function sendMessage() {
  const connection = await amqp.connect('amqp://localhost');
  const channel = await connection.createChannel();
  const queue = 'tasks';
  const msg = 'Process this task';

  await channel.assertQueue(queue, { durable: true });
  channel.sendToQueue(queue, Buffer.from(msg));

  console.log("[x] Sent '%s'", msg);
  setTimeout(() => {
    connection.close();
  }, 500);
}

sendMessage();

Šādi ziņojumu starpnieki palīdz būvēt izplatītas un mērogojamas sistēmas ar efektīvu datu apstrādi.