輕松創(chuàng)建nodejs服務(wù)器(9):實現(xiàn)非阻塞操作
我們要將response對象(從服務(wù)器的回調(diào)函數(shù)onRequest()獲?。┩ㄟ^請求路由傳遞給請求處理程序。隨后,處理程序就可以采用該對象上的函數(shù)來對請求作出響應(yīng)。
我們先對server.js做出修改:
var http = require("http");
var url = require("url");
function start(route, handle) {
function onRequest(request, response) {
var pathname = url.parse(request.url).pathname;
console.log("Request for " + pathname + " received.");
route(handle, pathname, response);
}
http.createServer(onRequest).listen(8888);
console.log("Server has started.");
}
exports.start = start;
我們將response對象作為第三個參數(shù)傳遞給route()函數(shù),并且,我們將onRequest()處理程序中所有有關(guān)response的函數(shù)調(diào)都移除,因為我們希望這部分工作讓route()函數(shù)來完成。
接下來修改 router.js:
function route(handle, pathname, response) {
console.log("About to route a request for " + pathname);
if (typeof handle[pathname] === 'function') {
handle[pathname](response);
} else {
console.log("No request handler found for " + pathname);
response.writeHead(404, {"Content-Type": "text/plain"});
response.write("404 Not found");
response.end();
}
}
exports.route = route;
同樣的模式:相對此前從請求處理程序中獲取返回值,這次取而代之的是直接傳遞response對象。 如果沒有對應(yīng)的請求處理器處理,我們就直接返回“404”錯誤。
接下來修改requestHandler.js:
var exec = require("child_process").exec;
function start(response) {
console.log("Request handler 'start' was called.");
exec("ls -lah", function (error, stdout, stderr) {
response.writeHead(200, {"Content-Type": "text/plain"});
response.write(stdout);
response.end();
});
}
function upload(response) {
console.log("Request handler 'upload' was called.");
response.writeHead(200, {"Content-Type": "text/plain"});
response.write("Hello Upload");
response.end();
}
exports.start = start;
exports.upload = upload;
我們的處理程序函數(shù)需要接收response參數(shù),為了對請求作出直接的響應(yīng)。 start處理程序在exec()的匿名回調(diào)函數(shù)中做請求響應(yīng)的操作,而upload處理程序仍然是簡單的回復(fù)“Hello World”,只是這次是使用response對象而已。
如果想要證明/start處理程序中耗時的操作不會阻塞對/upload請求作出立即響應(yīng)的話,可以將requestHandlers.js修改為如下形式:
var exec = require("child_process").exec;
function start(response) {
console.log("Request handler 'start' was called.");
exec("find /",
{ timeout: 10000, maxBuffer: 20000*1024 },
function (error, stdout, stderr) {
response.writeHead(200, {"Content-Type": "text/plain"});
response.write(stdout);
response.end();
}
);
}
function upload(response) {
console.log("Request handler 'upload' was called.");
response.writeHead(200, {"Content-Type": "text/plain"});
response.write("Hello Upload");
response.end();
}
exports.start = start;
exports.upload = upload;
這樣一來,當(dāng)請求http://localhost:8888/start的時候,會花10秒鐘的時間才載入,而當(dāng)請求http://localhost:8888/upload的時候,會立即響應(yīng),縱然這個時候/start響應(yīng)還在處理中。
相關(guān)文章
Node.js dgram模塊實現(xiàn)UDP通信示例代碼
這篇文章主要介紹了Node.js dgram模塊實現(xiàn)UDP通信示例代碼,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-09-09深入理解Node.js中通用基礎(chǔ)設(shè)計模式
大家在談到設(shè)計模式時最先想到的就是 singletons, observers(觀察者) 或 factories(工廠方法)。本文重點給大家介紹Node.JS一些基礎(chǔ)模式的實現(xiàn)方法,感興趣的朋友跟隨腳本之家小編一起學(xué)習(xí)吧2017-09-09用npm install時報錯node-sass npm ERR command
在用npm install時報錯npm ERR! path D:…\node-sass和npm ERR! command failed 問題,本文給大家介紹了如何解決這個問題,文中通過圖文給大家介紹的非常詳細(xì),需要的朋友可以參考下2024-03-03