Pengendalian Data yang Cekap dengan Node.js Streams

Dalam artikel ini, kami akan menyelami jauh ke dalam Strim Node.js dan memahami cara ia membantu dalam memproses sejumlah besar data dengan cekap. Strim menyediakan cara yang elegan untuk mengendalikan set data yang besar, seperti membaca fail besar, memindahkan data melalui rangkaian atau memproses maklumat masa nyata. Tidak seperti operasi I/O tradisional yang membaca atau menulis keseluruhan data sekali gus, menstrim memecahkan data kepada bahagian yang boleh diurus dan memprosesnya sekeping demi sekeping, membolehkan penggunaan memori yang cekap.

Dalam artikel ini, kami akan membincangkan:

1. Apakah itu Node.js Streams?
2. Jenis strim yang berbeza dalam Node.js.
3. Cara membuat dan menggunakan strim.
4. Kes penggunaan dunia sebenar untuk strim.
5. Kelebihan menggunakan strim.

Apakah Strim Node.js?

Satu strim dalam Node.js ialah aliran data yang berterusan. Strim amat berguna untuk mengendalikan tugas terikat I/O, seperti membaca fail, berkomunikasi melalui rangkaian atau berinteraksi dengan pangkalan data. Daripada menunggu keseluruhan operasi selesai, strim membolehkan data diproses dalam bahagian.

Ciri-ciri Utama Strim:

• Didorong Peristiwa: Strim dibina di atas seni bina dipacu peristiwa Node.js, yang membolehkan data pemprosesan sebaik sahaja tersedia.
• Cekap Memori: Menstrim memecahkan data menjadi kepingan dan memprosesnya sekeping demi sekeping, mengurangkan beban memori pada sistem anda.
• Tidak Menyekat: Strim Node.js boleh mengendalikan data besar secara tidak segerak tanpa menyekat gelung acara utama.

Jenis Strim dalam Node.js

Node.js menyediakan empat jenis strim:

1. Strim Boleh Dibaca: Strim dari mana anda boleh membaca data.
2. Strim Boleh Tulis: Strim yang anda boleh tulis data.
3. Strim Dupleks: Strim yang boleh dibaca dan boleh ditulis (cth., soket rangkaian).
4. Ubah Strim: Strim yang mengubah suai atau mengubah data semasa membaca atau menulis (cth., memampatkan atau menyahmampat fail).

Menggunakan Node.js Streams

Mari teroka setiap jenis strim dengan contoh.

3.1 Strim Boleh Baca

Strim boleh dibaca membolehkan anda membaca data sekeping demi sekeping, yang berguna untuk mengendalikan fail besar atau sumber data masa nyata.

const fs = require('fs');

// Create a readable stream from a large file
const readableStream = fs.createReadStream('largeFile.txt', {
    encoding: 'utf8',
    highWaterMark: 16 * 1024 // 16 KB chunk size
});

readableStream.on('data', (chunk) => {
    console.log('New chunk received:', chunk);
});

readableStream.on('end', () => {
    console.log('Reading file completed');
});

• Dalam contoh ini, kaedah createReadStream membaca fail dalam ketulan 16 KB.
• Setiap bahagian diproses sebaik sahaja ia tersedia, dan bukannya menunggu sehingga keseluruhan fail dimuatkan ke dalam memori.
• Acara tamat menandakan selesainya proses membaca.

3.2 Aliran Boleh Tulis

Strim boleh tulis digunakan untuk menulis data secara berperingkat ke destinasi, seperti fail atau soket rangkaian.

const fs = require('fs');

// Create a writable stream to write data to a file
const writableStream = fs.createWriteStream('output.txt');

writableStream.write('Hello, world!\n');
writableStream.write('Writing data chunk by chunk.\n');

// End the stream and close the file
writableStream.end(() => {
    console.log('File writing completed');
});

• write menghantar data ke fail secara berperingkat.
• Fungsi akhir memberi isyarat bahawa tiada lagi data akan ditulis dan menutup strim.

3.3 Aliran Dupleks

strim dupleks boleh membaca dan menulis data. Satu contoh biasa ialah soket TCP, yang boleh menghantar dan menerima data secara serentak.

const net = require('net');

// Create a duplex stream (a simple echo server)
const server = net.createServer((socket) => {
    socket.on('data', (data) => {
        console.log('Received:', data.toString());
        // Echo the data back to the client
        socket.write(`Echo: ${data}`);
    });

    socket.on('end', () => {
        console.log('Connection closed');
    });
});

server.listen(8080, () => {
    console.log('Server listening on port 8080');
});

