nodejs中實(shí)現(xiàn)阻塞實(shí)例_node.js

node.js中與生俱來的單線程編程、回調(diào)函數(shù)異步式風(fēng)格讓我們有時(shí)喜有時(shí)憂。先說單線程，很多人會費(fèi)解于node.js的單線程如何能做到高并發(fā)？這個(gè)問題不是本文重點(diǎn)，點(diǎn)到為止。澄清一點(diǎn)，node.js的單線程僅僅指javascript引擎是單線程的，無論如何我們沒有辦法在javascript中實(shí)現(xiàn)多線程和阻塞（本文用到的方法同樣不是通過V8引擎實(shí)現(xiàn)同步的）；但對于node.js的其他方面不代表不能多線程，例如IO。如果現(xiàn)在node.js遭受大量請求，而這些請求都是IO密集型的，那么此時(shí)node每接受一個(gè)請求，在遇到耗時(shí)較長的IO操作時(shí)，javascript線程并不會一直在此等待，而是交出控制，在回調(diào)堆棧里添加IO操作完成后要執(zhí)行的操作（當(dāng)回調(diào)層級過多，訪問數(shù)量過大，大量的回調(diào)鏈可能會爆棧）。而在這段時(shí)間內(nèi)，node.js又可以處理其他請求了。所以對于node.js而言，雖然javascript是單線程的，每次只能處理一個(gè)請求，但javascript處理一個(gè)請求的時(shí)間往往較短（對于IO密集型應(yīng)用而言），只要可以異步處理，那么在處理的過程中，此次請求都會釋放控制，使node.js能處理其他請求。這并發(fā)請求的同時(shí)，IO其實(shí)一直處于并發(fā)狀態(tài)，減少處理請求的線程數(shù)，節(jié)約資源以增加IO的線程數(shù)，對于通常耗時(shí)很長的IO密集型請求來說，無疑能帶來性能上的提升。

前面啰啰嗦嗦地一直在強(qiáng)調(diào)IO密集型，其實(shí)是在強(qiáng)調(diào)node.js的強(qiáng)項(xiàng)。相應(yīng)的，它的短板就是CPU密集型的請求。道理很簡單，javascript不會并發(fā)，只能一個(gè)請求完成后才能處理其他請求。一個(gè)請求處理的時(shí)間越長，其他請求等待的時(shí)間越長。同一時(shí)間只會有一個(gè)請求被處理，并發(fā)性能很低。

話說到這兒，我想申明一點(diǎn)：node.js不應(yīng)該被阻塞；能異步處理的方法異步處理（如使用fs.readFile()，而非fs.syncReadFile()fs.readFileSync()方法）。

node中不能阻塞，并不代表node外不能阻塞。前面我們有講到fibers，現(xiàn)在，我們就來嘗試在fibers中實(shí)現(xiàn)阻塞。就以處理一個(gè)http請求為例吧：

代碼如下:
var Fiber = require('fibers');
var http = require("http");
Fiber(function () {
var httpFiber = Fiber.current;
var html = "";
http.get("http://www.baidu.com", function (res) {
var dataFiber = Fiber.current;
res.on("data", function (data) {
html += data;
});
res.on("end", function (data) {
httpFiber.run();
});
});
Fiber.yield();
console.log(html);
}).run();

yield()、 run()這兩個(gè)方法還不了解的同學(xué)，請自行查閱《fibers in node》。

fibers的運(yùn)行并不在node進(jìn)程中，所以在fibers內(nèi)部實(shí)現(xiàn)阻塞對node整體的性能并沒有影響。而且實(shí)現(xiàn)起來也是相當(dāng)容易，只需要在想阻塞的時(shí)候，把fiber yield掉。需要繼續(xù)運(yùn)行，則執(zhí)行 run()恢復(fù)fiber。在上面的例子中，我們希望當(dāng)http.get請求發(fā)起時(shí)阻塞當(dāng)前程序，當(dāng)所有數(shù)據(jù)接收完成時(shí)，恢復(fù)程序。于是我們在調(diào)用http.get后使用 Fiber.yield()中斷此fiber。在對response的監(jiān)聽中，如果觸發(fā) end事件表明數(shù)據(jù)傳輸完成，于是在 end的回調(diào)函數(shù)中，調(diào)用 Fiber.current.run()恢復(fù)fiber，這樣，后續(xù)的代碼就以同步的方式拿到http.get請求的數(shù)據(jù)。

上面的示例只是提供一種思路。如果對這種思路進(jìn)行一些抽象封裝，比如說，對有接受回調(diào)函數(shù)為參數(shù)的異步方法進(jìn)行一步柯里化，在調(diào)用后中斷，并劫持回調(diào)函數(shù)，以恢復(fù)程序的代碼為回調(diào)函數(shù)。獲取異步數(shù)據(jù)后，再程序觸發(fā)預(yù)定的回調(diào)函數(shù)，這樣基本能實(shí)現(xiàn)異步方法同步化。這段說得比較亂，基本上就是 fibers/future的實(shí)現(xiàn)思路，如果有興趣，請參考其源代碼。

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com