Laksanakan contoh penyekatan dalam nodejs_node.js

Pengaturcaraan satu utas dan fungsi panggil balik gaya tak segerak dalam node.js membuatkan kita kadangkala gembira dan kadangkala bimbang. Mari kita bincangkan tentang single-threading dahulu Ramai orang tertanya-tanya bagaimana single-threading node.js boleh mencapai concurrency tinggi? Isu ini bukan fokus artikel ini, jadi mari kita berhenti di situ. Untuk menjelaskannya, utas tunggal node.js hanya merujuk kepada enjin JavaScript berutas tunggal Dalam apa jua keadaan, kami tidak mempunyai cara untuk melaksanakan berbilang benang dan menyekat dalam JavaScript (kaedah yang digunakan dalam artikel ini juga tidak disegerakkan melalui Enjin V8); tetapi untuk nod Aspek lain .js tidak bermakna ia tidak boleh berbilang benang, seperti IO. Jika node.js kini tertakluk kepada sejumlah besar permintaan, dan permintaan ini adalah IO intensif, maka setiap kali nod menerima permintaan, benang javascript tidak akan sentiasa menunggu di sini apabila menghadapi operasi IO yang panjang Sebaliknya, serahkan kawalan dan tambahkan operasi yang akan dilakukan selepas operasi IO selesai dalam tindanan panggil balik (apabila terdapat terlalu banyak tahap panggil balik dan bilangan akses terlalu besar, sebilangan besar rantai panggil balik mungkin pecah tindanan). Pada masa ini, node.js boleh mengendalikan permintaan lain. Jadi untuk node.js, walaupun javascript adalah satu-utas dan hanya boleh memproses satu permintaan pada satu masa, masa yang diperlukan untuk javascript memproses permintaan selalunya lebih pendek (untuk aplikasi intensif IO selagi ia boleh diproses). secara tidak segerak, kemudian dalam Semasa pemprosesan, permintaan ini akan melepaskan kawalan, membenarkan node.js mengendalikan permintaan lain. Semasa permintaan serentak ini, IO sebenarnya sentiasa dalam keadaan serentak, mengurangkan bilangan permintaan pemprosesan benang dan menjimatkan sumber untuk meningkatkan bilangan urutan IO Untuk permintaan intensif IO yang biasanya mengambil masa yang lama, sudah pasti ia akan membawa peningkatan prestasi .

Saya telah menekankan keamatan IO pada masa lalu, tetapi saya sebenarnya menekankan kekuatan node.js. Sejajar dengan itu, kekurangannya ialah permintaan intensif CPU. Sebabnya sangat mudah, JavaScript tidak akan serentak, dan permintaan lain hanya boleh diproses selepas satu permintaan selesai. Semakin lama satu permintaan diproses, semakin lama permintaan lain perlu menunggu. Hanya satu permintaan akan diproses pada masa yang sama, dan prestasi serentak adalah sangat rendah.

Setelah berkata demikian, saya ingin menjelaskannya: node.js tidak boleh disekat; kaedah yang boleh diproses secara tak segerak diproses secara tak segerak (seperti menggunakan fs.readFile() dan bukannya fs.syncReadFile() fs.readFileSync () kaedah).

Tidak boleh disekat dalam nod, tidak bermakna ia tidak boleh disekat di luar nod. Kami bercakap tentang serat sebelum ini, mari cuba melaksanakan penyekatan dalam gentian. Mari kita ambil pemprosesan permintaan http sebagai contoh:

Salin kod Kod adalah seperti berikut:

var Fiber = memerlukan('fibers');
var http = memerlukan("http");
Gentian(fungsi () {
var httpFiber = Fiber.current;
var html = "";
http.get("http://www.baidu.com", fungsi (res) {
        var dataFiber = Fiber.current;
res.on("data", fungsi (data) {
               html = data;
        });
          res.on("end", fungsi (data) {
httpFiber.run();
        });
});
Fiber.yield();
console.log(html);
}).run();

Bagi pelajar yang tidak biasa dengan kaedah

yield() dan run(), sila semak "fibers in nod" sendiri.

Gentian tidak berjalan dalam proses nod, jadi penyekatan dalam gentian tidak mempunyai kesan ke atas prestasi keseluruhan nod. Dan ia agak mudah untuk dilaksanakan Anda hanya perlu menghasilkan serat apabila anda ingin menyekat. Jika anda perlu terus berjalan, jalankan run() untuk memulihkan gentian. Dalam contoh di atas, kami ingin menyekat program semasa apabila permintaan http.get dimulakan dan menyambung semula program apabila semua penerimaan data selesai. Jadi kami menggunakan Fiber.yield() untuk mengganggu gentian ini selepas memanggil http.get. Dalam memantau tindak balas, jika peristiwa akhir dicetuskan, ia menunjukkan bahawa penghantaran data telah selesai, jadi dalam fungsi panggil balik akhir, panggil Fiber.current.run() untuk memulihkan gentian Dengan cara ini, kod berikutnya akan mendapat http.dapatkan data yang diminta.

Contoh di atas hanyalah untuk memberikan idea. Jika anda membuat beberapa pengkapsulan abstrak idea ini, contohnya, lakukan kari satu langkah pada kaedah tak segerak yang menerima fungsi panggil balik sebagai parameter, ganggu selepas panggilan dan rampas fungsi panggil balik untuk memulihkan kod program sebagai panggilan balik. fungsi. Selepas mendapatkan data tak segerak, program ini mencetuskan fungsi panggil balik yang telah ditetapkan, yang pada asasnya boleh merealisasikan penyegerakan kaedah tak segerak. Perenggan ini agak mengelirukan, tetapi pada dasarnya ia adalah idea pelaksanaan gentian/masa depan Jika anda berminat, sila rujuk kod sumbernya.