Cara mengonversi file menjadi streaming di javascript

Misalnya, saat Anda menampilkan sesuatu ke konsol menggunakan konsol. fungsi log, Anda sebenarnya menggunakan aliran untuk mengirim data ke konsol

Node. js juga memiliki kemampuan untuk mengalirkan data dari file sehingga dapat dibaca dan ditulis dengan tepat. Sekarang kita akan melihat contoh bagaimana kita dapat menggunakan stream untuk membaca dan menulis dari file. Kita perlu mengikuti langkah-langkah yang disebutkan di bawah untuk contoh ini

Langkah 1) Buat file bernama data. txt yang memiliki data di bawah ini. Anggaplah file ini disimpan di drive D mesin lokal kita

Tutorial Node. js

pengantar

Acara

Generator

Konektivitas Data

Menggunakan Jasmin

Langkah 2) Tulis kode yang relevan yang akan menggunakan aliran untuk membaca data dari file

var fs = require("fs");
var stream;
stream = fs.createReadStream("D://data.txt");

stream.on("data", function(data) {
    var chunk = data.toString();
    console.log(chunk);
}); 

Penjelasan Kode. -

1. Pertama-tama kita harus menyertakan modul 'fs' yang berisi semua fungsi yang diperlukan untuk membuat aliran
2. Selanjutnya kita membuat aliran yang dapat dibaca dengan menggunakan metode – createReadStream. Sebagai input, kami memberikan lokasi data kami. file txt
3. Uap. on function adalah event handler dan di dalamnya, kita menentukan parameter pertama sebagai 'data. ' Ini berarti bahwa setiap kali data masuk dalam aliran dari file, maka jalankan fungsi panggilan balik. Dalam kasus kami, kami mendefinisikan fungsi panggilan balik yang akan melakukan 2 langkah dasar. Yang pertama adalah mengonversi data yang dibaca dari file sebagai string. Yang kedua adalah mengirim string yang dikonversi sebagai output ke konsol
4. Kami mengambil setiap potongan data yang dibaca dari aliran data dan mengubahnya menjadi string
5. Akhirnya, kami mengirimkan output dari setiap potongan string yang dikonversi ke konsol

Keluaran

• Jika kode dijalankan dengan benar, Anda akan melihat output di atas di konsol. Output ini akan sama dengan yang ada di data. file txt

Menulis ke file

Dengan cara yang sama, saat kita membuat aliran baca, kita juga bisa membuat aliran tulis untuk menulis data ke file. Pertama mari kita buat file kosong tanpa isi yang disebut data. txt. Anggaplah file ini ditempatkan di drive D komputer kita

Kode di bawah ini menunjukkan bagaimana kita dapat menulis data ke file

var fs = require("fs");
var stream;
stream = fs.createWriteStream("D://data.txt");

stream.write("Tutorial on Node.js")
stream.write("Introduction")
stream.write("Events")
stream.write("Generators")
stream.write("Data Connectivity")
stream.write("Using Jasmine") 

Penjelasan Kode. -

1. Kami membuat aliran yang dapat ditulis dengan menggunakan metode – createWriteStream. Sebagai input, kami memberikan lokasi data kami. txt
2. Selanjutnya kami menggunakan aliran. tulis metode untuk menulis baris teks yang berbeda ke file teks kita. Aliran akan menangani penulisan data ini ke data. txt

Jika Anda membuka data. txt, Anda sekarang akan melihat data berikut dalam file

Tutorial Node. js

pengantar

Acara

Generator

Konektivitas Data

Menggunakan Jasmin

Pipa di Node. js

Di dalam aplikasi Node, aliran dapat disalurkan bersama menggunakan metode pipe() , yang membutuhkan dua argumen

• Aliran wajib yang dapat ditulis yang bertindak sebagai tujuan untuk data dan
• Objek opsional yang digunakan untuk meneruskan opsi

Contoh tipikal penggunaan pipa, jika Anda ingin mentransfer data dari satu file ke file lainnya

Jadi mari kita lihat contoh bagaimana kita dapat mentransfer data dari satu file ke file lainnya menggunakan pipa

Langkah 1) Buat file bernama datainput. txt yang memiliki data di bawah ini. Anggaplah file ini disimpan di drive D mesin lokal kita

Tutorial Node. js

pengantar

Acara

Generator

Konektivitas Data

Menggunakan Jasmin

Langkah 2) Buat file kosong kosong bernama dataOutput. txt dan meletakkannya di drive D mesin lokal Anda

Langkah 3) Tulis kode di bawah ini untuk melakukan transfer data dari input data. txt ke dataOutput. txt

var fs = require("fs");
var readStream = fs.createReadStream("D://datainput.txt");
var writeStream = fs.createWriteStream("D://dataOutput.txt");
readStream.pipe(writeStream);

Penjelasan Kode. -

1. Kami pertama kali membuat "readstream" ke input data kami. txt yang berisi semua data kami yang perlu ditransfer ke file baru
2. Kami kemudian perlu membuat "writestream" ke dataOutput kami. txt, yang merupakan file kosong kami dan merupakan tujuan transfer data dari input data. txt
3. Kami kemudian menggunakan perintah pipa untuk mentransfer data dari aliran baca ke aliran tulis. Perintah pipa akan mengambil semua data yang masuk ke aliran baca, dan mendorongnya ke aliran tulis

Jika Anda sekarang membuka dataOutput. txt, Anda akan melihat semua data yang ada di datainput. txt

Acara di Node. js

Acara adalah salah satu konsep kunci dalam Node. js dan terkadang Node. js disebut sebagai kerangka kerja yang digerakkan oleh Peristiwa

