ما هي الضغط العكسي (Backpressure) في streams وكيف تتعامل معها؟

Question

Accepted Answer

**الضغط العكسي** هو ما يحدث عندما يتم إنتاج البيانات **بسرعة أكبر مما يمكن استهلاكها**. في streams، إذا كان مصدر قراءة سريع يدفع البيانات إلى وجهة كتابة بطيئة، فإن البيانات غير المستهلكة تتراكم في الذاكرة — وبدون معالجة، يستمر هذا المخزن المؤقت في النمو حتى تنفد الذاكرة. الضغط العكسي هو الآلية (والانضباط) للحفاظ على توازن بين المُنتِج والمستهلك.

## المشكلة

```text
Fast source ──(1 GB/s)──▶ Slow destination (10 MB/s write speed)
                          ▲
             The 990 MB/s difference piles up in a memory buffer → OOM crash
```

مثال: قراءة ملف ضخم بسرعة وكتابته إلى socket شبكة بطيء أو قرص — إذا لم تحترم سرعة الوجهة، ستنمو الذاكرة بشكل هائل.

## pipe تتعامل مع الضغط العكسي تلقائياً

```js
import { createReadStream, createWriteStream } from "fs";

// ✅ pipe automatically pauses the source when the destination is full,
//    and resumes it when the destination drains — backpressure handled for you
createReadStream("huge.file").pipe(createWriteStream("copy.file"));
```

هذا هو السبب الرئيسي لاستخدام `pipe`/`pipeline`: فهي تدير الضغط العكسي نيابة عنك، توقف واستئناف التدفق بحيث تبقى الذاكرة محدودة بغض النظر عن عدم تطابق الحجم.

## معالجتها يدويًا باستخدام قيمة إرجاع write()

```js
// write() returns FALSE when the internal buffer is full — that's the backpressure signal
readable.on("data", (chunk) => {
  const ok = writable.write(chunk);
  if (!ok) {
    readable.pause();                       // stop reading — destination is full
    writable.once("drain", () => readable.resume()); // resume when it drains
  }
});
```

إذا كنت تتعامل مع streams يدويًا، القاعدة هي: عندما يُرجع `writable.write()` قيمة `false`، **وقّف** القراءة، و**استأنفها** عند حدث `drain` للكتابة. تجاهل إرجاع `false` هو خطأ الضغط العكسي الكلاسيكي.

## مع async iteration (حديث، نظيف)

```js
// for-await respects backpressure naturally — it awaits each chunk's processing
for await (const chunk of readable) {
  await processSlowly(chunk); // only pulls the next chunk when ready
}
```

## فضّل pipeline من أجل السلامة

```js
import { pipeline } from "stream/promises";
await pipeline(source, transform, destination); // backpressure + error handling + cleanup
```

## لماذا يهم

الضغط العكسي مفهوم دقيق لكن حاسم لأي خدمة Node تتعامل مع البيانات بكثافة (معالجة الملفات، المراجعة، البث، ETL).

تجاهله — عن طريق تخزين كل شيء أو تجاهل قيمة `write()` — يسبب نمو ذاكرة غير محدود وانهيارات تحت الحمل، غالباً فقط في الإنتاج مع البيانات الكبيرة.

فهم أن `pipe`/`pipeline` تتعامل معها تلقائياً (السبب الرئيسي لتفضيلهما)، وكيفية احترامها يدويًا (توقف عند `false`، استئناف عند `drain`) أو عبر `for await`، هو ما يمكّنك من بناء أنظمة streaming تبقى مستقرة من حيث الذاكرة بغض النظر عن حجم أو سرعة البيانات.

إنها علامة مميزة لاستخدام stream كفء.