美文网首页
node的阻塞与非阻塞

node的阻塞与非阻塞

作者: 围墙w | 来源:发表于2017-01-07 17:45 被阅读0次
    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;

    相关文章

      网友评论

          本文标题:node的阻塞与非阻塞

          本文链接:https://www.haomeiwen.com/subject/gacxbttx.html