node的阻塞与非阻塞

var exec = require('child_process').exec;
function start() {
    console.log('do start');
    // function sleep(seconds) {
    //     var startTime = new Date().getTime();
    //     while(new Date().getTime() <  startTime + seconds);
    // }
    // sleep(10000);
    var content ="empty";
    exec('find',function (error,stdout,stderr) {
        content = stdout;
    })
    return content;
}
function upload() {
    console.log('do upload');
    return 'upload';
}
exports.start = start;
exports.upload = upload;

引入child_process模块中的exec方法,可以被用来开启一个子进程来执行其他的程序

这里为了进行非阻塞操作,exec()调用了回调函数
这是一篇关于很好的讲解exec和spawn方法区别的链接
上述代码中,代码是同步执行的, 意味着调用exec()后,node.js会立即执行 return content,此时content仍然是“empty”,因为传递给exec()的回调函数还没有执行到--因为exec()操作是异步的。
但是这种异步是不好的

  • node.js有一种正确的实现方案以非阻塞操作进行请求响应:函数传递

应用可以通过应用各层之间的传递值的方式(请求处理程序->请求路由->服务器)将请求处理程序返回的内容传递给http服务器。
下面我们采用如下这种新的实现方式:相对采用讲内容传递给服务器的方式,我们这次采用讲服务器“传递”给内容的方式。就是讲response对象(从服务器的回调函数onRequest()获取)通过请求路由传递给请求处理程序。随后,处理程序就可以采用该对象上的函数来对请求作出相应。
先从sever.js开始

var http = require('http');
var url =require('url');
function start(route,handle) {
    function onRequest(request,response) {
        var pathname = url.parse(request.url).pathname;
        if (pathname === '/favicon.ico') {

        }else{
            response.writeHead(200,{'Content-Type':'text/plain'});
            route(handle,pathname,response);
            // var content = route(handle,pathname,response);
            // response.write(content);
            // response.end();    
        }

    }
    http.createServer(onRequest).listen(80);
    console.log('server running at 80');
}
exports.start = start;

相比之前从route()函数获取返回值的做法,这次我们京response对象作为第三个参数传递给route()函数,并且,我们将onRequest()处理程序中所有有关response的函数调用都移除,因为我们希望这部分工作又route()完成
下面修改router.js


function route(handle,pathname,response) {
    if (typeof handle[pathname] ==='function') {
        return handle[pathname](response);
    }else{
        console.log('no request'+pathname);
        response.writeHead(404,{"Content-Type":"text/plain"});
        response.write('404 NOT FOUND');
        response.end();
    }
}
exports.route = route;

同样的,用直接传递response对象,如果没有对应的请求处理信息就返回404错误

最后修改requestHandler.js

var exec = require('child_process').exec;

function start(response) {
    console.log('do start');
    exec('ipconfig',{encoding:"gbk",timeout:10000,maxBuffer:20000*1024},function (error,stdout,stderr) {
        response.writeHead(200,{"Content-Type":"text/plain;charset:utf-8"});
        response.write(stdout);
        response.end();
    })
}
function upload(response) {
    console.log('do upload');
    response.writeHead(200,{"Content-Type":"text/plain"});
    response.write('this command is upload');
    response.end();
}
exports.start = start;
exports.upload = upload;

上面这里如果encoding:"gbk"没有加,在浏览器编码是乱的。node.js默认的encoding是utf-8.如果encoding:"xxx" xxx没有被识别,那么会被转成buffer;

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 136,273评论 19 139
  • https://nodejs.org/api/documentation.html 工具模块 Assert 测试 ...
    KeKeMars阅读 11,557评论 0 6
  • 1. 简介 这篇文章主要的目的是分析理解express的源码,网络上关于源码的分析已经数不胜数,这篇文章准备另辟蹊...
    没事造轮子阅读 5,244评论 0 8
  • 女孩 女孩18岁。 听民谣,也听摇滚。 女孩喜欢红色的东西,红色的指甲油,红色的连衣裙,...
    眼泡泡阅读 1,540评论 0 0
  • 碎片化迁徙牧场,结构化产品组织 ​​​ 需求者、价值、组织分析 ​​​ 快,准,概率,动量慢,深,持续,定向
    咸叔说阅读 1,594评论 0 1

友情链接更多精彩内容