• Contoh ini mencipta pelayan gema asas yang membaca data masuk daripada klien dan menghantarnya semula.
• Strim dupleks berguna apabila komunikasi dua hala diperlukan, seperti dalam protokol rangkaian.

3.4 Aliran Transformasi

strim transformasi ialah jenis strim dupleks khas yang mengubah suai data semasa ia melaluinya. Kes penggunaan biasa ialah pemampatan fail.

const fs = require('fs');
const zlib = require('zlib');

// Create a readable stream for a file and a writable stream for the output file
const readable = fs.createReadStream('input.txt');
const writable = fs.createWriteStream('input.txt.gz');

// Create a transform stream that compresses the file
const gzip = zlib.createGzip();

// Pipe the readable stream into the transform stream, then into the writable stream
readable.pipe(gzip).pipe(writable);

writable.on('finish', () => {
    console.log('File successfully compressed');
});

• Kaedah paip digunakan untuk mengarahkan aliran data dari satu aliran ke aliran yang lain.
• Dalam kes ini, fail dibaca, dimampatkan menggunakan Gzip, dan kemudian ditulis ke fail baharu.

Kes Penggunaan Dunia Sebenar untuk Strim

4.1 Mengendalikan Fail Besar

Apabila berurusan dengan fail besar (cth., log atau media), memuatkan keseluruhan fail ke dalam memori adalah tidak cekap dan boleh menyebabkan masalah prestasi. Strim membolehkan anda membaca atau menulis fail besar secara berperingkat, mengurangkan beban pada memori.

Contoh:

• Kes Penggunaan: Pemain media yang menstrim fail video atau audio.
• Penyelesaian: Menggunakan strim memastikan pemain hanya memuatkan sebahagian kecil data pada satu masa, meningkatkan prestasi main balik dan mengurangkan penimbalan.

4.2 Pemprosesan Data Masa Nyata

Aplikasi masa nyata seperti pelayan sembang atau papan pemuka langsung perlu memproses data apabila ia tiba. Strim menyediakan cara untuk mengendalikan data ini dengan cekap, mengurangkan kependaman.

Contoh:

• Kes Penggunaan: Papan pemuka pemantauan harga saham.
• Penyelesaian: Strim membenarkan pelayan memproses harga saham masuk dalam masa nyata dan menolak kemas kini pada antara muka pengguna.

4.3 Pemampatan Fail dan Penyahmampatan

Mampatan ialah satu lagi kes penggunaan biasa untuk strim. Daripada memuatkan keseluruhan fail ke dalam memori, anda boleh memampatkan data dengan cepat menggunakan strim transform.

Contoh:

• Kes Penggunaan: Sistem sandaran yang memampatkan fail besar sebelum menyimpannya.
• Penyelesaian: Strim membenarkan fail dibaca dan dimampatkan secara berperingkat, menjimatkan masa dan mengurangkan jejak memori.

Kelebihan Menggunakan Strim

1. Kecekapan Memori: Strim berfungsi pada ketulan data, yang meminimumkan memori yang diperlukan untuk memproses fail besar atau set data.
2. Peningkatan Prestasi: Memproses data secara berperingkat mengurangkan masa yang diperlukan untuk memuatkan dan memproses sejumlah besar maklumat.
3. I/O Tidak Menyekat: Strim memanfaatkan seni bina tak segerak Node.js, membenarkan pelayan mengendalikan tugas lain semasa data sedang diproses.
4. Pemprosesan Data Masa Nyata: Strim membenarkan komunikasi masa nyata, sesuai untuk aplikasi web yang memerlukan pemindahan data kependaman rendah.
5. Fleksibiliti: Strim boleh digabungkan, disalurkan dan diubah, menjadikannya alat yang berkuasa untuk saluran paip pemprosesan data yang kompleks.

Kesimpulan

Strim Node.js menawarkan cara yang fleksibel dan cekap untuk mengendalikan sejumlah besar data, sama ada anda membaca fail, memproses permintaan rangkaian atau melakukan operasi masa nyata. Dengan memecahkan data kepada bahagian yang boleh diurus, strim membolehkan anda bekerja dengan set data yang besar tanpa mengatasi memori sistem.

Dalam artikel seterusnya, kami akan meneroka NGINX dan peranannya dalam menyajikan kandungan statik, pengimbangan beban dan berfungsi sebagai proksi terbalik dalam aplikasi Node.js. Kami juga akan membincangkan cara menyepadukan SSL dan penyulitan untuk keselamatan yang dipertingkatkan.

Atas ialah kandungan terperinci Pengendalian Data yang Cekap dengan Node.js Streams. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!