Pada dasarnya peristiwa adalah sesuatu yang terjadi. Misalnya, jika koneksi dibuat ke database, maka peristiwa koneksi database dipicu. Pemrograman berbasis peristiwa adalah untuk membuat fungsi yang akan dipicu saat peristiwa tertentu dipicu

Mari kita lihat contoh dasar untuk mendefinisikan suatu peristiwa di Node. js

Kami akan membuat acara yang disebut 'data_received'. Saat peristiwa ini dipicu, teks "data diterima" akan dikirim ke konsol

var events = require('events');
var eventEmitter = new events.EventEmitter();
eventEmitter.on('data_received', function() {
    console.log('data received succesfully.');
});

eventEmitter.emit('data_received'); 

Penjelasan Kode. -

1. Gunakan fungsi yang diperlukan untuk memasukkan modul 'acara'. Dengan modul ini, Anda akan dapat membuat acara di Node. js
2. Buat emitor peristiwa baru. Ini digunakan untuk mengikat acara, yang dalam kasus kami adalah "data_received" ke fungsi panggilan balik yang ditentukan di step3
3. Kami mendefinisikan fungsi berbasis peristiwa yang mengatakan bahwa jika seandainya peristiwa "data_received" dipicu maka kami harus menampilkan teks "data_received" ke konsol
4. Akhirnya, kami memiliki pemicu manual acara kami menggunakan eventEmitter. memancarkan fungsi. Ini akan memicu peristiwa data_received

Saat program dijalankan, teks “data diterima” akan dikirim ke konsol seperti gambar di bawah ini

Memancarkan Peristiwa

Saat mendefinisikan peristiwa, ada berbagai metode untuk peristiwa yang dapat dipanggil. Topik ini berfokus pada melihat masing-masing dari mereka secara rinci

1. Penangan kejadian satu kali

Terkadang Anda mungkin tertarik untuk bereaksi terhadap suatu peristiwa hanya saat pertama kali terjadi. Dalam situasi ini, Anda dapat menggunakan metode once()

Mari kita lihat bagaimana kita dapat menggunakan metode sekali untuk event handler

Penjelasan Kode. -

1. Di sini kita menggunakan metode 'sekali' untuk mengatakan bahwa untuk acara 'data_received', fungsi callback hanya boleh dijalankan sekali
2. Di sini kami secara manual memicu acara 'data_received'
3. Saat peristiwa 'data_received' dipicu lagi, kali ini tidak akan terjadi apa-apa. Ini karena langkah pertama di mana kami mengatakan bahwa acara hanya dapat dipicu satu kali

Jika kode dijalankan dengan benar, keluaran di log akan menjadi 'data_received succesful'. Pesan ini hanya akan muncul sekali di konsol

1. Memeriksa Pendengar Acara

Kapan pun dalam masa pakainya, emitor peristiwa dapat memiliki nol atau lebih pendengar yang melekat padanya. Pemroses untuk setiap jenis peristiwa dapat diperiksa dengan beberapa cara

Jika Anda hanya tertarik untuk menentukan jumlah pendengar terlampir, lihat EventEmitter. metode listenerCount()

(Catatan. Pendengar penting karena program utama harus tahu jika pendengar ditambahkan dengan cepat ke suatu acara, jika tidak, program akan gagal berfungsi karena pendengar tambahan akan dipanggil. )

Penjelasan Kode. -

1. Kami mendefinisikan tipe eventEmitter yang diperlukan untuk menggunakan metode terkait peristiwa
2. Kami kemudian mendefinisikan objek yang disebut emitor yang akan digunakan untuk menentukan penangan acara kami
3. Kami membuat 2 event handler yang pada dasarnya tidak melakukan apa-apa. Ini dibuat sederhana untuk contoh kita hanya untuk menunjukkan bagaimana metode listenerCount bekerja
4. Sekarang ketika Anda memanggil metode listenerCount pada peristiwa data_received kami, itu akan mengirimkan jumlah pendengar peristiwa yang dilampirkan ke peristiwa ini di log konsol

Jika kode dijalankan dengan benar, nilai 2 akan ditampilkan di log konsol

1. Acara Pendengar baru

Setiap kali event handler baru didaftarkan, emitor event memancarkan event newListener. Acara ini digunakan untuk mendeteksi penangan acara baru. Anda biasanya menggunakan event newListener saat Anda perlu mengalokasikan sumber daya atau melakukan beberapa tindakan untuk setiap pengendali event baru

var events = require('events');
var eventEmitter = events.EventEmitter;
var emitter = new eventEmitter();
emitter.on("newListener", function(eventName, listener) {
    console.log("Added listener for " + eventName + " events");
});
emitter.on('data_received', function() {});
emitter.on('data_received', function() {}); 

Penjelasan Kode. -

1. Kami sedang membuat event handler baru untuk event 'newListener'. Jadi, setiap kali event handler baru didaftarkan, teks "Added listener for" + nama event akan ditampilkan di konsol
2. Di sini kami menulis ke konsol teks "Added listener for" + nama acara untuk setiap acara yang terdaftar
3. Kami mendefinisikan 2 penangan acara untuk acara kami 'data_received'

Jika kode di atas dijalankan dengan benar, teks di bawah ini akan ditampilkan di konsol. Itu hanya menunjukkan bahwa event handler 'newListener' dipicu dua kali

Bagaimana cara mengubah file menjadi array byte dalam JavaScript?

Bagaimana cara mengonversi aliran ke file di nodejs?

Apa itu aliran byte dalam JavaScript?

Bagaimana cara mengubah file menjadi array byte di Angular 6?