Nodejs学习第4天

作者: _palm | 来源:发表于2016-10-15 16:26 被阅读76次

    之前我学习了使用Node.js实现一个简单的Server (见Nodejs学习第一天)这让我想起了当初学习java-web的时候,使用java #net 包下的Socket 实现一个简单的类似tomcat 的一个小Http服务器,如:

            ServerSocket serverSocket = new ServerSocket(8080) ;
            Socket socket = serverSocket.accept() ;
            InputStream in = new FileInputStream(new File("/home/palm/myapps/node-study/oneself/server.js")) ;
            OutputStream outputStream = socket.getOutputStream() ;
            int len = 0 ;
            byte[] b = new byte[1024] ;
            while((len = in.read(b)) != -1) {
                outputStream.write(b,0,len);
            }
    

    运行上面的java 代码, 一个没有任何处理能力的简单Http服务器就可以使用了,上面代码只是输出了文件内容,当然也可以接收前端页面传递的参数。访问http://localhost:8080/ 就可以看到输出文件server.js的内容了。如下:

    Screenshot from 2016-10-14 23-41-40.png

    之后又学习了使用内置模块来处理多请求分发的问题,再次通过调整整体代码架构来适应web多线程并发异步处理的问题。
    <em>
    到这里,差不多就是node.js对http server支持的基础的部分了. 我个人理解是node.js是又一个JavaScript运行时环境,其实node官网也是这么解释的,之前 JavaScript 之运行在浏览器中,比如IE、Chomre、Firefox等。

    谁都知道瘟到死下的IE提供的 JavaScript运行环境处处是坑,各种乱七八糟的非标准解释,导致 JavaScript在其下运行各种问题。兼容问题层出不穷。

    但是这些问题在Node.js下不会再产生了,因为Node.js使用了chrome浏览器的V8引擎来解释JavaScript代码。在Node下只有一个标准就是遵循当前ECMAScript标准来解释执行代码,使用当前ECMA支持语法就可以得到正确的结果。不会有一行代码执行结果各不相同。
    </em>

    Node.js® is a JavaScript runtime built on Chrome's V8 JavaScript engine. ...........

    之前的node.js代码向页面输出的都是一些简单的问题,接下来的代码会看起来更web一点,因为可以有用户交互了,如下:
    将之前的dispatcher.js #start函数修改下,将一个简单的html代码输出并采用html数据格式解析,就像在进入java-web学习的时候在学习jsp之前,就直接在servlet中write html代码:

     function start(res) {
      console.log('call /start');
      /**var process = require('child_process') ;
       process.exec('cd /home/palm/ && find *',function(error,stdout,stdrr) {
       //
       res.writeHead(200,{'Content-Type':'text/plain'}) ;
       res.write(stdout) ;
       res.end() ;
       }) ;*/
    
      var body = '<html>' +
          '<head>' +
          '<meta http-equiv="Content-Type" content="text/html; ' +
          'charset=UTF-8" />' +
          '</head>' +
          '<body>' +
          '<form action="/upload" method="post">' +
          '<textarea name="text" rows="15" cols="50"></textarea>' +
          '<input type="submit" value="提交" />' +
          '</form>' +
          '</body>' +
          '</html>';
    
      res.writeHead(200, {'Content-Type': 'text/html'}); //注意这里的内容头声明
      res.write(body);
      res.end();
     }
    
     function upload(res) {
      console.log('call /upload') ;
      res.writeHead(200,{'Content-Type':'text/plain'}) ;
      res.write('call /upload') ;
      res.end() ;
     }
    
     function root(res) {
      console.log('call /') ;
      res.writeHead(200,{'Content-Type':'text/plain'}) ;
      res.write('call /') ;
      res.end() ;
     }
    
     exports.start = start ;
     exports.upload = upload ;
     exports.root = root ;
    

    访问 http://localhost:8081/start 就可以看到一个可以提交的简单表单,然后修改下/upload 来响应这个表单的请求(上述输出html提交路径是/upload).

    /upload中一定需要采用异步处理机制,否则就产生阻塞了,所以这里需要进行适当的调整。这里node采用了一个特定的事件 --- data事件用来处理数据接收 以及end事件来标识数据接收完毕。根据node异步实现机制 ---- 事件轮询 , 事件node已经提供了,剩下的需要我们提供对应事件触发后该做什么,也就是回调函数。所以只需要将这两个回调函数提供给node就可以了。

    因为这两个事件都是发生在请求服务的过程中,所以把这两个事件注册到request对象上就显得很合理了,如:

    //server.js
     //导入http 和 url模块 类似java的 Map\List等工具类
    var http = require('http'),
        url = require('url') ;
     //编写服务启动函数,这里的参数稍后解释
     //function start(handle,route) {
     function start(hander,route) {
      //请求处理函数,就是第一天学习的箭头函数,这里不再是一个匿名函数
      function onRequest(req,res) {
       //这里通过url模块提供函数 parse获得请求方法,详细可以参考node官方网站document说明
       var pathName = url.parse(req.url).pathname ;
       console.log('request path ',pathName) ;
    
       var postData = '' ;
       req.setEncoding("utf8");
       req.addListener('data',function(postDataChunk){
        //
        postData = postDataChunk ;
       }) ;
    
       //end
       req.addListener('end',function(){
        //
        route(pathName,hander,res,postData) ;
       }) ;
    
       //dispatcher
       //route(pathName,hander,res) ;
      }
    
      http.createServer(onRequest).listen(8081) ;
      console.log('server has started.') ;
     }
    
     //将函数start函数导出为一个模块
     //export
     exports.start = start ;
    
    //dispatcher.js
     function start(res,postData) {
      console.log('call /start');
      /**var process = require('child_process') ;
       process.exec('cd /home/palm/ && find *',function(error,stdout,stdrr) {
       //
       res.writeHead(200,{'Content-Type':'text/plain'}) ;
       res.write(stdout) ;
       res.end() ;
       }) ;*/
    
      var body = '<html>' +
          '<head>' +
          '<meta http-equiv="Content-Type" content="text/html; ' +
          'charset=UTF-8" />' +
          '</head>' +
          '<body>' +
          '<form action="/upload" method="post">' +
          '<textarea name="text" rows="15" cols="50"></textarea>' +
          '<input type="submit" value="提交" />' +
          '</form>' +
          '</body>' +
          '</html>';
    
      res.writeHead(200, {'Content-Type': 'text/html'});
      res.write(body);
      res.end();
     }
    
     function upload(res,postData) {
      console.log('call /upload') ;
      res.writeHead(200,{'Content-Type':'text/plain'}) ;
      res.write(postData) ;
      res.end() ;
     }
    
     function root(res,postData) {
      console.log('call /') ;
      res.writeHead(200,{'Content-Type':'text/plain'}) ;
      res.write('call /') ;
      res.end() ;
     }
    
     exports.start = start ;
     exports.upload = upload ;
     exports.root = root ;
    
    //router.js
     function route(path,handle,res,postData) {
      console.log('route path ',path) ;
    
      var fun = handle[path] ;
      if(typeof fun === "function") {
       fun.call(null,res,postData) ;
      }else {
       console.log('unknown path.') ;
       res.writeHead(200,{'Content-Type':'text/plain'}) ;
       res.write('404 Unknown path') ;
       res.end() ;
      }
     }
    
     exports.route = route ;
    

    //index.js 不用改变

    重启服务,访问 http://localhost:8081/start 输入在文本域内输入内容,点击提交 可以看到页面条装到 http://localhost:8081/upload 并输出刚才录入的内容。
    大概的数据流转如下:

    当我点击页面提交按钮后,将请求/upload 经过server.js #start函数 通过data 事件的回调函数获取到页面录入内容,然后数据接收完毕后触发end 事件,后通过end事件回调函数直接将此数据交给了/upload 方法,后又输出到页面。

    如果提交中文内容会发现跳转到'/upload'页面显示的并不是我们之前输入的内容,是因为在/upload中向页面write内容并不只是我们输入的,所以这里需要使用Node内置模块querystring来获取到之前页面输入的内容:

     function upload(res,postData) {
      var querystring = require('querystring') ;
      console.log('call /upload') ;
      res.writeHead(200,{'Content-Type':'text/plain'}) ;
      res.write(querystring.parse(postData).text) ; //通过querystring获取text
      res.end() ;
     }
    

    以上就是一个简单的Node.js对Post请求的处理结构,今天的学习就到这里啦,以上代码或对Node.js的理解有错误的地方,恳请纠正! 谢谢~~ #

    相关文章

      网友评论

        本文标题:Nodejs学习第4天

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