??

?? ????? ??? ? ?? ??? ? ?? ???? ???? ??????? ???? ??, ?? ?? ?? ??? ??? ??? ??? ? ????. ??? ??? ??? ?????.

??? ??? ?? ?? ?? ??? ??? ???? ???? ? ???? ?????. ????? ???? ????? ?? ???? ???? ??? ?? ??? ???? ??? ???? ???? ??? ??? ?????.

? ????? ? ???? ???, ?? ??, Node.js? ?? ?? ???? ?? ???? ???? ? ??? ???.

???? ??????

???? ???? ?? ??? ??? ?? ???? ???? ??? ? ??? ???? ?? ?? ???????. ??? ?? ??? ??? ?????.

? ????? ???? ? ?? ???? ??? ? ?? ???? ?? ??? ?????.

? ???? ???? ?? ?? ??? ??? ?????.

? ? ???? ??? ??? ?? ????, ??? ??? ?? ? ?? ?? ??? ????.

??? ? ??????

???? ??: ???? ??? ? ?? ??? ?? ???? ???? ??? ?????.

??? ?? ???: CPU, ???, ???? ?? ???? ????? ????? ?????.

??? ??: ?? ????? ?? ?? ??? ????.

Node.js?? Back Pressure? ???? ??

Node.js ??????, ?? ????? ???? ??? ???? ??????? ?? ?? ??? ??? ????? ?????.

1?? ???? ??

Node.js ???? ??? ????? ?????. ???? ??? ? ?? ???? ?????? ???? ?? ???? ???? ?? ??? ? ????.

?: ???? ?? ?? ??? ???

const fs = require('fs');
const writable = fs.createWriteStream('output.txt');

for (let i = 0; i < 1e6; i++) {
  const canWrite = writable.write(`Line ${i}\n`);

  if (!canWrite) {
    writable.once('drain', () => {
      console.log('Drained, resuming writes...');
    });
    break; // Pause writes temporarily
  }
}

2?? API?? ?? ??

? ????? ?? ?? ??? ???? API? ?? ?? ?? ??? ???? ??? ??? ? ????. ?? ?? ?? ??? ???? ?? ??? ?? ??? ??? ? ? ????.

?: ??? ??? ??

const queue = [];
const MAX_QUEUE_SIZE = 100;

function handleRequest(request) {
  if (queue.length >= MAX_QUEUE_SIZE) {
    return { error: "Server overloaded. Try again later." };
  }

  queue.push(request);
  processQueue();
}

function processQueue() {
  if (queue.length > 0) {
    const nextRequest = queue.shift();
    // Process request
  }
}

3?? ??? ?? ???? ??

??? ?? ????? ????? ???? ??? ?? ??? ??? ???? RabbitMQ ?? Kafka? ?? ??? ???? ???? ??? ??? ?? ?? ????.

?: ??? RabbitMQ ??

const fs = require('fs');
const writable = fs.createWriteStream('output.txt');

for (let i = 0; i < 1e6; i++) {
  const canWrite = writable.write(`Line ${i}\n`);

  if (!canWrite) {
    writable.once('drain', () => {
      console.log('Drained, resuming writes...');
    });
    break; // Pause writes temporarily
  }
}

??? RabbitMQ? ?? ??? ?? ack ????? ???? ????? ?? ???? ????? ?????.

?? ?? ?? ??

? ??? ???? ?????: ??? ??? ??? ????? ??? ??? ????.

? ???? ????: ??? ?? ????(?: ??? ??, ??? ???)? ???? ??? ??? ?????.

? ??? ?? ?? ??: ??? ?? ?? ????? ??? ??? ??????(?: ?? ?? ??).

? ?? ??: ?????? ??(?: HTTP 429 ??? ?? ??)? ???? ??????? ??? ??? ????.

??

??? ???? ????? ???? ???? ? ???? ???????. Node.js?? ??? ???? ?? ??? ???? ?? ??? ???? ???? ???? ??????? ??? ? ????. ???, API ?? ??? ?? ???? ???? ???? ?? ??? ???? ???? ?????? ???? ?? ?????.

? ??? ??? ? ?? ??: ??? ??? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!