Nodejs学习第三天

作者: _palm | 来源:发表于2016-10-13 16:37 被阅读81次

    Nodejs学习第二天,我学习了如何将不同的请求比较有效正确的转发路由,使用了Node内置模块urlhttp,同时,使用url模块提供解析函数 url#parse ,来获取各个请求路劲,api长这样:

    url.parse(urlString[, parseQueryString[, slashesDenoteHost]])
    

    例如: 在浏览器地址栏输入: http://localhost:8081/upload

    var rurl = 'http://localhost:8081/upload' ;
    var pathname = url.parse(url).pathname ; //得到值得为:/upload
    

    通过将不同的业务使用单独模块分离出来,如: dispatcher.js 然后利用javaScript 对象的数据结构和函数是第一等对象特性使访问路径和具体的业务逻辑关联起来。

    如此算是解决了服务器对请求分发的问题,但同时也暴露了这种结构的一个致命的缺点,就是依然没有改变javaScript 代码串行执行的特性。如下代码:

    //index.js
    var server = require('./server'),
        router = require('./router'),
        dispatcher = require('./dispatcher') ;
    //以上模块引入代码,require调用的时候需要注意模块文件的相对路径. 
    //这里的index.js/server.js/dispatcher.js/router.js都是同级目录存在.
    var hander = {} ;
    
    hander['/'] = dispatcher['root'] ;
    hander['/start'] = dispatcher['start'] ;
    hander['/upload'] = dispatcher['upload'] ;
    console.log('hander ',hander) ;
    
    server.start(router.route,hander) ;
    
    //dispatcher.js  
    exports.start = function() {
        console.log('/start') ;
    
        //
        wait(10000) ;
    
    
        return 'the server started.' ;
    
    
        function wait(milliSeconds) {
            var now = new Date().getTime() ;
            while(new Date().getTime() < now + milliSeconds) {
                //continue
            }
        }
    
    }
    
    
    exports.root = function() {
        console.log('call root.') ;
        return 'welcome to visit' ;
    }
    
    exports.upload = function() {
    
        console.log('upload') ;
    
        return 'upload file is none' ;
    }
    
    // router.js
    exports.route = function (pathname,hander) {
    
        var ef = hander[pathname] ;
        console.log('route path ', pathname) ;
    
        if (typeof ef === 'function') {
            //
            return ef.call(null,arguments) ;
        }else {
            return '404 Unknown path.' ;
        }
    }
    
    //server.js
    
    var http = require('http'), 
        url = require('url') ; 
    
    exports.start = function(route,hander) {
            //
        http.createServer(onRequest).listen(8081) ;
        
        function onRequest(req,res) {
            //
            var pathname = url.parse(req.url).pathname ;
            var text = route(pathname,hander) ;
            console.log('text ',text) ;
            res.writeHead(200,{'Content-Type':'text/plain'}) ;
            res.write(text) ;
            res.end() ;
        }
    
        console.log('node server has started.......') ;
    }
    

    上面代码在访问/start 的时候可以看到浏览器title会转圈10s左右的时间,然后才会输出the server started. 假如同时有两个请求到达,server模块会如何处理? 按照如下操作:

    1. 打开两个标签页或者窗口分屏铺开(win下 Win + Left/Right 左右分屏 Arch#Gnome3.20默认为super + Left/Right 一般和win下一致)

    2. 分别输入: http://localhost:8081/start / http://localhost:8081/upload

    3. 切换到/start 页面按下Enter 快速切换到/upload 页面同时按下Enter

      可以看到页面/upload页面也和/start页面一样出现一直转圈的情况,等待10s后,/start/upload 页面几乎同时输出了信息,如果单独访问/upload ,页面瞬间就有输出upload file is none ,这说明导致这个问题的原因不在于'/upload' 而是被/start 影响到了.
      这种现象其实是因为目前代码实现的 server 都串行处理所有的请求,/start由于有10s的处理时间,对于其他请求来说,也就需要等待10s,/start 阻塞了所有其他的处理工作.

    这和官网 About Node.js 描述有所差异:

    As an asynchronous event driven JavaScript runtime.........................

    其实,nodejs 本质上和javascript一样是单线程执行任务的,一个任务没有执行完,之后的任务只能等待,但是nodejs 采用了一个叫做事件轮询(event loop)机制来实现并行操作,也就是多任务异步执行。

    事件轮询 的解释大概如下:
    前端所有的请求(事件)都会进入一个事件队列,这个队列采用FIFO模型通信(一端put事件,另一端pull事件,这个队列是这两端唯一的通信渠道),在node中只有一个线程用来专门轮训这个队列中是否有事件,如果有则将I/OHttp请求等易阻塞事件交给底层C/C++(是C/C++吗?不太确定,不过官网上有C/C++和nodejs交互api)实现的线程池来做,同时也会将回调函数一并交给线程池,之后单线程不会等待事件的执行结果,而是继续处理队列中下一个事件,等这个阻塞操作完成后,线程池会将结果和回调函数一并再放入这个事件队列,然后单线程获取到之后会执行该回调函数。

    可以说,nodejs表面上看起来的多线程或异步操作是完全基于javaScript回调函数的。没有回调函数,则不能通知对应线程继续完成后续操作。

    nodejs很多模块均提供了异步操作,如:fs模块 / child_process#exec函数等,如下代码:

    //dispatcher.js
    var process = require('child_process') ;
    
    exports.start = function(res) {
        console.log('/start') ;
        process.exec("find  / ", function (error, stdout, stderr) {
            var content = stdout ;
            if (!content) {
                content = 'empty dir.' ;
             }
    
            res.writeHead(200,{'Content-Type':'text/plain'}) ;
            res.write(content) ;
                res.end() ;
        });
    
        // //
        // wait(10000) ;
    
    
        // return 'the server started.' ;
    
    
        // function wait(milliSeconds) {
        //  var now = new Date().getTime() ;
        //  while(new Date().getTime() < now + milliSeconds) {
        //      //continue
        //  }
        // }
    
    }
    
    
    exports.root = function(res) {
        console.log('call root.') ;
        res.writeHead(200,{'Content-Type':'text/plain'}) ;
        res.write('welcome to visit') ;
        res.end() ;
    }
    
    exports.upload = function(res) {
        console.log('upload') ;
        res.writeHead(200,{'Content-Type':'text/plain'}) ;
        res.write('upload file is none') ;
        res.end() ;
    }
    

    上面代码调整了各个函数的参数,参数新增response对象来处理页面信息和结束请求操作。 这是因为 exec函数是异步操作,如果/start 请求响应函数代码如下:

    exports.start = function(res) {
        console.log('/start') ;
            var content = 'empty dir' ;
          process.exec("find  / ", function (error, stdout, stderr) {
            content = stdout ;
          });
    
      return content ;
    }
    

    然后server.js中回调函数中处理逻辑如:

    //server.js
    var http = require('http'), 
        url = require('url') ; 
    
    exports.start = function(route,hander) {
    
        http.createServer(onRequest).listen(8081) ;
        
        function onRequest(req,res) {
            //
            var pathname = url.parse(req.url).pathname ;
            var text = route(pathname,hander) ;
            console.log('text ',text) ;
            res.writeHead(200,{'Content-Type':'text/plain'}) ;
            res.write(text) ;
            res.end() ;
        }
    
        console.log('node server has started.......') ;
    }
    

    相信有几乎100%概率向页面输出 empty dir,在非空目录的情况下. 当onRequest函数执行到 res.end() ;的时候可能 var text = route(pathname,hander) ; 还没有返回。

    继续调整router.js代码:

    //router.js
    //添加参数,并将这个参数传递给各个回调函数
    exports.route = function (pathname,hander,res) {
    
        var ef = hander[pathname] ;
        console.log('route path ', pathname) ;
    
        if (typeof ef === 'function') {
            //
            return ef.call(null,res) ;
        }else {
            res.writeHead(200,{'Content-Type':'text/plain'}) ;
            res.write('404 Unknown path.') ;
            res.end() ;
        }
    }
    
    //server.js
    var http = require('http'), 
        url = require('url') ; 
    
    exports.start = function(route,hander) {
        http.createServer(onRequest).listen(8081) ;
            function onRequest(req,res) {
            //
            var pathname = url.parse(req.url).pathname ;
            route(pathname,hander,res) ;
            // var text = route(pathname,hander) ;
            // console.log('text ',text) ;
            // res.writeHead(200,{'Content-Type':'text/plain'}) ;
            // res.write(text) ;
            // res.end() ;
        }
    
        console.log('node server has started.......') ;
    }
    

    然后执行服务启动命令可以看到页面有输出根(/)目录下的全部目录和文件 ;
    nodejs第三天的学习到这里就结束啦! ~#-_- 加油!!!

    如果您看到以上内容有错误,请您一定谦虚指出! 哈哈哈哈 开玩笑,只要您说得对,我绝对洗耳恭听!! #=_=

    相关文章

      网友评论

        本文标题:Nodejs学习第三天

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