轻松创建nodejs服务器(9):实现非阻塞操作
我们要将response对象(从服务器的回调函数onRequest()获取)通过请求路由传递给请求处理程序。随后,处理程序就可以采用该对象上的函数来对请求作出响应。
我们先对server.js做出修改:
varhttp=require("http"); varurl=require("url"); functionstart(route,handle){ functiononRequest(request,response){ varpathname=url.parse(request.url).pathname; console.log("Requestfor"+pathname+"received."); route(handle,pathname,response); } http.createServer(onRequest).listen(8888); console.log("Serverhasstarted."); } exports.start=start;
我们将response对象作为第三个参数传递给route()函数,并且,我们将onRequest()处理程序中所有有关response的函数调都移除,因为我们希望这部分工作让route()函数来完成。
接下来修改router.js:
functionroute(handle,pathname,response){ console.log("Abouttoroutearequestfor"+pathname); if(typeofhandle[pathname]==='function'){ handle[pathname](response); }else{ console.log("Norequesthandlerfoundfor"+pathname); response.writeHead(404,{"Content-Type":"text/plain"}); response.write("404Notfound"); response.end(); } } exports.route=route;
同样的模式:相对此前从请求处理程序中获取返回值,这次取而代之的是直接传递response对象。如果没有对应的请求处理器处理,我们就直接返回“404”错误。
接下来修改requestHandler.js:
varexec=require("child_process").exec; functionstart(response){ console.log("Requesthandler'start'wascalled."); exec("ls-lah",function(error,stdout,stderr){ response.writeHead(200,{"Content-Type":"text/plain"}); response.write(stdout); response.end(); }); } functionupload(response){ console.log("Requesthandler'upload'wascalled."); response.writeHead(200,{"Content-Type":"text/plain"}); response.write("HelloUpload"); response.end(); } exports.start=start; exports.upload=upload;
我们的处理程序函数需要接收response参数,为了对请求作出直接的响应。start处理程序在exec()的匿名回调函数中做请求响应的操作,而upload处理程序仍然是简单的回复“HelloWorld”,只是这次是使用response对象而已。
如果想要证明/start处理程序中耗时的操作不会阻塞对/upload请求作出立即响应的话,可以将requestHandlers.js修改为如下形式:
varexec=require("child_process").exec; functionstart(response){ console.log("Requesthandler'start'wascalled."); exec("find/", {timeout:10000,maxBuffer:20000*1024}, function(error,stdout,stderr){ response.writeHead(200,{"Content-Type":"text/plain"}); response.write(stdout); response.end(); } ); } functionupload(response){ console.log("Requesthandler'upload'wascalled."); response.writeHead(200,{"Content-Type":"text/plain"}); response.write("HelloUpload"); response.end(); } exports.start=start; exports.upload=upload;
这样一来,当请求http://localhost:8888/start的时候,会花10秒钟的时间才载入,而当请求http://localhost:8888/upload的时候,会立即响应,纵然这个时候/start响应还在处理中。