Node js Stream

Node js stream iki nokta arasında gerçekleşicek veri transferini düzenliyen mekanizmadır. Pipe, okunur stream nesnesinin yazılır stream nesnesine veri yolu tanımlanabilir. Bu bağlamda veri akışı kontrölü pipe bırakılır.





Okunabilir Stream
Dosya stream nesnesi olarak açılır ve içerisindeki veriler veri parçaları halinde iletilir.
Veri parçası ulaştığında data olayı tetiklenir data olayı tetiklendiği zaman ise dinleyici devreye girir.Ulaşan veriler  chunk nesnesinden okunan_veri değişkenine atanır. Dosya veri aktarımı bittiği zaman end olayı tetiklenir.

var fs = require('fs');
var path = require('path');
dosyaKonumu = __dirname+path.sep+'/files/25.txt';

ReadableStream = fs.createReadStream(dosyaKonumu);
var okunanVeri = '';

ReadableStream.setEncoding('utf-8');

ReadableStream.on('data', function(chunk){
okunanVeri += chunk;
});

ReadableStream.on('end', function(){
console.log('okunan veri : ' + okunanVeri);
});

Okunabilir Stream

var fs = require('fs');
var path = require('path');
kaynakKonumu = __dirname+path.sep+'/files/26.txt';
hedefKonumu = __dirname+path.sep+'/files/26.1.txt';

var readableStream = fs.createReadStream(kaynakKonumu);
var writeableStream = fs.createWriteStream(hedefKonumu);

readableStream.setEncoding('utf-8');

readableStream.on('data', function(chunk){
writeableStream.write(chunk);
})

Pipe, okunur stream nesnesinin yazılır stream nesnesine veri yolu tanımlanabilir. Bu bağlamda veri akışı kontrölü pipe bırakılır.

var fs = require('fs');
var path = require('path');
kaynakKonumu = __dirname+path.sep+'/files/27.txt';
hedefKonumu = __dirname+path.sep+'/files/27.1.txt';

var readableStream = fs.createReadStream(kaynakKonumu);
var writeableStream = fs.createWriteStream(hedefKonumu);

readableStream.setEncoding('utf-8');

readableStream.pipe(writeableStream);







Related Posts

Node js Stream
4/ 5
Oleh