Akışlarda (streams) arka basıncı (backpressure) nedir ve bunu nasıl ele alırsınız?

Question

Accepted Answer

**Arka basıncı (Backpressure)**, veri **tüketilebilecekten daha hızlı üretildiğinde** ortaya çıkan durumdur. Akışlarda, hızlı bir okunabilir kaynak yavaş bir yazılabilir hedefe veri iterse, tüketilmemiş veriler bellekte arabelleğe alınır — ve bunu ele almazsa, arabellek bellek tükenene kadar büyür. Arka basıncı, üretici ve tüketiciyi dengede tutma mekanizması (ve disiplini)dir.

## Sorun

```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
```

Örnek: büyük bir dosyayı hızlı okuyor ve bunu yavaş bir ağ soketine veya diske yazıyorsunuz — hedefin hızına saygı göstermezseniz, bellek şişer.

## pipe arka basıncını otomatik olarak ele alır

```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"));
```

Bu, `pipe`/`pipeline` kullanmanın önemli nedenlerinden biridir: boyut uyumsuzluğu ne olursa olsun bellek sınırlı kalması için akışı duraklatıp devam ettirerek arka basıncı yönetirler.

## write() döndürülen değeriyle manuel olarak ele almak

```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
  }
});
```

Akışları manuel olarak ele alıyorsanız, kural şudur: `writable.write()` `false` döndürüldüğünde, okunabiliri **duraklatın** ve yazılabilirin `drain` olayında **devam ettirin**. `false` dönüşünü göz ardı etmek, klasik arka basıncı hatası olur.

## Async yineleme ile (modern, temiz)

```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
}
```

## Güvenlik için pipeline'ı tercih edin

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

## Neden önemli

Arka basıncı, herhangi bir veri yoğun Node hizmeti için (dosya işleme, proxy, akış, ETL) ince ama kritik bir kavramdır.

Bunu göz ardı etmek — her şeyi arabelleğe almak veya `write()` döndürülen değerini göz ardı etmek — sınırsız bellek büyümesine ve yük altında çökmelere neden olur, çoğunlukla sadece üretimde büyük verilerle görülür.

`pipe`/`pipeline` tarafından otomatik olarak ele alındığını (bunları tercih etmenin ana nedeni) ve manuel olarak nasıl saygı gösterilmesi gerektiğini (`false`de duraklatma, `drain`de devam ettirme) veya `for await` aracılığıyla anlamak, veri ne kadar büyük veya hızlı olursa olsun bellekçe stabil kalan akış sistemleri oluşturmanıza olanak sağlar.

Bu, yetkin akış kullanımının belirleyici özelliğidir.