zoukankan      html  css  js  c++  java
  • NodeJS系列~第四个小例子,NodeJs处理Get请求和Post请求

    返回目录

    说在前

    对于HTTP请求来说,我们通常使用的是Get和Post,除此之外还有put,delete等,而对于get来说,比较lightweight,只是对字符串的传输,它会被添加到URL地址里,属于URL的一部分,有时,我们为了安全和兼容性问题,URL地址上的参数会进行Url.Encode,有的浏览器已经带我们做了这些;而对于Post来说,就显得重了一些,它的数据以包的形式存在,除了可以有文本信息,还可以有二进制文件流信息,这讲里,我们主要说的是Post里的文本处理。

    做在后

    一  使用NodeJs实现对Get请求的处理,nodejs接入的形式为url?param1=zzl&param2=male

    var redis = require("redis");
    var http = require('http');
    var url = require("url");
    var info = "通过HTTPGet方式成功加入队列";
    http.createServer(function (req, res) {
        var params = url.parse(req.url, true).query;//解释url参数部分name=zzl&email=zzl@sina.com
        var client = redis.createClient();
        client.lpush("topnews", params.info);
        res.writeHead(200, {
            'Content-Type': 'text/plain;charset=utf-8'
        });
        client.lpop("topnews", function (i, o) {
            console.log(o);//回调,所以info可能没法得到o的值,就被res.write输出了
        })
        client.quit();
        res.write(info);
        res.end();
    }).listen(8000, "127.0.0.1");
    console.log('Server running at http://127.0.0.1:8000/');

    测试:http://127.0.0.1:8000?info=zzl

    二  使用NodeJs实现对Post请求的处理,nodejs接入的形式为{param1="zzl",param2="male"}

    Post由于它的重量,所以不可能说接收就接收,它会存储接入中和接入完成两种状态,两种状态对应着回调方法,即,当然数据处于接入中状态时,处理一种流程;当数据接入完成后,处理另一种流程。

    //接入中 
     req.addListener("data", function (postDataChunk) {});
    //接收完成
     req.addListener("end", function () {});

    下面看一下完成的代码:

    var redis = require('redis');
    var http = require('http');
    var url = require("url");
    var querystring = require("querystring");
    http.createServer(function (req, res) {
        // 设置接收数据编码格式为 UTF-8
        req.setEncoding('utf-8');
        var postData = ""; //POST & GET : name=zzl&email=zzl@sina.com
        // 数据块接收中
        req.addListener("data", function (postDataChunk) {
            postData += postDataChunk;
        });
        // 数据接收完毕,执行回调函数
        req.addListener("end", function () {
            console.log('数据接收完毕');
            var params = querystring.parse(postData);//GET & POST  ////解释表单数据部分{name="zzl",email="zzl@sina.com"}
            console.log(params);
            console.log(params["name"]);
            PushToRedis(params["name"]);
            res.writeHead(500, {
                "Content-Type": "text/plain;charset=utf-8"
            });
            res.end("数据提交完毕");
        });
    }).listen(8000, "127.0.0.1");
    console.log('Server running at http://127.0.0.1:8000/');
    
    //表单接收完成后,再处理redis部分
    function PushToRedis(info) {
        var client = redis.createClient();
        client.lpush("topnews", info);
        console.log("PushToRedis:" + info);
        client.lpop("topnews", function (i, o) {
            console.log(o);//回调,所以info可能没法得到o的值,就被res.write输出了
        })
        client.quit();
    }

    下面看一下结果,我把它截了图:

    实事上,对于post到nodeJS再由nodeJS到redis,这个case我们经常会看到,它实现起来比IIS,apache在性能上要高很多,它没有为每个连接建立线程,它解决了IO阻塞等等,OK,说到这里,我再强调一个nodeJS用到的最重要的场合:逻辑简单的高并发场合!

    下一次,我将为大家带来NodeJS实现文件上传的功能,敬请关注!

     返回目录

  • 相关阅读:
    Cuckoo Hashing
    Microsoft Windows的消息循环
    Simplex, Full-Duplex and Half-Duplex Operation
    Linux 技巧:让进程在后台运行更可靠的几种方法
    https://learnku.com/docs/go-blog/qihoo/6532 。 heap size went up to 69G, with maximum garbage collection (GC)
    Go GC: Latency Problem Solved
    Sapphire: Copying GC Without Stopping the World
    The Go Blog Getting to Go: The Journey of Go's Garbage Collector
    xml CDATA
    Joseph cicyle's algorithm
  • 原文地址:https://www.cnblogs.com/lori/p/3437562.html
Copyright © 2011-2022 走看看