Stream Nedir? Node.js'te Veri Akışı İşleme

Adı : Stream Nedir? Node.js'te Veri Akışı İşleme

Stream, veri akışını okumak veya yazmak için kullanılan bir işlemler setidir. Node.js'te veri akışını işlemek için kullanılan stream modülü, büyük veri kütlelerini daha etkin bir şekilde işlemenizi sağlar. Bu yazıda, Node.js'te streame dair daha fazla bilgi vereceğim ve değişik örneklerle konuyu açıklayacağım.

Stream, veriyi parçalar halinde okumak veya yazmak için çeşitli yöntemler sunar. Bu, bir dosyadan veri okurken veya bir ağ bağlantısı üzerinden veri gönderirken özellikle faydalıdır. Veriyi parçalara ayırarak, bellekteki tüketim ve işleme açısından daha verimli çalışmayı sağlar. Stream'ler, bellek kullanımını optimize ederek aynı anda büyük miktarda veriyi işleyebilmenizi sağlar.

Node.js, dört farklı stream türü sunar:

1. Readable Stream: Veri kaynağından veri okuyan bir stream türüdür. Örneğin, bir dosyadan veya bir ağ bağlantısı üzerinden veri okurken kullanılır.

2. Writable Stream: Veri hedefine veri yazan bir stream türüdür. Bu, dosyalara veya ağ bağlantılarına veri yazarken kullanılır.

3. Duplex Stream: Hem veri okuyan hem de veri yazan bir stream türüdür. Bu, bir sunucu istemci ilişkisi gibi çift yönlü veri iletişiminde kullanılır.

4. Transform Stream: Giriş verisini bir dönüşüm işlemine tabi tutan ve sonucunu çıktıya yazan bir stream türüdür. Bu, veri dönüşümü gerektiren senaryolarda kullanılır.

Node.js'teki stream modülü, bu stream türlerinin çalışmasını sağlar ve çeşitli yöntemler sunar. Örneğin, bir Readable Stream'in \"data\" olayına abone olarak veri parçalarını okuyabilir veya Writable Stream üzerinden veri yazabilirsiniz.

Aşağıda, Node.js'te stream kullanarak bir dosyadan veri okuma örneği verilmiştir:

```javascript
const fs = require('fs');

const readableStream = fs.createReadStream('dosya.txt');

readableStream.on('data', (chunk) => {
console.log(`Okunan veri: ${chunk}`);
});

readableStream.on('end', () => {
console.log('Veri okuma tamamlandı.');
});
```

Yukarıdaki örnekte, `createReadStream` yöntemiyle bir Readable Stream oluşturulur ve \"data\" olayına abone olarak veri parçalarını okuruz. \"end\" olayı, verinin tamamen okunduğunda tetiklenir.

Aynı şekilde, aşağıdaki örnekte bir Writable Stream kullanarak veriyi bir dosyaya yazma işlemini görebilirsiniz:

```javascript
const fs = require('fs');

const writableStream = fs.createWriteStream('hedef.txt');

writableStream.write('Selam, dünya!');
writableStream.end();
```

Bu örnekte, `createWriteStream` yöntemiyle bir Writable Stream oluşturulur ve `write` yöntemiyle veri yazılır. İşlemi tamamlamak için `end` yöntemi çağrılır.

## Örnekler

1. Bir dosyadan veri okumak ve her parçayı büyük harfe dönüştürerek yeni bir dosyaya yazmak:

```javascript
const fs = require('fs');
const { Transform } = require('stream');

const readableStream = fs.createReadStream('kaynak.txt');
const writableStream = fs.createWriteStream('hedef.txt');

const transformStream = new Transform({
transform(chunk, encoding, callback) {
const upperCaseChunk = chunk.toString().toUpperCase();
this.push(upperCaseChunk);
callback();
}
});

readableStream.pipe(transformStream).pipe(writableStream);
```

Bu örnekte, `createReadStream` ve `createWriteStream` ile birer Readable ve Writable Stream oluşturulur. Ardından, bir Transform Stream oluşturulur ve her parçadaki veriyi büyük harfe dönüştürmek için `transform` yöntemi kullanılır. Son olarak, `pipe` yöntemiyle tüm stream'ler birbirine bağlanır ve veriyi dönüştürerek yeni dosyaya yazılır.

2. HTTP talebine yanıt olarak stream kullanma:

```javascript
const http = require('http');
const fs = require('fs');

const server = http.createServer((req, res) => {
const readableStream = fs.createReadStream('dosya.txt');
readableStream.pipe(res);
});

server.listen(3000, () => {
console.log('Sunucu çalışıyor...');
});
```

Bu örnekte, bir HTTP sunucusu oluşturulur ve gelen her talebe bir dosyanın içeriğini stream olarak yanıt döner. Verinin tamamını belleğe yüklemek yerine, stream sayesinde veri parçalar halinde gönderilir ve daha verimli bir şekilde işlenir.

## Sık Sorulan Sorular

1. Stream nedir?

Stream, veriyi okumak veya yazmak için kullanılan bir işlemler setidir. Büyük veri kütlelerini daha etkin bir şekilde işlemenizi ve bellek kullanımını optimize etmenizi sağlar.

2. Node.js'te stream nasıl kullanılır?

Node.js, stream modülü ile veri akışını işlemeyi sağlar. Öncelikle doğru stream türünü seçmelisiniz (Readable, Writable, Duplex veya Transform). Ardından, ilgili stream'i oluşturmalı ve veriyi okuma veya yazma işlemi için gerekli yöntemleri kullanmalısınız.

3. Stream'lerin avantajları nelerdir?

Stream'ler, bellekteki tüketimi optimizasyon sağlar ve aynı anda büyük miktarda veriyi işlemenizi sağlar. Veriyi parcacıklar halinde işlemek, daha verimli ve hızlı bir işlem yapmanızı sağlar.

4. Stream'lerin dezavantajları nelerdir?

Stream'ler zaman zaman karmaşık olabilir ve kodunuzdaki akışı takip etmek zor olabilir. Ayrıca, bazı durumlarda stream işlemlerini düzgün bir şekilde tamamlamak için ekstra uğraş gerekebilir.

5. Hangi senaryolarda stream kullanılır?

Stream'ler, büyük veri dosyalarının işlenmesi, ağ trafiği üzerinde çalışma, sıkıştırma veya şifreleme gibi senaryolarda oldukça kullanışlıdır. Stream'ler, veriyi parçalara ayırarak bellek kullanımını optimizeler ve daha hızlı işleme sağlar.

Bu yazıda, Node.js'te stream kavramını ve stream modülünü detaylı bir şekilde ele aldık. Veri akışını okumak veya yazmak için kullanılan stream türlerini ve bu türlerin nasıl kullanıldığını gösterdik. Stream'lerin nasıl avantaj sağladığını da tartıştık ve bazı sık sorulan soruları yanıtladık. Stream'lerin daha etkin bir şekilde veri işlemek ve bellek kullanmak için güçlü bir araç olduğunu gördük."