Խոսեք ձեր փորձի մասին հաղորդագրության բրոքերների հետ և դրանց օգտագործման մասին նախագծերում

Node.js նախագծերում ես աշխատել եմ հաղորդագրության միջնորդների հետ, ինչպիսիք են RabbitMQ և Apache Kafka: Դրանք օգտագործվում են համակարգի բաղադրիչների միջև ասինխրոն հաղորդագրությունների փոխանակումը կազմակերպելու համար, ինչը բարձրացնում է ընդլայնելիությունը և սխալների հանդուրժողականությունը:

Օրինակ, մի նախագծում RabbitMQ- ն օգտագործվում էր ֆոնային առաջադրանքների մշակման համար. վեբ սերվերը ուղարկում էր հաղորդագրություններ հերթին, իսկ առանձին աշխատող դրանք մշակում էր: Սա թույլ էր տալիս բեռը նվազեցնել հիմնական հոսքից և բարելավել հավելվածի արձագանքման արագությունը:

Node.js- ում amqplib գրադարանի օգտագործմամբ RabbitMQ- ն ուղարկելու օրինակ:

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();

Այսպիսով, հաղորդագրության միջնորդները օգնում են կառուցել բաշխված և ընդլայնվող համակարգեր արդյունավետ տվյալների մշակմամբ: